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

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

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

Message.getPayload介绍

暂无

代码示例

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

  1. public MessageBuilder(Message message) {
  2. this(message.getPayload());
  3. this.headers = message.getHeaders();
  4. }

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

  1. public <C extends Command> SagaParticipantStubManagerHelper<C> when(C expectedCommand) {
  2. return new SagaParticipantStubManagerHelper<C>(this, (Class<C>) expectedCommand.getClass(),
  3. message -> JSonMapper.fromJson(message.getPayload(), expectedCommand.getClass()).equals(expectedCommand));
  4. }

代码示例来源: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: eventuate-tram/eventuate-tram-core

  1. @Override
  2. public void accept(Message message) {
  3. try {
  4. queue.put(message.getPayload());
  5. } catch (InterruptedException e) {
  6. throw new RuntimeException(e);
  7. }
  8. }

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

  1. @Override
  2. protected ContractVerifierMessage convert(Message m) {
  3. return m == null ? null : contractVerifierMessaging.create(m.getPayload(), m.getHeaders());
  4. }
  5. }

代码示例来源: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-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: io.eventuate.tram.sagas/eventuate-tram-sagas-simple-dsl

  1. @Override
  2. public SagaActions<Data> handleReply(String currentState, Data sagaData, Message message) {
  3. Optional<ReplyClassAndHandler> replyHandler = this.findReplyHandler(currentState, sagaData, message);
  4. // if (!replyHandler.isPresent()) {
  5. // logger.error("No handler for {}", message);
  6. // return;
  7. // }
  8. ReplyClassAndHandler m = replyHandler.get();
  9. Object param = JSonMapper.fromJson(message.getPayload(), m.getReplyClass());
  10. return (SagaActions<Data>) m.getReplyHandler().apply(sagaData, param);
  11. }

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

  1. @Override
  2. public SagaActions<Data> handleReply(String currentState, Data sagaData, Message message) {
  3. Optional<ReplyClassAndHandler> replyHandler = this.findReplyHandler(currentState, sagaData, message);
  4. // if (!replyHandler.isPresent()) {
  5. // logger.error("No handler for {}", message);
  6. // return;
  7. // }
  8. ReplyClassAndHandler m = replyHandler.get();
  9. Object param = JSonMapper.fromJson(message.getPayload(), m.getReplyClass());
  10. return (SagaActions<Data>) m.getReplyHandler().apply(sagaData, param);
  11. }

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

  1. public void messageHandler(Message message) {
  2. String aggregateType = message.getRequiredHeader(EventMessageHeaders.AGGREGATE_TYPE);
  3. Optional<DomainEventHandler> handler = domainEventHandlers.findTargetMethod(message);
  4. if (!handler.isPresent()) {
  5. return;
  6. }
  7. DomainEvent param = JSonMapper.fromJson(message.getPayload(), handler.get().getEventClass());
  8. handler.get().invoke(new DomainEventEnvelopeImpl<>(message,
  9. aggregateType,
  10. message.getRequiredHeader(EventMessageHeaders.AGGREGATE_ID),
  11. message.getRequiredHeader(Message.ID),
  12. param));
  13. }

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

  1. public void messageHandler(Message message) {
  2. String aggregateType = message.getRequiredHeader(EventMessageHeaders.AGGREGATE_TYPE);
  3. Optional<DomainEventHandler> handler = domainEventHandlers.findTargetMethod(message);
  4. if (!handler.isPresent()) {
  5. return;
  6. }
  7. DomainEvent param = JSonMapper.fromJson(message.getPayload(), handler.get().getEventClass());
  8. handler.get().invoke(new DomainEventEnvelopeImpl<>(message,
  9. aggregateType,
  10. message.getRequiredHeader(EventMessageHeaders.AGGREGATE_ID),
  11. message.getRequiredHeader(Message.ID),
  12. param));
  13. }

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

  1. public void messageHandler(Message message) {
  2. logger.trace("Received message {} {}", commandDispatcherId, message);
  3. Optional<CommandHandler> possibleMethod = commandHandlers.findTargetMethod(message);
  4. if (!possibleMethod.isPresent()) {
  5. throw new RuntimeException("No method for " + message);
  6. }
  7. CommandHandler m = possibleMethod.get();
  8. Object param = convertPayload(m, message.getPayload());
  9. Map<String, String> correlationHeaders = correlationHeaders(message.getHeaders());
  10. Map<String, String> pathVars = getPathVars(message, m);
  11. Optional<String> defaultReplyChannel = message.getHeader(CommandMessageHeaders.REPLY_TO);
  12. List<Message> replies;
  13. try {
  14. CommandMessage cm = new CommandMessage(message.getId(), param, correlationHeaders, message);
  15. replies = invoke(m, cm, pathVars);
  16. logger.trace("Generated replies {} {} {}", commandDispatcherId, message, replies);
  17. } catch (Exception e) {
  18. logger.trace("Generated error {} {} {}", commandDispatcherId, message, e.getClass().getName());
  19. handleException(message, param, m, e, pathVars, defaultReplyChannel);
  20. return;
  21. }
  22. if (replies != null) {
  23. publish(correlationHeaders, replies, defaultReplyChannel);
  24. } else {
  25. logger.trace("Null replies - not publishling");
  26. }
  27. }

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

  1. private void messageHandler(Message message) {
  2. logger.info("received message {}" , message);
  3. TestMessage testMessage = JSonMapper.fromJson(message.getPayload(), TestMessage.class);
  4. ResponseEntity<String> result = restTemplate.postForEntity(String.format("http://localhost:%s/bar", testMessage
  5. .getPort()),
  6. "hello", String.class);
  7. assertEquals(HttpStatus.OK, result.getStatusCode());
  8. }
  9. }

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

  1. private boolean satisfies(Message message, Contract groovyDsl) {
  2. if (!headersMatch(message, groovyDsl)) {
  3. logger.info("Headers don't match {} {} ", groovyDsl.getLabel(), message);
  4. return false;
  5. }
  6. BodyMatchers matchers = groovyDsl.getInput().getBodyMatchers();
  7. Object dslBody = MapConverter.getStubSideValues(groovyDsl.getInput().getMessageBody());
  8. Object matchingInputMessage = JsonToJsonPathsConverter
  9. .removeMatchingJsonPaths(dslBody, matchers);
  10. JsonPaths jsonPaths = JsonToJsonPathsConverter
  11. .transformToJsonPathWithStubsSideValuesAndNoArraySizeCheck(
  12. matchingInputMessage);
  13. DocumentContext parsedJson = JsonPath.parse(message.getPayload());
  14. boolean matches = true;
  15. for (MethodBufferingJsonVerifiable path : jsonPaths) {
  16. matches &= matchesJsonPath(parsedJson, path.jsonPath());
  17. }
  18. logger.info("jsonPaths match {} {} {} ", groovyDsl.getLabel(), matches, message);
  19. if (matchers != null && matchers.hasMatchers()) {
  20. for (BodyMatcher matcher : matchers.jsonPathMatchers()) {
  21. String jsonPath = JsonToJsonPathsConverter.convertJsonPathAndRegexToAJsonPath(matcher, dslBody);
  22. matches &= matchesJsonPath(parsedJson, jsonPath);
  23. }
  24. }
  25. logger.info("matchers {} {} {} ", groovyDsl.getLabel(), matches, message);
  26. return matches;
  27. }

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

  1. String messageJson = message.getPayload();

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

  1. @Test
  2. public void shouldReleaseLockAndUnstashMessage() {
  3. String sagaId1 = idGenerator.genId().toString();
  4. String sagaId2 = idGenerator.genId().toString();
  5. String target = "/target/" + idGenerator.genId().toString();
  6. String messageId = idGenerator.genId().toString();
  7. assertTrue(sagaLockManager.claimLock(sagaType, sagaId1, target));
  8. assertFalse(sagaLockManager.claimLock(sagaType, sagaId2, target));
  9. String payload = "hello";
  10. Message message = MessageBuilder.withPayload(payload).withHeader(Message.ID, messageId).build();
  11. sagaLockManager.stashMessage(sagaType, sagaId2, target, message);
  12. Optional<Message> unstashedMessage1 = sagaLockManager.unlock(sagaId1, target);
  13. assertTrue(unstashedMessage1.isPresent());
  14. assertEquals(messageId, unstashedMessage1.get().getId());
  15. assertEquals(payload, unstashedMessage1.get().getPayload());
  16. assertFalse(sagaLockManager.unlock(sagaId2, target).isPresent());
  17. }

相关文章