Package org.springframework.amqp.rabbit.listener.adapter

Examples of org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.onMessage()

133
134
135
136
137
138
139
140
141
142
143
    MessageProperties properties = new MessageProperties();
    properties.setContentType(MessageProperties.CONTENT_TYPE_TEXT_PLAIN);
    Message amqpMessage = new Message("Hello".getBytes(), properties);

    try {
      listener.onMessage(amqpMessage, mock(Channel.class));
    }
    catch (Exception e) {
      fail("should not have failed to process simple message but got " + e.getMessage());
    }
  }
View Full Code Here
245
246
247
248
249
250
251
252
253
254
255
    MessageProperties properties = new MessageProperties();
    properties.setContentType(MessageProperties.CONTENT_TYPE_TEXT_PLAIN);
    Message amqpMessage = new Message("failValidation".getBytes(), properties);

    listener.onMessage(amqpMessage, mock(Channel.class));
  }

  @Component
  static class ValidationBean {
View Full Code Here
116
117
118
119
120
121
122
123
124
125
126
  public void resolveMessageAndSession() throws Exception {
    MessagingMessageListenerAdapter listener = createDefaultInstance(
        org.springframework.amqp.core.Message.class, Channel.class);

    Channel channel = mock(Channel.class);
    listener.onMessage(createTextMessage("test"), channel);
    assertDefaultListenerMethodInvocation();
  }

  @Test
  public void resolveGenericMessage() throws Exception {
View Full Code Here
125
126
127
128
129
130
131
132
133
134
135
  @Test
  public void resolveGenericMessage() throws Exception {
    MessagingMessageListenerAdapter listener = createDefaultInstance(Message.class);

    Channel channel = mock(Channel.class);
    listener.onMessage(createTextMessage("test"), channel);
    assertDefaultListenerMethodInvocation();
  }

  @Test
  public void resolveHeaderAndPayload() throws Exception {
View Full Code Here
137
138
139
140
141
142
143
144
145
146
147
    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();
  }

  @Test
  public void resolveCustomHeaderNameAndPayload() throws Exception {
View Full Code Here
149
150
151
152
153
154
155
156
157
158
159
    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();
  }

  @Test
  public void resolveHeaders() throws Exception {
View Full Code Here
162
163
164
165
166
167
168
169
170
171
172
    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();
  }

  @Test
  public void resolveMessageHeaders() throws Exception {
View Full Code Here
175
176
177
178
179
180
181
182
183
184
185
    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();
  }

  @Test
  public void resolveRabbitMessageHeaderAccessor() throws Exception {
View Full Code Here
188
189
190
191
192
193
194
195
196
197
198
    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();
  }

  @Test
  public void resolveObjectPayload() throws Exception {
View Full Code Here
203
204
205
206
207
208
209
210
211
212
213
    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();
  }

  @Test
  public void resolveConvertedPayload() throws Exception {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.