Package | Description |
---|---|
org.mule.api.store | |
org.mule.routing |
Defines the core routing patterns supported by mule.
|
org.mule.routing.correlation | |
org.mule.util.store |
Modifier and Type | Interface and Description |
---|---|
interface |
PartitionableExpirableObjectStore<T extends Serializable> |
Modifier and Type | Method and Description |
---|---|
void |
EventGroup.initEventsStore(PartitionableObjectStore<MuleEvent> events) |
void |
AbstractAggregator.setEventGroupsObjectStore(PartitionableObjectStore<MuleEvent> eventGroupsObjectStore) |
Constructor and Description |
---|
EventCorrelator(EventCorrelatorCallback callback,
MessageProcessor timeoutMessageProcessor,
MessageInfoMapping messageInfoMapping,
MuleContext muleContext,
FlowConstruct flowConstruct,
PartitionableObjectStore correlatorStore,
String storePrefix,
ObjectStore<Long> processedGroups) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractPartitionedObjectStore<T extends Serializable> |
class |
PartitionedInMemoryObjectStore<T extends Serializable> |
class |
PartitionedPersistentObjectStore<T extends Serializable> |
class |
ProvidedPartitionableObjectStoreWrapper<T extends Serializable>
Will wrap a provided object store or a newly created one with the provided factory, with the provided having
precedence if present.
|
Modifier and Type | Method and Description |
---|---|
PartitionableObjectStore<T> |
ObjectStorePartition.getBaseStore() |
protected PartitionableObjectStore<T> |
ProvidedPartitionableObjectStoreWrapper.getWrapped() |
Constructor and Description |
---|
ObjectStorePartition(String partitionName,
PartitionableObjectStore<T> partitionedObjectStore) |
ProvidedPartitionableObjectStoreWrapper(PartitionableObjectStore<T> providedObjectStore,
org.apache.commons.collections.Factory objectStoreFactory)
Wraps the
providedObjectStore if given, or uses the objectStoreFactory to create one. |
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.