public final class EndpointUtils
extends java.lang.Object
| Modifier and Type | Method and Description |
|---|---|
static org.springframework.amqp.rabbit.support.ListenerExecutionFailedException |
errorMessagePayload(java.util.List<org.springframework.amqp.core.Message> messages,
com.rabbitmq.client.Channel channel,
boolean isManualAck,
java.lang.Exception ex)
Return an
ListenerExecutionFailedException or a ManualAckListenerExecutionFailedException
depending on whether isManualAck is false or true. |
static org.springframework.amqp.rabbit.support.ListenerExecutionFailedException |
errorMessagePayload(org.springframework.amqp.core.Message message,
com.rabbitmq.client.Channel channel,
boolean isManualAck,
java.lang.Exception ex)
Return an
ListenerExecutionFailedException or a ManualAckListenerExecutionFailedException
depending on whether isManualAck is false or true. |
public static org.springframework.amqp.rabbit.support.ListenerExecutionFailedException errorMessagePayload(org.springframework.amqp.core.Message message,
com.rabbitmq.client.Channel channel,
boolean isManualAck,
java.lang.Exception ex)
ListenerExecutionFailedException or a ManualAckListenerExecutionFailedException
depending on whether isManualAck is false or true.message - the failed message.channel - the channel.isManualAck - true if the container uses manual acknowledgment.ex - the exception.public static org.springframework.amqp.rabbit.support.ListenerExecutionFailedException errorMessagePayload(java.util.List<org.springframework.amqp.core.Message> messages,
com.rabbitmq.client.Channel channel,
boolean isManualAck,
java.lang.Exception ex)
ListenerExecutionFailedException or a ManualAckListenerExecutionFailedException
depending on whether isManualAck is false or true.messages - the failed messages.channel - the channel.isManualAck - true if the container uses manual acknowledgment.ex - the exception.