public final class EndpointUtils extends Object
Modifier and Type | Method and Description |
---|---|
static org.springframework.amqp.rabbit.support.ListenerExecutionFailedException |
errorMessagePayload(List<org.springframework.amqp.core.Message> messages,
com.rabbitmq.client.Channel channel,
boolean isManualAck,
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,
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, 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(List<org.springframework.amqp.core.Message> messages, com.rabbitmq.client.Channel channel, boolean isManualAck, 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.