Package org.citrusframework.message.correlation

Class DefaultCorrelationManager<T>

java.lang.Object

org.citrusframework.message.correlation.DefaultCorrelationManager<T>

All Implemented Interfaces:

org.citrusframework.message.correlation.CorrelationManager<T>

Direct Known Subclasses:

PollingCorrelationManager

public class DefaultCorrelationManager<T>
extends Object
implements org.citrusframework.message.correlation.CorrelationManager<T>

Default correlation manager implementation works on simple in memory map for storing objects. Correlation key is the map key. Clients can access objects in the store using the correlation key.

Since:

2.0

Constructor Summary

Constructors

Constructor	Description
DefaultCorrelationManager()

Method Summary

Modifier and Type	Method	Description
T	find(String correlationKey, long timeout)
String	getCorrelationKey(String correlationKeyName, org.citrusframework.context.TestContext context)
org.citrusframework.message.correlation.ObjectStore<T>	getObjectStore()
void	saveCorrelationKey(String correlationKeyName, String correlationKey, org.citrusframework.context.TestContext context)
void	setObjectStore(org.citrusframework.message.correlation.ObjectStore<T> store)
void	store(String correlationKey, T object)

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultCorrelationManager

public DefaultCorrelationManager()

Method Details

saveCorrelationKey

public void saveCorrelationKey(String correlationKeyName,
 String correlationKey,
 org.citrusframework.context.TestContext context)

Specified by:

saveCorrelationKey in interface org.citrusframework.message.correlation.CorrelationManager<T>

getCorrelationKey

public String getCorrelationKey(String correlationKeyName,
 org.citrusframework.context.TestContext context)

Specified by:

getCorrelationKey in interface org.citrusframework.message.correlation.CorrelationManager<T>

store

public void store(String correlationKey,
 T object)

Specified by:

store in interface org.citrusframework.message.correlation.CorrelationManager<T>

find

public T find(String correlationKey,
 long timeout)

Specified by:

find in interface org.citrusframework.message.correlation.CorrelationManager<T>

setObjectStore

public void setObjectStore(org.citrusframework.message.correlation.ObjectStore<T> store)

Specified by:

setObjectStore in interface org.citrusframework.message.correlation.CorrelationManager<T>

getObjectStore

public org.citrusframework.message.correlation.ObjectStore<T> getObjectStore()

Specified by:

getObjectStore in interface org.citrusframework.message.correlation.CorrelationManager<T>