public class IdempotentRedeliveryPolicy extends AbstractRedeliveryPolicy
Modifier and Type | Field and Description |
---|---|
protected Logger |
logger |
deadLetterQueue, flowConstruct, maxRedeliveryCount, REDELIVERY_FAIL_ON_FIRST
muleContext, next, notificationHandler
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
PROPERTY_NAME
Constructor and Description |
---|
IdempotentRedeliveryPolicy() |
Modifier and Type | Method and Description |
---|---|
void |
dispose()
A lifecycle method where implementor should free up any resources.
|
AtomicInteger |
findCounter(String messageId) |
String |
getIdExpression() |
String |
getMessageDigestAlgorithm() |
void |
initialise()
Method used to perform any initialisation work.
|
protected org.apache.commons.collections.Factory |
internalObjectStoreFactory() |
boolean |
isUseSecureHash() |
MuleEvent |
process(MuleEvent event)
Invokes the MessageProcessor.
|
void |
setIdExpression(String idExpression) |
void |
setMessageDigestAlgorithm(String messageDigestAlgorithm) |
void |
setMessageProcessor(MessageProcessor processor) |
void |
setObjectStore(ObjectStore<AtomicInteger> store) |
void |
setUseSecureHash(boolean useSecureHash) |
void |
start() |
getMaxRedeliveryCount, getTheFailedMessageProcessor, setDeadLetterQueue, setFlowConstruct, setMaxRedeliveryCount, setMessagingExceptionHandler, setMuleContext, stop
addMessageProcessorPathElements, getListener, getMuleContext, isEventValid, processNext, setListener, toString
getAnnotation, getAnnotations, setAnnotations
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
setListener
protected Logger logger
public void initialise() throws InitialisationException
Initialisable
InitialisationException
should be thrown,
causing the Mule instance to shutdown. If the error is recoverable, say by
retrying to connect, a RecoverableException
should be thrown.
There is no guarantee that by throwing a Recoverable exception that the Mule
instance will not shut down.initialise
in interface Initialisable
initialise
in class AbstractRedeliveryPolicy
InitialisationException
- if a fatal error occurs causing the Mule instance to shutdownRecoverableException
- if an error occurs that can be recovered fromprotected org.apache.commons.collections.Factory internalObjectStoreFactory()
public void dispose()
Disposable
dispose
in interface Disposable
dispose
in class AbstractRedeliveryPolicy
public void start() throws MuleException
start
in interface Startable
start
in class AbstractRedeliveryPolicy
MuleException
public MuleEvent process(MuleEvent event) throws MuleException
MessageProcessor
event
- MuleEvent to be processedMuleException
public AtomicInteger findCounter(String messageId) throws ObjectStoreException
ObjectStoreException
public boolean isUseSecureHash()
public void setUseSecureHash(boolean useSecureHash)
public String getMessageDigestAlgorithm()
public void setMessageDigestAlgorithm(String messageDigestAlgorithm)
public String getIdExpression()
public void setIdExpression(String idExpression)
public void setObjectStore(ObjectStore<AtomicInteger> store)
public void setMessageProcessor(MessageProcessor processor)
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.