org.springframework.integration.amqp.support

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 and Description
static ListenerExecutionFailedException	errorMessagePayload(List<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 ListenerExecutionFailedException	errorMessagePayload(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.

Methods inherited from class java.lang.Object

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

Method Detail

errorMessagePayload

public static ListenerExecutionFailedException errorMessagePayload(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.

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,
                                                                   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