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

Method Summary

Modifier and Type	Method and Description
static ListenerExecutionFailedException	errorMessagePayload(Message message, com.rabbitmq.client.Channel channel, boolean isManualAck, Exception e) 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 e)

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.

e - the exception.

Returns:

the exception.