public interface DeadLetterStrategy
Modifier and Type | Method and Description |
---|---|
ActiveMQDestination |
getDeadLetterQueueFor(Message message,
Subscription subscription)
Returns the dead letter queue for the given message and subscription.
|
long |
getExpiration() |
boolean |
isProcessExpired() |
boolean |
isProcessNonPersistent() |
boolean |
isSendToDeadLetterQueue(Message message)
Allow pluggable strategy for deciding if message should be sent to a dead letter queue
for example, you might not want to ignore expired or non-persistent messages
|
void |
rollback(Message message)
Allows for a Message that was already processed by a DLQ to be rolled back in case
of a move or a retry of that message, otherwise the Message would be considered a
duplicate if this strategy is doing Message Auditing.
|
void |
setExpiration(long expiration)
The expiration value to use on messages sent to the DLQ, default 0
|
void |
setProcessExpired(boolean processExpired) |
void |
setProcessNonPersistent(boolean processNonPersistent) |
boolean isSendToDeadLetterQueue(Message message)
message
- ActiveMQDestination getDeadLetterQueueFor(Message message, Subscription subscription)
boolean isProcessExpired()
void setProcessExpired(boolean processExpired)
processExpired
- the processExpired to setboolean isProcessNonPersistent()
void setProcessNonPersistent(boolean processNonPersistent)
processNonPersistent
- the processNonPersistent to setvoid rollback(Message message)
message
- void setExpiration(long expiration)
long getExpiration()
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.