Package io.awspring.cloud.sqs.listener

Class InterceptorExecutionFailedException

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

io.awspring.cloud.sqs.listener.InterceptorExecutionFailedException

All Implemented Interfaces:

MessageProcessingException, Serializable

public class InterceptorExecutionFailedException
extends RuntimeException
implements MessageProcessingException

Exception thrown when a MessageInterceptor throws during before-processing execution. Contains the Message instance or instances for which the interceptor failed, allowing downstream pipeline stages such as the error handler and acknowledgement handler to retrieve the message and act accordingly.

Since:

4.1

Author:

Tomaz Fernandes

See Also:

• MessageProcessingException
• ListenerExecutionFailedException
• Serialized Form

Constructor Summary

Constructors

Constructor	Description
InterceptorExecutionFailedException(String message, Throwable cause, Collection<Message<T>> failedMessages)
InterceptorExecutionFailedException(String message, Throwable cause, Message<?> failedMessage)

Method Summary

Modifier and Type	Method	Description
Collection<Message<?>>	getFailedMessages()	Return the messages for which processing failed.

Methods inherited from class java.lang.Throwable

addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

Methods inherited from class java.lang.Object

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

Constructor Details

InterceptorExecutionFailedException

public InterceptorExecutionFailedException(String message,
 Throwable cause,
 Message<?> failedMessage)

InterceptorExecutionFailedException

public InterceptorExecutionFailedException(String message,
 Throwable cause,
 Collection<Message<T>> failedMessages)

Method Details

getFailedMessages

public Collection<Message<?>> getFailedMessages()

Description copied from interface: MessageProcessingException

Return the messages for which processing failed.

Specified by:

getFailedMessages in interface MessageProcessingException

Returns:

the messages.