org.mule.retry.async

Class AsynchronousRetryTemplate

java.lang.Object

org.mule.retry.async.AsynchronousRetryTemplate

All Implemented Interfaces:

RetryPolicyTemplate

public class AsynchronousRetryTemplate
extends Object
implements RetryPolicyTemplate

This class is a wrapper for a RetryPolicyTemplate and will execute any retry work within a separate thread. An optional Latch can be passed into this template, in which case execution will only occur once the latch is released.

Constructor Summary

Constructors

Constructor and Description
AsynchronousRetryTemplate(RetryPolicyTemplate delegate)

Method Summary

Methods

Modifier and Type	Method and Description
RetryPolicy	createRetryInstance()
RetryContext	execute(RetryCallback callback, WorkManager workManager)
RetryPolicyTemplate	getDelegate()
Map<Object,Object>	getMetaInfo()
RetryNotifier	getNotifier()
boolean	isSynchronous()
void	setMetaInfo(Map<Object,Object> metaInfo)
void	setNotifier(RetryNotifier retryNotifier)
void	setStartLatch(Latch latch)

Methods inherited from class java.lang.Object

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

Constructor Detail

AsynchronousRetryTemplate

public AsynchronousRetryTemplate(RetryPolicyTemplate delegate)

Method Detail

execute

public RetryContext execute(RetryCallback callback,
                   WorkManager workManager)
                     throws Exception

Specified by:

execute in interface RetryPolicyTemplate

Throws:

Exception

createRetryInstance

public RetryPolicy createRetryInstance()

Specified by:

createRetryInstance in interface RetryPolicyTemplate

getNotifier

public RetryNotifier getNotifier()

Specified by:

getNotifier in interface RetryPolicyTemplate

setNotifier

public void setNotifier(RetryNotifier retryNotifier)

Specified by:

setNotifier in interface RetryPolicyTemplate

getMetaInfo

public Map<Object,Object> getMetaInfo()

Specified by:

getMetaInfo in interface RetryPolicyTemplate

setMetaInfo

public void setMetaInfo(Map<Object,Object> metaInfo)

Specified by:

setMetaInfo in interface RetryPolicyTemplate

getDelegate

public RetryPolicyTemplate getDelegate()

setStartLatch

public void setStartLatch(Latch latch)

isSynchronous

public boolean isSynchronous()

Specified by:

isSynchronous in interface RetryPolicyTemplate