org.springframework.amqp.rabbit.retry

Class RepublishMessageRecoverer

java.lang.Object

org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer

All Implemented Interfaces:

MessageRecoverer

public class RepublishMessageRecoverer
extends Object
implements MessageRecoverer

MessageRecoverer implementation that republishes recovered messages to a specified exchange with the exception stack trace stored in the message header x-exception.

If no routing key is provided, the original routing key for the message, prefixed with setErrorRoutingKeyPrefix(String) (default "error.") will be used to publish the message to the exchange provided in name, or the template's default exchange if none is set.

Since:

1.3

Author:

James Carr, Gary Russell

Constructor Summary

Constructors

Constructor and Description
RepublishMessageRecoverer(AmqpTemplate errorTemplate)
RepublishMessageRecoverer(AmqpTemplate errorTemplate, String errorExchange)
RepublishMessageRecoverer(AmqpTemplate errorTemplate, String errorExchange, String errorRoutingKey)

Method Summary

Methods

Modifier and Type	Method and Description
RepublishMessageRecoverer	errorRoutingKeyPrefix(String errorRoutingKeyPrefix) Apply a prefix to the outbound routing key, which will be prefixed to the original message routing key (if no explicit routing key was provided in the constructor; ignored otherwise.
void	recover(Message message, Throwable cause) Callback for message that was consumed but failed all retry attempts.
void	setErrorRoutingKeyPrefix(String errorRoutingKeyPrefix)

Methods inherited from class java.lang.Object

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

Constructor Detail

RepublishMessageRecoverer

public RepublishMessageRecoverer(AmqpTemplate errorTemplate)

RepublishMessageRecoverer

public RepublishMessageRecoverer(AmqpTemplate errorTemplate,
                         String errorExchange)

RepublishMessageRecoverer

public RepublishMessageRecoverer(AmqpTemplate errorTemplate,
                         String errorExchange,
                         String errorRoutingKey)

Method Detail

errorRoutingKeyPrefix

public RepublishMessageRecoverer errorRoutingKeyPrefix(String errorRoutingKeyPrefix)

Apply a prefix to the outbound routing key, which will be prefixed to the original message routing key (if no explicit routing key was provided in the constructor; ignored otherwise. Use an empty string ("") for no prefixing.

Parameters:

errorRoutingKeyPrefix - The prefix (default "error.").

Returns:

this.

setErrorRoutingKeyPrefix

public void setErrorRoutingKeyPrefix(String errorRoutingKeyPrefix)

Parameters:

errorRoutingKeyPrefix - The prefix (default "error.").

See Also:

errorRoutingKeyPrefix(String)

recover

public void recover(Message message,
           Throwable cause)

Description copied from interface: MessageRecoverer

Callback for message that was consumed but failed all retry attempts.

Specified by:

recover in interface MessageRecoverer

Parameters:

message - the message to recover

cause - the cause of the error