Package org.springframework.amqp.core

Examples of org.springframework.amqp.core.MessageProperties

105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
    log.warn("This is a WARN message with properties");
    log.error("This is an ERROR message with properties", new RuntimeException("Test exception"));
    MDC.remove(propertyName);

    assertTrue(testListener.getLatch().await(5, TimeUnit.SECONDS));
    MessageProperties messageProperties = testListener.getMessageProperties();
    assertNotNull(messageProperties);
    assertNotNull(messageProperties.getHeaders().get(propertyName));
    assertEquals(propertyValue, messageProperties.getHeaders().get(propertyName));
    Object location = messageProperties.getHeaders().get("location");
    assertNotNull(location);
    assertThat(location, instanceOf(String.class));
    assertThat((String) location,
        startsWith("org.springframework.amqp.rabbit.logback.AmqpAppenderIntegrationTests.testAppenderWithProps()"));
  }
View Full Code Here
134
135
136
137
138
139
140
141
142
143
144
  @Test
  public void resolveHeaderAndPayload() throws Exception {
    MessagingMessageListenerAdapter listener = createDefaultInstance(String.class, int.class);

    Channel channel = mock(Channel.class);
    MessageProperties properties = new MessageProperties();
    properties.setHeader("myCounter", 55);
    org.springframework.amqp.core.Message message = createTextMessage("my payload", properties);
    listener.onMessage(message, channel);
    assertDefaultListenerMethodInvocation();
  }
View Full Code Here
146
147
148
149
150
151
152
153
154
155
156
  @Test
  public void resolveCustomHeaderNameAndPayload() throws Exception {
    MessagingMessageListenerAdapter listener = createDefaultInstance(String.class, int.class);

    Channel channel = mock(Channel.class);
    MessageProperties properties = new MessageProperties();
    properties.setHeader("myCounter", 24);
    org.springframework.amqp.core.Message message = createTextMessage("my payload", properties);
    listener.onMessage(message, channel);
    assertDefaultListenerMethodInvocation();
  }
View Full Code Here
158
159
160
161
162
163
164
165
166
167
168
169
  @Test
  public void resolveHeaders() throws Exception {
    MessagingMessageListenerAdapter listener = createDefaultInstance(String.class, Map.class);

    Channel channel = mock(Channel.class);
    MessageProperties properties = new MessageProperties();
    properties.setHeader("customInt", 1234);
    properties.setMessageId("abcd-1234");
    org.springframework.amqp.core.Message message = createTextMessage("my payload", properties);
    listener.onMessage(message, channel);
    assertDefaultListenerMethodInvocation();
  }
View Full Code Here
171
172
173
174
175
176
177
178
179
180
181
182
  @Test
  public void resolveMessageHeaders() throws Exception {
    MessagingMessageListenerAdapter listener = createDefaultInstance(MessageHeaders.class);

    Channel channel = mock(Channel.class);
    MessageProperties properties = new MessageProperties();
    properties.setHeader("customLong", 4567L);
    properties.setType("myMessageType");
    org.springframework.amqp.core.Message message = createTextMessage("my payload", properties);
    listener.onMessage(message, channel);
    assertDefaultListenerMethodInvocation();
  }
View Full Code Here
184
185
186
187
188
189
190
191
192
193
194
195
  @Test
  public void resolveRabbitMessageHeaderAccessor() throws Exception {
    MessagingMessageListenerAdapter listener = createDefaultInstance(AmqpMessageHeaderAccessor.class);

    Channel channel = mock(Channel.class);
    MessageProperties properties = new MessageProperties();
    properties.setHeader("customBoolean", true);
    properties.setAppId("myAppId");
    org.springframework.amqp.core.Message message = createTextMessage("my payload", properties);
    listener.onMessage(message, channel);
    assertDefaultListenerMethodInvocation();
  }
View Full Code Here
199
200
201
202
203
204
205
206
207
208
209
210
    MessagingMessageListenerAdapter listener = createDefaultInstance(MyBean.class);
    MyBean myBean = new MyBean();
    myBean.name = "myBean name";

    Channel channel = mock(Channel.class);
    MessageProperties messageProperties = new MessageProperties();
    messageProperties.setContentType(MessageProperties.CONTENT_TYPE_SERIALIZED_OBJECT);
    org.springframework.amqp.core.Message message =
        new org.springframework.amqp.core.Message(SerializationUtils.serialize(myBean), messageProperties);
    listener.onMessage(message, channel);
    assertDefaultListenerMethodInvocation();
  }
View Full Code Here
227
228
229
230
231
232
233
234
235
236
237
238
    String responseExchange = "fooQueue";
    String responseRoutingKey = "abc-1234";

    listener.setResponseExchange(responseExchange);
    listener.setResponseRoutingKey(responseRoutingKey);
    MessageProperties properties = new MessageProperties();
    properties.setCorrelationId(correlationId.getBytes(SimpleMessageConverter.DEFAULT_CHARSET));
    org.springframework.amqp.core.Message message = createTextMessage(body, properties);

    processAndReply(listener, message, responseExchange, responseRoutingKey, false, correlationId);
    assertDefaultListenerMethodInvocation();
  }
View Full Code Here
242
243
244
245
246
247
248
249
250
251
252
    MessagingMessageListenerAdapter listener = createDefaultInstance(org.springframework.amqp.core.Message.class);
    listener.setMessageConverter(null);
    listener.setResponseExchange("fooQueue");
    String body = "echo text";

    org.springframework.amqp.core.Message message = createTextMessage(body, new MessageProperties());


    processAndReply(listener, message, "fooQueue", "", false, null);
    assertDefaultListenerMethodInvocation();
  }
View Full Code Here
256
257
258
259
260
261
262
263
264
265
266
    MessagingMessageListenerAdapter listener = createDefaultInstance(org.springframework.amqp.core.Message.class);
    listener.setMessageConverter(null);
    listener.setResponseExchange("fooQueue");
    String body = "echo text";

    org.springframework.amqp.core.Message message = createTextMessage(body, new MessageProperties());

    try {
      processAndReply(listener, message, "fooQueue", "", false, null);
      fail("Should have fail. Not converter and the reply is not a message");
    }
View Full Code Here
TOP

Related Classes of org.springframework.amqp.core.MessageProperties

  • amqp.spring.camel.component.SpringAMQPHeaderTest
  • amqp.spring.camel.component.SpringAMQPMessage
  • amqp.spring.camel.component.SpringAMQPMessageTest
  • amqp.spring.converter.ContentTypeConverterFactory
  • amqp.spring.converter.ContentTypeConverterFactoryTest
  • amqp.spring.converter.StringConverter
  • amqp.spring.converter.StringConverterTest
  • amqp.spring.converter.XStreamConverter
  • amqp.spring.converter.XStreamConverterTest
  • com.jbrisbin.groovy.mqdsl.RabbitMQBuilder$Publish
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.