Class EndpointUtils

java.lang.Object

org.springframework.integration.amqp.support.EndpointUtils

public final class EndpointUtils
extends Object

Utility methods for messaging endpoints.

Since:

5.1.3

Author:

Gary Russell, Artem Bilan

Method Summary

Modifier and Type	Method	Description
static ListenerExecutionFailedException	errorMessagePayload(List<Message> messages, @Nullable com.rabbitmq.client.Channel channel, boolean isManualAck, Exception ex)	Return an ListenerExecutionFailedException or a ManualAckListenerExecutionFailedException depending on whether isManualAck is false or true.
static ListenerExecutionFailedException	errorMessagePayload(Message message, @Nullable com.rabbitmq.client.Channel channel, boolean isManualAck, Exception ex)	Return an ListenerExecutionFailedException or a ManualAckListenerExecutionFailedException depending on whether isManualAck is false or true.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

errorMessagePayload

public static ListenerExecutionFailedException errorMessagePayload(Message message,
 @Nullable com.rabbitmq.client.Channel channel,
 boolean isManualAck,
 Exception ex)

Return an ListenerExecutionFailedException or a ManualAckListenerExecutionFailedException depending on whether isManualAck is false or true.

Parameters:

message - the failed message.

channel - the channel.

isManualAck - true if the container uses manual acknowledgment.

ex - the exception.

Returns:

the exception.

errorMessagePayload

public static ListenerExecutionFailedException errorMessagePayload(List<Message> messages,
 @Nullable com.rabbitmq.client.Channel channel,
 boolean isManualAck,
 Exception ex)

Return an ListenerExecutionFailedException or a ManualAckListenerExecutionFailedException depending on whether isManualAck is false or true.

Parameters:

messages - the failed messages.

channel - the channel.

isManualAck - true if the container uses manual acknowledgment.

ex - the exception.

Returns:

the exception.

Since:

5.3