protected class AmqpInboundGateway.Listener extends Object implements 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(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(Message message, com.rabbitmq.client.Channel channel) throws Exception
onMessage in interface 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