com.twosigma.beakerx.message.Header.getTypeEnum()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(1.3k)|赞(0)|评价(0)|浏览(111)

本文整理了Java中com.twosigma.beakerx.message.Header.getTypeEnum()方法的一些代码示例,展示了Header.getTypeEnum()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Header.getTypeEnum()方法的具体详情如下:
包路径:com.twosigma.beakerx.message.Header
类名称:Header
方法名:getTypeEnum

Header.getTypeEnum介绍

暂无

代码示例

代码示例来源:origin: twosigma/beakerx

public JupyterMessages type() {
 return (header != null && header.getTypeEnum() != null) ? header.getTypeEnum() : null;
}

代码示例来源:origin: twosigma/beakerx

@Test
public void handleMagicMessage_replyIsSent() throws InterruptedException {
 //when
 executeRequestHandler.handle(magicMessage);
 waitForIdleMessage(kernel);
 //then
 final List<Message> sentMessages = kernel.getSentMessages();
 assertThat(sentMessages).isNotEmpty();
 Message firstSentMessage = sentMessages.get(0);
 assertThat(firstSentMessage.getHeader().getTypeEnum()).isEqualTo(EXECUTE_REPLY);
}

代码示例来源:origin: twosigma/beakerx

private void handleControlMsg() {
 Message message = readMessage(controlSocket);
 JupyterMessages type = message.getHeader().getTypeEnum();
 if (type.equals(SHUTDOWN_REQUEST)) {
  Message reply = new Message(new Header(SHUTDOWN_REPLY, message.getHeader().getSession()));
  reply.setParentHeader(message.getHeader());
  reply.setContent(message.getContent());
  sendMsg(controlSocket, Collections.singletonList(reply));
  shutdown();
 }
}

相关文章