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

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

213
214
215
216
217
218
219
220
221
222
223
  public void resolveConvertedPayload() throws Exception {
    MessagingMessageListenerAdapter listener = createDefaultInstance(Integer.class);

    Channel channel = mock(Channel.class);

    listener.onMessage(createTextMessage("33"), channel);
    assertDefaultListenerMethodInvocation();
  }

  @Test
  public void processAndReply() throws Exception {
View Full Code Here
348
349
350
351
352
353
354
355
356
357
358
    initializeFactory(customFactory);

    Method method = getListenerMethod(methodName, String.class);
    MessagingMessageListenerAdapter listener = createInstance(customFactory, method);
    Channel channel = mock(Channel.class);
    listener.onMessage(createTextMessage("test"), channel); // test is a valid value
    assertListenerMethodInvocation(sample, methodName);
  }

  @Test
  public void validatePayloadInvalid() throws Exception {
View Full Code Here
362
363
364
365
366
367
368
369
370
371
372
    Method method = getListenerMethod("validatePayload", String.class);
    MessagingMessageListenerAdapter listener = createInstance(customFactory, method);
    Channel channel = mock(Channel.class);

    thrown.expect(ListenerExecutionFailedException.class);
    listener.onMessage(createTextMessage("invalid value"), channel); // test is an invalid value

  }

  // failure scenario
View Full Code Here
376
377
378
379
380
381
382
383
384
385
386
    Channel channel = mock(Channel.class);

    thrown.expect(ListenerExecutionFailedException.class);
    thrown.expectCause(Matchers.isA(MessageConversionException.class));
    thrown.expectMessage(getDefaultListenerMethod(Integer.class).toGenericString()); // ref to method
    listener.onMessage(createTextMessage("test"), channel); // test is not a valid integer
  }

  @Test
  public void invalidMessagePayloadType() throws Exception {
    MessagingMessageListenerAdapter listener = createDefaultInstance(Message.class);
View Full Code Here
386
387
388
389
390
391
392
393
394
395
396
    MessagingMessageListenerAdapter listener = createDefaultInstance(Message.class);
    Channel channel = mock(Channel.class);

    thrown.expect(ListenerExecutionFailedException.class);
    thrown.expectCause(Matchers.isA(MethodArgumentTypeMismatchException.class));
    listener.onMessage(createTextMessage("test"), channel);  // Message<String> as Message<Integer>
  }

  private MessagingMessageListenerAdapter createInstance(
      DefaultMessageHandlerMethodFactory factory, Method method, MessageListenerContainer container) {
    MethodRabbitListenerEndpoint endpoint = new MethodRabbitListenerEndpoint();
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.