org.springframework.amqp.core.Message.<init>()方法的使用及代码示例

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

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

Message.<init>介绍

暂无

代码示例

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

  1. @Test
  2. public void testPubSub() {
  3.   final Channel channel = mock(Channel.class);
  4.   Connection connection = mock(Connection.class);
  5.   doAnswer(invocation -> channel).when(connection).createChannel(anyBoolean());
  6.   ConnectionFactory connectionFactory = mock(ConnectionFactory.class);
  7.   when(connectionFactory.createConnection()).thenReturn(connection);
  8.   SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
  9.   container.setConnectionFactory(connectionFactory);
  10.   AmqpTemplate amqpTemplate = mock(AmqpTemplate.class);
  11.   PublishSubscribeAmqpChannel amqpChannel = new PublishSubscribeAmqpChannel("noSubscribersChannel",
  12.       container, amqpTemplate);
  13.   amqpChannel.setBeanName("noSubscribersChannel");
  14.   amqpChannel.setBeanFactory(mock(BeanFactory.class));
  15.   amqpChannel.afterPropertiesSet();
  16.   List<String> logList = insertMockLoggerInListener(amqpChannel);
  17.   MessageListener listener = (MessageListener) container.getMessageListener();
  18.   listener.onMessage(new Message("Hello world!".getBytes(), null));
  19.   verifyLogReceived(logList);
  20. }

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

  1. @Test // INT-2090
  2. public void jsonTypeIdNotOverwritten() {
  3.   DefaultAmqpHeaderMapper headerMapper = DefaultAmqpHeaderMapper.inboundMapper();
  4.   MessageConverter converter = new Jackson2JsonMessageConverter();
  5.   MessageProperties amqpProperties = new MessageProperties();
  6.   converter.toMessage("123", amqpProperties);
  7.   Map<String, Object> headerMap = new HashMap<String, Object>();
  8.   headerMap.put("__TypeId__", "java.lang.Integer");
  9.   MessageHeaders integrationHeaders = new MessageHeaders(headerMap);
  10.   headerMapper.fromHeadersToRequest(integrationHeaders, amqpProperties);
  11.   assertEquals("java.lang.String", amqpProperties.getHeaders().get("__TypeId__"));
  12.   Object result = converter.fromMessage(new Message("123".getBytes(), amqpProperties));
  13.   assertEquals(String.class, result.getClass());
  14. }

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

  1. @SuppressWarnings("unchecked")
  2. @Test
  3. public void testPtP() throws Exception {
  4.   final Channel channel = mock(Channel.class);
  5.   DeclareOk declareOk = mock(DeclareOk.class);
  6.   when(declareOk.getQueue()).thenReturn("noSubscribersChannel");
  7.   when(channel.queueDeclare(anyString(), anyBoolean(), anyBoolean(), anyBoolean(), isNull()))
  8.       .thenReturn(declareOk);
  9.   Connection connection = mock(Connection.class);
  10.   doAnswer(invocation -> channel).when(connection).createChannel(anyBoolean());
  11.   ConnectionFactory connectionFactory = mock(ConnectionFactory.class);
  12.   when(connectionFactory.createConnection()).thenReturn(connection);
  13.   SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
  14.   container.setConnectionFactory(connectionFactory);
  15.   AmqpTemplate amqpTemplate = mock(AmqpTemplate.class);
  16.   PointToPointSubscribableAmqpChannel amqpChannel =
  17.       new PointToPointSubscribableAmqpChannel("noSubscribersChannel", container, amqpTemplate);
  18.   amqpChannel.setBeanName("noSubscribersChannel");
  19.   amqpChannel.setBeanFactory(mock(BeanFactory.class));
  20.   amqpChannel.afterPropertiesSet();
  21.   MessageListener listener = (MessageListener) container.getMessageListener();
  22.   try {
  23.     listener.onMessage(new Message("Hello world!".getBytes(), null));
  24.     fail("Exception expected");
  25.   }
  26.   catch (MessageDeliveryException e) {
  27.     assertThat(e.getMessage(),
  28.         containsString("Dispatcher has no subscribers for amqp-channel 'noSubscribersChannel'."));
  29.   }
  30. }

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

  1. amqpProperties.setHeader("foobar", "foobar");
  2.   amqpProperties.setHeader("bar", "bar");
  3.   return new org.springframework.amqp.core.Message("hello".getBytes(), amqpProperties);
  4. })
  5.     .when(amqpTemplate).sendAndReceive(Mockito.any(String.class), Mockito.any(String.class),

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

  1. amqpProperties.setHeader("foobar", "foobar");
  2.   amqpProperties.setHeader("bar", "bar");
  3.   return new org.springframework.amqp.core.Message("hello".getBytes(), amqpProperties);
  4. })
  5.     .when(amqpTemplate).sendAndReceive(Mockito.any(String.class), Mockito.any(String.class),

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

  1. amqpProperties.setHeader("foo", "foo");
  2. amqpProperties.setHeader("bar", "bar");
  3. Message amqpMessage = new Message("hello".getBytes(), amqpProperties);
  4. listener.onMessage(amqpMessage, null);

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

  1. assertEquals(MessageDeliveryMode.PERSISTENT, properties.getDeliveryMode());
  2.   amqpProperties.setReceivedDeliveryMode(properties.getDeliveryMode());
  3.   return new org.springframework.amqp.core.Message("hello".getBytes(), amqpProperties);
  4. })
  5.     .when(amqpTemplate).sendAndReceive(Mockito.any(String.class), Mockito.any(String.class),

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

  1. amqpProperties.setHeader("foobar", "foobar");
  2.   amqpProperties.setHeader("bar", "bar");
  3.   return new org.springframework.amqp.core.Message("hello".getBytes(), amqpProperties);
  4. })
  5.     .when(amqpTemplate).sendAndReceive(Mockito.any(String.class), Mockito.any(String.class),

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

  1. @Test
  2. public void withHeaderMapperNothingToMap() throws Exception {
  3.   AmqpInboundChannelAdapter adapter = context.getBean("withHeaderMapperNothingToMap",
  4.       AmqpInboundChannelAdapter.class);
  5.   AbstractMessageListenerContainer mlc =
  6.       TestUtils.getPropertyValue(adapter, "messageListenerContainer", AbstractMessageListenerContainer.class);
  7.   ChannelAwareMessageListener listener = TestUtils.getPropertyValue(mlc, "messageListener",
  8.       ChannelAwareMessageListener.class);
  9.   MessageProperties amqpProperties = new MessageProperties();
  10.   amqpProperties.setAppId("test.appId");
  11.   amqpProperties.setClusterId("test.clusterId");
  12.   amqpProperties.setContentEncoding("test.contentEncoding");
  13.   amqpProperties.setContentLength(99L);
  14.   amqpProperties.setContentType("test.contentType");
  15.   amqpProperties.setHeader("foo", "foo");
  16.   amqpProperties.setHeader("bar", "bar");
  17.   Message amqpMessage = new Message("hello".getBytes(), amqpProperties);
  18.   listener.onMessage(amqpMessage, null);
  19.   QueueChannel requestChannel = context.getBean("requestChannel", QueueChannel.class);
  20.   org.springframework.messaging.Message<?> siMessage = requestChannel.receive(0);
  21.   assertNull(siMessage.getHeaders().get("foo"));
  22.   assertNull(siMessage.getHeaders().get("bar"));
  23.   assertNull(siMessage.getHeaders().get(AmqpHeaders.CONTENT_ENCODING));
  24.   assertNull(siMessage.getHeaders().get(AmqpHeaders.CLUSTER_ID));
  25.   assertNull(siMessage.getHeaders().get(AmqpHeaders.APP_ID));
  26.   assertNull(siMessage.getHeaders().get(AmqpHeaders.CONTENT_TYPE));
  27. }

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

  1. @Test
  2. public void withHeaderMapperDefaultMapping() throws Exception {
  3.   AmqpInboundChannelAdapter adapter = context.getBean("withHeaderMapperDefaultMapping",
  4.       AmqpInboundChannelAdapter.class);
  5.   AbstractMessageListenerContainer mlc =
  6.       TestUtils.getPropertyValue(adapter, "messageListenerContainer", AbstractMessageListenerContainer.class);
  7.   ChannelAwareMessageListener listener = TestUtils.getPropertyValue(mlc, "messageListener",
  8.       ChannelAwareMessageListener.class);
  9.   MessageProperties amqpProperties = new MessageProperties();
  10.   amqpProperties.setAppId("test.appId");
  11.   amqpProperties.setClusterId("test.clusterId");
  12.   amqpProperties.setContentEncoding("test.contentEncoding");
  13.   amqpProperties.setContentLength(99L);
  14.   amqpProperties.setContentType("test.contentType");
  15.   amqpProperties.setHeader("foo", "foo");
  16.   amqpProperties.setHeader("bar", "bar");
  17.   Message amqpMessage = new Message("hello".getBytes(), amqpProperties);
  18.   listener.onMessage(amqpMessage, null);
  19.   QueueChannel requestChannel = context.getBean("requestChannel", QueueChannel.class);
  20.   org.springframework.messaging.Message<?> siMessage = requestChannel.receive(0);
  21.   assertNotNull(siMessage.getHeaders().get("bar"));
  22.   assertNotNull(siMessage.getHeaders().get("foo"));
  23.   assertNotNull(siMessage.getHeaders().get(AmqpHeaders.CONTENT_ENCODING));
  24.   assertNotNull(siMessage.getHeaders().get(AmqpHeaders.CLUSTER_ID));
  25.   assertNotNull(siMessage.getHeaders().get(AmqpHeaders.APP_ID));
  26.   assertNotNull(siMessage.getHeaders().get(AmqpHeaders.CONTENT_TYPE));
  27. }

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

  1. @Test
  2. public void withHeaderMapperOnlyCustomHeaders() throws Exception {
  3.   AmqpInboundChannelAdapter adapter = context.getBean("withHeaderMapperOnlyCustomHeaders",
  4.       AmqpInboundChannelAdapter.class);
  5.   AbstractMessageListenerContainer mlc =
  6.       TestUtils.getPropertyValue(adapter, "messageListenerContainer", AbstractMessageListenerContainer.class);
  7.   ChannelAwareMessageListener listener = TestUtils.getPropertyValue(mlc, "messageListener",
  8.       ChannelAwareMessageListener.class);
  9.   MessageProperties amqpProperties = new MessageProperties();
  10.   amqpProperties.setAppId("test.appId");
  11.   amqpProperties.setClusterId("test.clusterId");
  12.   amqpProperties.setContentEncoding("test.contentEncoding");
  13.   amqpProperties.setContentLength(99L);
  14.   amqpProperties.setContentType("test.contentType");
  15.   amqpProperties.setHeader("foo", "foo");
  16.   amqpProperties.setHeader("bar", "bar");
  17.   Message amqpMessage = new Message("hello".getBytes(), amqpProperties);
  18.   listener.onMessage(amqpMessage, null);
  19.   QueueChannel requestChannel = context.getBean("requestChannel", QueueChannel.class);
  20.   org.springframework.messaging.Message<?> siMessage = requestChannel.receive(0);
  21.   assertEquals("foo", siMessage.getHeaders().get("foo"));
  22.   assertNull(siMessage.getHeaders().get("bar"));
  23.   assertNull(siMessage.getHeaders().get(AmqpHeaders.CONTENT_ENCODING));
  24.   assertNull(siMessage.getHeaders().get(AmqpHeaders.CLUSTER_ID));
  25.   assertNull(siMessage.getHeaders().get(AmqpHeaders.APP_ID));
  26.   assertNull(siMessage.getHeaders().get(AmqpHeaders.CONTENT_TYPE));
  27. }

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

  1. @Test
  2. public void withHeaderMapperStandardAndCustomHeaders() throws Exception {
  3.   AmqpInboundChannelAdapter adapter = context.getBean("withHeaderMapperStandardAndCustomHeaders",
  4.       AmqpInboundChannelAdapter.class);
  5.   AbstractMessageListenerContainer mlc =
  6.       TestUtils.getPropertyValue(adapter, "messageListenerContainer", AbstractMessageListenerContainer.class);
  7.   ChannelAwareMessageListener listener = TestUtils.getPropertyValue(mlc, "messageListener",
  8.       ChannelAwareMessageListener.class);
  9.   MessageProperties amqpProperties = new MessageProperties();
  10.   amqpProperties.setAppId("test.appId");
  11.   amqpProperties.setClusterId("test.clusterId");
  12.   amqpProperties.setContentEncoding("test.contentEncoding");
  13.   amqpProperties.setContentLength(99L);
  14.   amqpProperties.setContentType("test.contentType");
  15.   amqpProperties.setHeader("foo", "foo");
  16.   amqpProperties.setHeader("bar", "bar");
  17.   Message amqpMessage = new Message("hello".getBytes(), amqpProperties);
  18.   listener.onMessage(amqpMessage, null);
  19.   QueueChannel requestChannel = context.getBean("requestChannel", QueueChannel.class);
  20.   org.springframework.messaging.Message<?> siMessage = requestChannel.receive(0);
  21.   assertEquals("foo", siMessage.getHeaders().get("foo"));
  22.   assertNull(siMessage.getHeaders().get("bar"));
  23.   assertNotNull(siMessage.getHeaders().get(AmqpHeaders.CONTENT_ENCODING));
  24.   assertNotNull(siMessage.getHeaders().get(AmqpHeaders.CLUSTER_ID));
  25.   assertNotNull(siMessage.getHeaders().get(AmqpHeaders.APP_ID));
  26.   assertNotNull(siMessage.getHeaders().get(AmqpHeaders.CONTENT_TYPE));
  27. }

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

  1. messageProperties.setConsumerQueue(this.queue);
  2. Map<String, Object> headers = this.headerMapper.toHeadersFromRequest(messageProperties);
  3. org.springframework.amqp.core.Message amqpMessage = new org.springframework.amqp.core.Message(resp.getBody(), messageProperties);
  4. Object payload = this.messageConverter.fromMessage(amqpMessage);
  5. AbstractIntegrationMessageBuilder<Object> builder = getMessageBuilderFactory().withPayload(payload)

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

  1. @SuppressWarnings("unused")
  2.   public Message handleMessage(Message message) {
  3.     replyToWas.set(message.getMessageProperties().getReplyTo());
  4.     return new Message(new String(message.getBody()).toUpperCase().getBytes(),
  5.         message.getMessageProperties());
  6.   }
  7. });

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

  1. @Test
  2. public void testNoTypeInfo() {
  3.   byte[] bytes = "{\"name\" : { \"foo\" : \"bar\" } }".getBytes();
  4.   MessageProperties messageProperties = new MessageProperties();
  5.   messageProperties.setContentType("application/json");
  6.   Message message = new Message(bytes, messageProperties);
  7.   Object foo = this.converter.fromMessage(message);
  8.   assertThat(foo, instanceOf(LinkedHashMap.class));
  9.   @SuppressWarnings("unchecked")
  10.   Map<String, Object> map = (Map<String, Object>) foo;
  11.   assertThat(map.get("name"), instanceOf(LinkedHashMap.class));
  12. }

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

  1. @Test
  2. public void testInferredTypeInfo() {
  3.   byte[] bytes = "{\"name\" : \"foo\" }".getBytes();
  4.   MessageProperties messageProperties = new MessageProperties();
  5.   messageProperties.setContentType("application/json");
  6.   messageProperties.setInferredArgumentType(Foo.class);
  7.   Message message = new Message(bytes, messageProperties);
  8.   Object foo = this.converter.fromMessage(message);
  9.   assertThat(foo, instanceOf(Foo.class));
  10. }

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

  1. @Test
  2. public void testConvert4Args() throws Exception {
  3.   ListenableFuture<String> future = this.asyncTemplate.convertSendAndReceive("", this.requests.getName(), "foo",
  4.       message -> {
  5.         String body = new String(message.getBody());
  6.         return new Message((body + "bar").getBytes(), message.getMessageProperties());
  7.       });
  8.   checkConverterResult(future, "FOOBAR");
  9. }

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

  1. @Test
  2. public void toStringForNonSerializableMessageBody() {
  3.   MessageProperties messageProperties = new MessageProperties();
  4.   messageProperties.setContentType(MessageProperties.CONTENT_TYPE_SERIALIZED_OBJECT);
  5.   Message message = new Message("foo".getBytes(), messageProperties);
  6.   assertNotNull(message.toString());
  7. }

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

  1. @Test
  2. public void testMPPsAppliedDirectReplyToTests() {
  3.   this.template.setUseDirectReplyToContainer(false);
  4.   this.template.sendAndReceive(new Message("foo".getBytes(), new MessageProperties()));
  5.   assertTrue("before MPP not called", this.config.beforeMppCalled);
  6.   assertTrue("after MPP not called", this.config.afterMppCalled);
  7. }

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

  1. @Test
  2. public void testSimpleBatchTimeoutMultiple() throws Exception {
  3.   BatchingStrategy batchingStrategy = new SimpleBatchingStrategy(2, Integer.MAX_VALUE, 50);
  4.   BatchingRabbitTemplate template = new BatchingRabbitTemplate(batchingStrategy, this.scheduler);
  5.   template.setConnectionFactory(this.connectionFactory);
  6.   MessageProperties props = new MessageProperties();
  7.   Message message = new Message("foo".getBytes(), props);
  8.   template.send("", ROUTE, message);
  9.   template.send("", ROUTE, message);
  10.   message = receive(template);
  11.   assertEquals("\u0000\u0000\u0000\u0003foo\u0000\u0000\u0000\u0003foo", new String(message.getBody()));
  12. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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