io.eventuate.tram.messaging.common.Message.getRequiredHeader()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(7.9k)|赞(0)|评价(0)|浏览(240)

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

Message.getRequiredHeader介绍

暂无

代码示例

代码示例来源：origin: eventuate-tram/eventuate-tram-sagas

  1. private String getSagaType(Message message) {
  2.  return message.getRequiredHeader(SagaCommandHeaders.SAGA_TYPE);
  3. }

代码示例来源：origin: eventuate-tram/eventuate-tram-core

  1. public boolean handles(Message message) {
  2.  return aggregateType.equals(message.getRequiredHeader(EventMessageHeaders.AGGREGATE_TYPE))
  3.      && eventClass.getName().equals(message.getRequiredHeader(EventMessageHeaders.EVENT_TYPE));
  4. }

代码示例来源：origin: io.eventuate.tram.core/eventuate-tram-events

  1. public boolean handles(Message message) {
  2.  return aggregateType.equals(message.getRequiredHeader(EventMessageHeaders.AGGREGATE_TYPE))
  3.      && eventClass.getName().equals(message.getRequiredHeader(EventMessageHeaders.EVENT_TYPE));
  4. }

代码示例来源：origin: io.eventuate.tram.sagas/eventuate-jpa-sagas-framework

  1. private boolean isUnlockMessage(Message message) {
  2.  return message.getRequiredHeader(CommandMessageHeaders.COMMAND_TYPE).equals(SagaUnlockCommand.class.getName());
  3. }

代码示例来源：origin: eventuate-tram/eventuate-tram-sagas

  1. @Override
  2. public boolean isSuccessfulReply(Message message) {
  3.  return CommandReplyOutcome.SUCCESS.name().equals(message.getRequiredHeader(ReplyMessageHeaders.REPLY_OUTCOME));
  4. }

代码示例来源：origin: eventuate-tram/eventuate-tram-sagas

  1. @Override
  2. public boolean isSuccessfulReply(Message message) {
  3.  return CommandReplyOutcome.SUCCESS.name().equals(message.getRequiredHeader(ReplyMessageHeaders.REPLY_OUTCOME));
  4. }

代码示例来源：origin: eventuate-tram/eventuate-tram-sagas

  1. @Override
  2. public boolean handles(Message message) {
  3.  return message.getRequiredHeader(Message.DESTINATION).equals(commandChannel) && super.handles(message) && expectedCommand.test(message);
  4. }

代码示例来源：origin: io.eventuate.tram.sagas/eventuate-tram-sagas-simple-dsl

  1. @Override
  2. public boolean isSuccessfulReply(Message message) {
  3.  return CommandReplyOutcome.SUCCESS.name().equals(message.getRequiredHeader(ReplyMessageHeaders.REPLY_OUTCOME));
  4. }

代码示例来源：origin: eventuate-tram/eventuate-tram-core

  1. @PostConstruct
  2. public void subscribe() {
  3.  messageConsumer.subscribe("etmv", singleton("*"), m -> {
  4.   String destination = m.getRequiredHeader(Message.DESTINATION);
  5.   getForDestination(destination).add(m);
  6.  });
  7. }

代码示例来源：origin: eventuate-tram/eventuate-tram-sagas

  1. @Override
  2. public void stashMessage(String sagaType, String sagaId, String target, Message message) {
  3.  logger.debug("Stashing message from {} for {} : {}", sagaId, target, message);
  4.  jdbcTemplate.update(insertIntoSagaStashTableSql,
  5.      message.getRequiredHeader(Message.ID),
  6.      target,
  7.      sagaType,
  8.      sagaId,
  9.      JSonMapper.toJson(message.getHeaders()),
  10.      message.getPayload()
  11.      );
  12. }

代码示例来源：origin: io.eventuate.tram.sagas/eventuate-jpa-sagas-framework

  1. @Override
  2. public void stashMessage(String sagaType, String sagaId, String target, Message message) {
  3.  logger.debug("Stashing message from {} for {} : {}", sagaId, target, message);
  4.  jdbcTemplate.update(insertIntoSagaStashTableSql,
  5.      message.getRequiredHeader(Message.ID),
  6.      target,
  7.      sagaType,
  8.      sagaId,
  9.      JSonMapper.toJson(message.getHeaders()),
  10.      message.getPayload()
  11.      );
  12. }

代码示例来源：origin: eventuate-tram/eventuate-tram-sagas

  1. public SagaUnitTestSupport to(String commandChannel) {
  2.  assertEquals(1, sentCommands.size());
  3.  sentCommand = sentCommands.get(0);
  4.  assertEquals(commandChannel, sentCommand.getDestination());
  5.  assertEquals(expectedCommand.getClass().getName(), sentCommand.getMessage().getRequiredHeader(CommandMessageHeaders.COMMAND_TYPE));
  6.  // TODO 
  7.  sentCommands.clear();
  8.  return this;
  9. }

代码示例来源：origin: eventuate-tram/eventuate-tram-core

  1. private void send(Message message) {
  2.  String destination = message.getRequiredHeader(Message.DESTINATION);
  3.  List<MessageHandlerWithSubscriberId> handlers = subscriptions.getOrDefault(destination, Collections.emptyList());
  4.  sendToHandlers(destination, message, handlers);
  5.  sendToHandlers(destination, message, wildcardSubscriptions);
  6. }

代码示例来源：origin: io.eventuate.tram.core/eventuate-tram-in-memory

  1. private void send(Message message) {
  2.  String destination = message.getRequiredHeader(Message.DESTINATION);
  3.  List<MessageHandlerWithSubscriberId> handlers = subscriptions.getOrDefault(destination, Collections.emptyList());
  4.  sendToHandlers(destination, message, handlers);
  5.  sendToHandlers(destination, message, wildcardSubscriptions);
  6. }

代码示例来源：origin: eventuate-tram/eventuate-tram-core

  1. private void send(Message message) {
  2.  String table = eventuateSchema.qualifyTable("message");
  3.  jdbcTemplate.update(String.format("insert into %s(id, destination, headers, payload) values(?, ?, ?, ?)", table),
  4.      message.getId(),
  5.      message.getRequiredHeader(Message.DESTINATION),
  6.      JSonMapper.toJson(message.getHeaders()),
  7.      message.getPayload());
  8. }

代码示例来源：origin: io.eventuate.tram.core/eventuate-tram-producer-jdbc

  1. private void send(Message message) {
  2.   String table = eventuateSchema.qualifyTable("message");
  3.   jdbcTemplate.update(String.format("insert into %s(id, destination, headers, payload, creation_time) values(?, ?, ?, ?, %s)",
  4.       table,
  5.       currentTimeInMillisecondsSql),
  6.       message.getId(),
  7.       message.getRequiredHeader(Message.DESTINATION),
  8.       JSonMapper.toJson(message.getHeaders()),
  9.       message.getPayload());
  10.  }
  11. }

代码示例来源：origin: eventuate-tram/eventuate-tram-core

  1. @Test
  2.  public void shouldDoSomething() throws InterruptedException {
  3.   String messageId = commandProducer.send("customerService", "/customers/10",
  4.       new MyTestCommand(), myReplyConsumer.getReplyChannel(),
  5.       Collections.emptyMap());
  7.   Message m = myReplyConsumer.messages.poll(30, TimeUnit.SECONDS);
  9.   assertNotNull(m);
  11.   assertEquals(messageId, m.getRequiredHeader(ReplyMessageHeaders.IN_REPLY_TO));
  13.   System.out.println("Received m=" + m);
  15.   verify(myTestCommandHandler).myHandlerMethod(any(CommandMessage.class), any(PathVariables.class));
  16.  }
  17. }

代码示例来源：origin: io.eventuate.tram.sagas/eventuate-tram-sagas-simple-dsl

  1. public Optional<ReplyClassAndHandler> findReplyHandler(String currentState, Data data, Message message) {
  2.  SagaExecutionState state = decodeState(currentState);
  3.  ParticipantInvocationStep<Data> participantInvocationStep = participantInvocationStepFor(state);
  4.  String replyType = message.getRequiredHeader(ReplyMessageHeaders.REPLY_TYPE);
  5.  Optional<BiConsumer<Data, Object>> possibleReplyHandler = participantInvocationStep.getReplyHandler(replyType, state.isCompensating());
  6.  ParticipantInvocation pi = participantInvocationStep.getParticipantInvocation(state.isCompensating());
  7.  if (pi.isSuccessfulReply(message)) {
  8.   return figureOutNextStepsAndState(data, replyType, state, possibleReplyHandler);
  9.  } else if (state.isCompensating()) {
  10.   throw new UnsupportedOperationException("Failure when compensating");
  11.  } else {
  12.   return figureOutNextStepsAndState(data, replyType, state.startCompensating(), possibleReplyHandler);
  13.  }
  14. }

代码示例来源：origin: eventuate-tram/eventuate-tram-core

  1. @Override
  2. public void preSend(Message message) {
  3.  MessageHeaderAccessor headers = makeMessageHeaderAccessor(message);
  4.  TraceContextOrSamplingFlags extracted = this.extractor.extract(headers);
  5.  Span span = this.threadLocalSpan.next(extracted);
  6.  MessageHeaderPropagation.removeAnyTraceHeaders(headers, this.tracing.propagation().keys());
  7.  this.injector.inject(span.context(), headers);
  8.  if (!span.isNoop()) {
  9.   span.kind(Span.Kind.PRODUCER).name("send " + message.getRequiredHeader(Message.DESTINATION)).start();
  10.   addMessageTags(span, message);
  11.  }
  12. }

代码示例来源：origin: eventuate-tram/eventuate-tram-core

  1. @Override
  2. public void preHandle(String subscriberId, Message message) {
  3.  MessageHeaderAccessor headers = makeMessageHeaderAccessor(message);
  4.  TraceContextOrSamplingFlags extracted = this.extractor.extract(headers);
  5.  Span span = this.threadLocalSpan.next(extracted);
  6.  MessageHeaderPropagation.removeAnyTraceHeaders(headers, this.tracing.propagation().keys());
  7.  this.injector.inject(span.context(), headers);
  8.  if (!span.isNoop()) {
  9.   span.kind(Span.Kind.CONSUMER).name("receive " + message.getRequiredHeader(Message.DESTINATION)).start();
  10.   span.tag("subscriberId", subscriberId);
  11.   addMessageTags(span, message);
  12.  }
  13. }

内容来源于网络，如有侵权，请联系作者删除！

Message

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com