com.consol.citrus.message.correlation

Class PollingCorrelationManager<T>

java.lang.Object

com.consol.citrus.message.correlation.DefaultCorrelationManager<T>

com.consol.citrus.message.correlation.PollingCorrelationManager<T>

All Implemented Interfaces:

CorrelationManager<T>

public class PollingCorrelationManager<T>
extends DefaultCorrelationManager<T>

Extension of default correlation manager adds polling mechanism for find operation on object store. In case object is not found in store retry is automatically performed. Polling interval and overall retry timeout is usually defined in endpoint configuration.

Since:

2.1

Author:

Christoph Deppisch

Constructor Summary

Constructors

Constructor and Description
PollingCorrelationManager(PollableEndpointConfiguration endpointConfiguration, String retryLogMessage) Constructor using fields.

Method Summary

Modifier and Type	Method and Description
T	find(String correlationKey) Convenience method for using default timeout settings of endpoint configuration.
T	find(String correlationKey, long timeout) Finds stored object by its correlation key.
String	getCorrelationKey(String correlationKeyName, TestContext context) Gets correlation key for given identifier.
String	getRetryLogMessage() Gets the retry log message
void	setRetryLogMessage(String retryLogMessage) Sets the retry log message.

Methods inherited from class com.consol.citrus.message.correlation.DefaultCorrelationManager

getObjectStore, saveCorrelationKey, setObjectStore, store

Methods inherited from class java.lang.Object

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

Constructor Detail

PollingCorrelationManager

public PollingCorrelationManager(PollableEndpointConfiguration endpointConfiguration,
                                 String retryLogMessage)

Constructor using fields.

Parameters:

endpointConfiguration -

retryLogMessage -

Method Detail

find

public T find(String correlationKey)

Convenience method for using default timeout settings of endpoint configuration.

Parameters:

correlationKey -

Returns:

getCorrelationKey

public String getCorrelationKey(String correlationKeyName,
                                TestContext context)

Description copied from interface: CorrelationManager

Gets correlation key for given identifier. Consults test context with test variables for retrieving stored correlation key.

Specified by:

getCorrelationKey in interface CorrelationManager<T>

Overrides:

getCorrelationKey in class DefaultCorrelationManager<T>

Returns:

find

public T find(String correlationKey,
              long timeout)

Description copied from interface: CorrelationManager

Finds stored object by its correlation key.

Specified by:

find in interface CorrelationManager<T>

Overrides:

find in class DefaultCorrelationManager<T>

Returns:

getRetryLogMessage

public String getRetryLogMessage()

Gets the retry log message

Returns:

setRetryLogMessage

public void setRetryLogMessage(String retryLogMessage)

Sets the retry log message.

Parameters:

retryLogMessage -