protected class AmqpInboundGateway.Listener
extends java.lang.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 java.lang.Throwable> |
close(org.springframework.retry.RetryContext context,
org.springframework.retry.RetryCallback<T,E> callback,
java.lang.Throwable throwable) |
<T,E extends java.lang.Throwable> |
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> |
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 java.lang.Exception
onMessage
in interface org.springframework.amqp.rabbit.core.ChannelAwareMessageListener
java.lang.Exception
public <T,E extends java.lang.Throwable> boolean open(org.springframework.retry.RetryContext context, org.springframework.retry.RetryCallback<T,E> callback)
open
in interface org.springframework.retry.RetryListener
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)
close
in interface org.springframework.retry.RetryListener
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)
onError
in interface org.springframework.retry.RetryListener