Class RepublishMessageRecoverer
java.lang.Object
org.springframework.amqp.rabbit.retry.RepublishMessageRecoverer
- All Implemented Interfaces:
MessageRecoverer
- Direct Known Subclasses:
RepublishMessageRecovererWithConfirms
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, Artem Bilan
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionRepublishMessageRecoverer(AmqpTemplate errorTemplate) RepublishMessageRecoverer(AmqpTemplate errorTemplate, String errorExchange) RepublishMessageRecoverer(AmqpTemplate errorTemplate, String errorExchange, String errorRoutingKey) -
Method Summary
Modifier and TypeMethodDescriptionadditionalHeaders(Message message, Throwable cause) Subclasses can override this method to add more headers to the republished message.protected voidSend the message.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.frameMaxHeadroom(int headroom) Set the amount by which the negotiated frame_max is to be reduced when considering truncating the stack trace header.protected MessageDeliveryModeprotected StringvoidCallback for message that was consumed but failed all retry attempts.voidsetDeliveryMode(MessageDeliveryMode deliveryMode) Specify aMessageDeliveryModeto set into the message to republish if the message doesn't have it already.voidsetErrorRoutingKeyPrefix(String errorRoutingKeyPrefix)
-
Field Details
-
X_EXCEPTION_STACKTRACE
- See Also:
-
X_EXCEPTION_MESSAGE
- See Also:
-
X_ORIGINAL_EXCHANGE
- See Also:
-
X_ORIGINAL_ROUTING_KEY
- See Also:
-
DEFAULT_FRAME_MAX_HEADROOM
public static final int DEFAULT_FRAME_MAX_HEADROOM- See Also:
-
logger
-
errorTemplate
-
errorRoutingKey
-
errorExchangeName
-
-
Constructor Details
-
RepublishMessageRecoverer
-
RepublishMessageRecoverer
-
RepublishMessageRecoverer
public RepublishMessageRecoverer(AmqpTemplate errorTemplate, String errorExchange, String errorRoutingKey)
-
-
Method Details
-
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.
-
frameMaxHeadroom
Set the amount by which the negotiated frame_max is to be reduced when considering truncating the stack trace header. Defaults to 20000.- Parameters:
headroom- the headroom- Returns:
- this.
- Since:
- 2.0.5
-
setErrorRoutingKeyPrefix
- Parameters:
errorRoutingKeyPrefix- The prefix (default "error.").- See Also:
-
getErrorRoutingKeyPrefix
-
setDeliveryMode
Specify aMessageDeliveryModeto set into the message to republish if the message doesn't have it already.- Parameters:
deliveryMode- the delivery mode to set to message.- Since:
- 2.0
-
getDeliveryMode
-
recover
Description copied from interface:MessageRecovererCallback for message that was consumed but failed all retry attempts.- Specified by:
recoverin interfaceMessageRecoverer- Parameters:
message- the message to recovercause- the cause of the error
-
doSend
Send the message.- Parameters:
exchange- the exchange or null to use the template's default.routingKey- the routing key.message- the message.- Since:
- 2.3.3
-
additionalHeaders
Subclasses can override this method to add more headers to the republished message.- Parameters:
message- The failed message.cause- The cause.- Returns:
- A
Mapof additional headers to add.
-