org.springframework.integration.amqp.inbound

Class AmqpInboundChannelAdapter.Listener

java.lang.Object

org.springframework.integration.amqp.inbound.AmqpInboundChannelAdapter.Listener

All Implemented Interfaces:

org.springframework.amqp.rabbit.core.ChannelAwareMessageListener, org.springframework.retry.RetryListener

Enclosing class:

AmqpInboundChannelAdapter

protected class AmqpInboundChannelAdapter.Listener
extends java.lang.Object
implements org.springframework.amqp.rabbit.core.ChannelAwareMessageListener, org.springframework.retry.RetryListener

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Listener()

Method Summary

Modifier and Type	Method and Description
<T,E extends java.lang.Throwable> void	close(org.springframework.retry.RetryContext context, org.springframework.retry.RetryCallback<T,E> callback, java.lang.Throwable throwable)
<T,E extends java.lang.Throwable> void	onError(org.springframework.retry.RetryContext context, org.springframework.retry.RetryCallback<T,E> callback, java.lang.Throwable throwable)
void	onMessage(org.springframework.amqp.core.Message message, com.rabbitmq.client.Channel channel)
<T,E extends java.lang.Throwable> boolean	open(org.springframework.retry.RetryContext context, org.springframework.retry.RetryCallback<T,E> callback)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Listener

protected Listener()

Method Detail

onMessage

public void onMessage(org.springframework.amqp.core.Message message,
                      com.rabbitmq.client.Channel channel)
               throws java.lang.Exception

Specified by:

onMessage in interface org.springframework.amqp.rabbit.core.ChannelAwareMessageListener

Throws:

java.lang.Exception

open

public <T,E extends java.lang.Throwable> boolean open(org.springframework.retry.RetryContext context,
                                                      org.springframework.retry.RetryCallback<T,E> callback)

Specified by:

open in interface org.springframework.retry.RetryListener

close

public <T,E extends java.lang.Throwable> void close(org.springframework.retry.RetryContext context,
                                                    org.springframework.retry.RetryCallback<T,E> callback,
                                                    java.lang.Throwable throwable)

Specified by:

close in interface org.springframework.retry.RetryListener

onError

public <T,E extends java.lang.Throwable> void onError(org.springframework.retry.RetryContext context,
                                                      org.springframework.retry.RetryCallback<T,E> callback,
                                                      java.lang.Throwable throwable)

Specified by:

onError in interface org.springframework.retry.RetryListener