protected class AmqpInboundGateway.Listener extends Object implements org.springframework.amqp.rabbit.core.ChannelAwareMessageListener, org.springframework.retry.RetryListener
| Modifier | Constructor and Description |
|---|---|
protected |
Listener() |
| Modifier and Type | Method and Description |
|---|---|
<T,E extends Throwable> |
close(org.springframework.retry.RetryContext context,
org.springframework.retry.RetryCallback<T,E> callback,
Throwable throwable) |
<T,E extends Throwable> |
onError(org.springframework.retry.RetryContext context,
org.springframework.retry.RetryCallback<T,E> callback,
Throwable throwable) |
void |
onMessage(org.springframework.amqp.core.Message message,
com.rabbitmq.client.Channel channel) |
<T,E extends Throwable> |
open(org.springframework.retry.RetryContext context,
org.springframework.retry.RetryCallback<T,E> callback) |
public void onMessage(org.springframework.amqp.core.Message message,
com.rabbitmq.client.Channel channel)
throws Exception
onMessage in interface org.springframework.amqp.rabbit.core.ChannelAwareMessageListenerExceptionpublic <T,E extends Throwable> boolean open(org.springframework.retry.RetryContext context, org.springframework.retry.RetryCallback<T,E> callback)
open in interface org.springframework.retry.RetryListenerpublic <T,E extends Throwable> void close(org.springframework.retry.RetryContext context, org.springframework.retry.RetryCallback<T,E> callback, Throwable throwable)
close in interface org.springframework.retry.RetryListener