org.springframework.messaging.Message.getPayload()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(9.1k)|赞(0)|评价(0)|浏览(650)

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

Message.getPayload介绍

[英]Return the message payload.
[中]返回消息有效载荷。

代码示例

代码示例来源：origin: spring-projects/spring-framework

  1. /**
  2.  * Encodes the given STOMP {@code message} into a {@code byte[]}.
  3.  * @param message the message to encode
  4.  * @return the encoded message
  5.  */
  6. public byte[] encode(Message<byte[]> message) {
  7.   return encode(message.getHeaders(), message.getPayload());
  8. }

代码示例来源：origin: spring-projects/spring-framework

  1. private MessageBuilder(Message<T> originalMessage) {
  2.   Assert.notNull(originalMessage, "Message must not be null");
  3.   this.payload = originalMessage.getPayload();
  4.   this.originalMessage = originalMessage;
  5.   this.headerAccessor = new MessageHeaderAccessor(originalMessage);
  6. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Override
  2.   public void onFailure(Throwable ex) {
  3.     if (tcpConnection != null) {
  4.       handleTcpConnectionFailure("failed to forward " +
  5.           accessor.getShortLogMessage(message.getPayload()), ex);
  6.     }
  7.     else if (logger.isErrorEnabled()) {
  8.       logger.error("Failed to forward " + accessor.getShortLogMessage(message.getPayload()));
  9.     }
  10.   }
  11. });

代码示例来源：origin: spring-projects/spring-framework

  1. @Override
  2. protected Object convertFromInternal(Message<?> message, Class<?> targetClass, @Nullable Object conversionHint) {
  3.   Charset charset = getContentTypeCharset(getMimeType(message.getHeaders()));
  4.   Object payload = message.getPayload();
  5.   return (payload instanceof String ? payload : new String((byte[]) payload, charset));
  6. }

代码示例来源：origin: spring-projects/spring-framework

  1. private void logMessage(Message<?> message) {
  2.   if (logger.isDebugEnabled()) {
  3.     SimpMessageHeaderAccessor accessor = MessageHeaderAccessor.getAccessor(message, SimpMessageHeaderAccessor.class);
  4.     accessor = (accessor != null ? accessor : SimpMessageHeaderAccessor.wrap(message));
  5.     logger.debug("Processing " + accessor.getShortLogMessage(message.getPayload()));
  6.   }
  7. }

代码示例来源：origin: spring-projects/spring-framework

  1. public MessageExchangeBuilder andExpectMessage(String sessionId, String subscriptionId) {
  2.   Assert.state(SimpMessageType.MESSAGE.equals(this.headers.getMessageType()), "MESSAGE type expected");
  3.   String destination = this.headers.getDestination();
  4.   Object payload = this.message.getPayload();
  5.   this.expected.add(new StompMessageFrameMessageMatcher(sessionId, subscriptionId, destination, payload));
  6.   return this;
  7. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void toMessageUtf16() {
  3.   MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();
  4.   MimeType contentType = new MimeType("application", "json", StandardCharsets.UTF_16BE);
  5.   Map<String, Object> map = new HashMap<>();
  6.   map.put(MessageHeaders.CONTENT_TYPE, contentType);
  7.   MessageHeaders headers = new MessageHeaders(map);
  8.   String payload = "H\u00e9llo W\u00f6rld";
  9.   Message<?> message = converter.toMessage(payload, headers);
  10.   assertEquals("\"" + payload + "\"", new String((byte[]) message.getPayload(), StandardCharsets.UTF_16BE));
  11.   assertEquals(contentType, message.getHeaders().get(MessageHeaders.CONTENT_TYPE));
  12. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void toMessageWithPayloadAndHeaders() {
  3.   MessageHeaders headers = new MessageHeaders(Collections.<String, Object>singletonMap("foo", "bar"));
  4.   Message<?> message = this.converter.toMessage("payload", headers);
  5.   assertEquals("payload", message.getPayload());
  6.   assertEquals("bar", message.getHeaders().get("foo"));
  7. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void basic() throws InterruptedException {
  3.   BufferingStompDecoder stompDecoder = new BufferingStompDecoder(STOMP_DECODER, 128);
  4.   String chunk = "SEND\na:alpha\n\nMessage body\0";
  5.   List<Message<byte[]>> messages = stompDecoder.decode(toByteBuffer(chunk));
  6.   assertEquals(1, messages.size());
  7.   assertEquals("Message body", new String(messages.get(0).getPayload()));
  8.   assertEquals(0, stompDecoder.getBufferSize());
  9.   assertNull(stompDecoder.getExpectedContentLength());
  10. }

代码示例来源：origin: spring-projects/spring-framework

  1. @JsonView(Summary.class)
  2. public Message<SampleResponse> replyJacksonMessageAndJsonView(Message<String> input) {
  3.   return MessageBuilder.withPayload(createSampleResponse(input.getPayload()))
  4.       .setHeader("foo", "bar").build();
  5. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void convertAndSendPayload() {
  3.   this.template.convertAndSend("myChannel", "payload");
  4.   assertSame(this.myChannel, this.template.messageChannel);
  5.   assertNotNull(this.template.message);
  6.   assertSame("payload", this.template.message.getPayload());
  7. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2.   public void toMessageWithPayloadAndMutableHeaders() {
  3.     MessageHeaderAccessor accessor = new MessageHeaderAccessor();
  4.     accessor.setHeader("foo", "bar");
  5.     accessor.setLeaveMutable(true);
  6.     MessageHeaders headers = accessor.getMessageHeaders();
  8.     Message<?> message = this.converter.toMessage("payload", headers);
  10.     assertEquals("payload", message.getPayload());
  11.     assertSame(headers, message.getHeaders());
  12.     assertEquals("bar", message.getHeaders().get("foo"));
  13.   }
  14. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void decodeFrameWithCrLfEols() {
  3.   Message<byte[]> frame = decode("DISCONNECT\r\n\r\n\0");
  4.   StompHeaderAccessor headers = StompHeaderAccessor.wrap(frame);
  5.   assertEquals(StompCommand.DISCONNECT, headers.getCommand());
  6.   assertEquals(0, headers.toNativeHeaderMap().size());
  7.   assertEquals(0, frame.getPayload().length);
  8. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void decodeFrameWithNoHeadersAndNoBody() {
  3.   Message<byte[]> frame = decode("DISCONNECT\n\n\0");
  4.   StompHeaderAccessor headers = StompHeaderAccessor.wrap(frame);
  5.   assertEquals(StompCommand.DISCONNECT, headers.getCommand());
  6.   assertEquals(0, headers.toNativeHeaderMap().size());
  7.   assertEquals(0, frame.getPayload().length);
  8. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void customPayloadConverter() throws JMSException {
  3.   TextMessage jmsMsg = new StubTextMessage("1224");
  4.   this.converter.setPayloadConverter(new TestMessageConverter());
  5.   Message<?> msg = (Message<?>) this.converter.fromMessage(jmsMsg);
  6.   assertEquals(1224L, msg.getPayload());
  7. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void createFromMessage() {
  3.   Message<String> message1 = MessageBuilder.withPayload("test")
  4.       .setHeader("foo", "bar").build();
  5.   Message<String> message2 = MessageBuilder.fromMessage(message1).build();
  6.   assertEquals("test", message2.getPayload());
  7.   assertEquals("bar", message2.getHeaders().get("foo"));
  8. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void convertAndSendPayloadWithPostProcessorToDestination() {
  3.   this.template.convertAndSend("somewhere", "payload", this.postProcessor);
  4.   assertEquals("somewhere", this.template.destination);
  5.   assertNotNull(this.template.message);
  6.   assertEquals("expected 'id' and 'timestamp' headers only", 2, this.template.message.getHeaders().size());
  7.   assertEquals("payload", this.template.message.getPayload());
  8.   assertNotNull(this.postProcessor.getMessage());
  9.   assertSame(this.template.message, this.postProcessor.getMessage());
  10. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void convertAndSendPayloadWithPostProcessor() {
  3.   this.template.convertAndSend("myChannel", "payload", this.postProcessor);
  4.   assertSame(this.myChannel, this.template.messageChannel);
  5.   assertNotNull(this.template.message);
  6.   assertEquals("payload", this.template.message.getPayload());
  7.   assertNotNull(this.postProcessor.getMessage());
  8.   assertSame(this.postProcessor.getMessage(), this.template.message);
  9. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void convertAndSendWithPostProcessor() {
  3.   Message<?> responseMessage = new GenericMessage<Object>("response");
  4.   this.template.setDefaultDestination("home");
  5.   this.template.setReceiveMessage(responseMessage);
  6.   String response = this.template.convertSendAndReceive("request", String.class, this.postProcessor);
  7.   assertEquals("home", this.template.destination);
  8.   assertSame("request", this.template.requestMessage.getPayload());
  9.   assertSame("response", response);
  10.   assertSame(this.postProcessor.getMessage(), this.template.requestMessage);
  11. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void payloadConversionLazilyInvoked() throws JMSException {
  3.   javax.jms.Message jmsMessage = mock(javax.jms.Message.class);
  4.   MessageConverter messageConverter = mock(MessageConverter.class);
  5.   given(messageConverter.fromMessage(jmsMessage)).willReturn("FooBar");
  6.   MessagingMessageListenerAdapter listener = getSimpleInstance("simple", Message.class);
  7.   listener.setMessageConverter(messageConverter);
  8.   Message<?> message = listener.toMessagingMessage(jmsMessage);
  9.   verify(messageConverter, never()).fromMessage(jmsMessage);
  10.   assertEquals("FooBar", message.getPayload());
  11.   verify(messageConverter, times(1)).fromMessage(jmsMessage);
  12. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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