Package | Description |
---|---|
org.mule.api.store | |
org.mule.processor | |
org.mule.routing |
Defines the core routing patterns supported by mule.
|
org.mule.routing.correlation | |
org.mule.security.oauth | |
org.mule.tck.util | |
org.mule.transport.jdbc.store | |
org.mule.transport.polling.watermark | |
org.mule.transport.polling.watermark.selector | |
org.mule.util.queue |
A resource manager that allow access to transactional queues with optional persistence.
|
org.mule.util.queue.objectstore |
A resource manager that allow access to transactional queues with optional persistence.
|
org.mule.util.store |
Modifier and Type | Class and Description |
---|---|
class |
ObjectAlreadyExistsException |
class |
ObjectDoesNotExistException |
class |
ObjectStoreNotAvaliableException
This exception is thrown when the underlying to an
ObjectStore 's system fails. |
Modifier and Type | Method and Description |
---|---|
List<Serializable> |
ListableObjectStore.allKeys() |
List<Serializable> |
PartitionableObjectStore.allKeys(String partitionName) |
List<String> |
PartitionableObjectStore.allPartitions() |
void |
ObjectStore.clear()
Removes all items of this store without disposing it, meaning that after
performing a clear(), you should still be able perform other operations.
|
void |
PartitionableObjectStore.clear(String partitionName) |
void |
ListableObjectStore.close()
Close the underlying store.
|
void |
PartitionableObjectStore.close(String partitionName) |
boolean |
ObjectStore.contains(Serializable key)
Check whether the given Object is already registered with this store.
|
boolean |
PartitionableObjectStore.contains(Serializable key,
String partitionName) |
void |
PartitionableObjectStore.disposePartition(String partitionName) |
void |
ObjectStoreManager.disposeStore(ObjectStore<? extends Serializable> store)
Delete all objects from the partition
|
void |
ExpirableObjectStore.expire(int entryTTL,
int maxEntries) |
void |
PartitionableExpirableObjectStore.expire(int entryTTL,
int maxEntries,
String partitionName) |
void |
ListableObjectStore.open()
Open the underlying store.
|
void |
PartitionableObjectStore.open(String partitionName) |
T |
ObjectStore.remove(Serializable key)
Remove the object with key.
|
T |
PartitionableObjectStore.remove(Serializable key,
String partitionName) |
T |
ObjectStore.retrieve(Serializable key)
Retrieve the given Object.
|
T |
PartitionableObjectStore.retrieve(Serializable key,
String partitionName) |
void |
ObjectStore.store(Serializable key,
T value)
Store the given Object.
|
void |
PartitionableObjectStore.store(Serializable key,
T value,
String partitionName) |
Modifier and Type | Method and Description |
---|---|
AtomicInteger |
IdempotentRedeliveryPolicy.findCounter(String messageId) |
Modifier and Type | Method and Description |
---|---|
void |
EventGroup.addEvent(MuleEvent event)
Add the given event to this group.
|
void |
EventGroup.clear()
Removes all events from this group.
|
protected MuleSession |
EventGroup.getMergedSession() |
void |
EventGroup.initEventsStore(PartitionableObjectStore<MuleEvent> events) |
Iterator<MuleEvent> |
EventGroup.iterator()
Returns an iterator over a snapshot copy of this group's collected events
sorted by their arrival time.
|
Iterator<MuleEvent> |
EventGroup.iterator(boolean sortByArrival)
Returns an iterator over a snapshot copy of this group's collected events.,
optionally sorted by arrival order.
|
void |
EventGroup.removeEvent(MuleEvent event)
Remove the given event from the group.
|
MuleEvent[] |
EventGroup.toArray()
Returns a snapshot of collected events in this group sorted by their arrival time.
|
MuleEvent[] |
EventGroup.toArray(boolean sortByArrival)
Returns a snapshot of collected events in this group, optionally sorted by their arrival time.
|
MuleMessageCollection |
EventGroup.toMessageCollection() |
MuleMessageCollection |
EventGroup.toMessageCollection(boolean sortByArrival) |
Modifier and Type | Method and Description |
---|---|
protected EventGroup |
EventCorrelator.addEventGroup(EventGroup group) |
protected void |
EventCorrelator.addProcessedGroup(Object id) |
protected EventGroup |
EventCorrelator.getEventGroup(Serializable groupId) |
protected boolean |
EventCorrelator.isGroupAlreadyProcessed(Object id) |
protected void |
EventCorrelator.removeEventGroup(EventGroup group) |
Modifier and Type | Method and Description |
---|---|
MuleEvent |
BaseOAuth2Manager.restoreAuthorizationEvent(String eventId)
Recovers a MuleEvent from the object store.
|
MuleEvent |
OAuth2Manager.restoreAuthorizationEvent(String eventId)
Recovers a MuleEvent from the object store.
|
Modifier and Type | Method and Description |
---|---|
void |
FakeObjectStore.clear() |
boolean |
FakeObjectStore.contains(Serializable key) |
T |
FakeObjectStore.remove(Serializable key) |
T |
FakeObjectStore.retrieve(Serializable key) |
void |
FakeObjectStore.store(Serializable key,
T value) |
Modifier and Type | Method and Description |
---|---|
void |
JdbcObjectStore.clear() |
boolean |
JdbcObjectStore.contains(Serializable key)
Check whether the given Object is already registered with this store.
|
T |
JdbcObjectStore.remove(Serializable key)
Remove the object with key.
|
T |
JdbcObjectStore.retrieve(Serializable key)
Retrieve the given Object.
|
void |
JdbcObjectStore.store(Serializable key,
T value)
Store the given Object.
|
void |
JdbcObjectStore.store(Serializable key,
T value,
String[] parameters) |
Modifier and Type | Method and Description |
---|---|
void |
WatermarkPollingInterceptor.postProcessRouting(MuleEvent event)
Watermark post processing saves the flow variable to the object store
|
void |
Watermark.putInto(MuleEvent event)
Retrieves the watermark value from the underlying peristent store and enriches
the event.If there is no value stored, a default expression will be used to
create a new one.
|
void |
Watermark.updateFrom(MuleEvent event)
Updates the watermark in persistent storage based on the flow variable defined
in the event
|
void |
Watermark.updateWith(MuleEvent event,
Serializable newValue) |
Modifier and Type | Method and Description |
---|---|
void |
SelectorWatermarkPollingInterceptor.postProcessRouting(MuleEvent event) |
Modifier and Type | Method and Description |
---|---|
boolean |
TransactionAwareQueueStore.offer(Serializable item,
long timeout) |
boolean |
Queue.offer(Serializable object,
long timeout) |
void |
TransactionAwareQueueStore.put(Serializable item) |
void |
Queue.put(Serializable object)
Puts a new object in this queue and wait if necessary.
|
void |
TransactionAwareQueueStore.untake(Serializable item) |
void |
Queue.untake(Serializable item) |
Modifier and Type | Method and Description |
---|---|
protected void |
TransactionalQueueManager.doClear(QueueInfo queue)
Deprecated.
|
protected Serializable |
TransactionalQueueManager.doLoad(QueueInfo queue,
Serializable id)
Deprecated.
|
protected void |
TransactionalQueueManager.doRemove(QueueInfo queue,
Serializable id)
Deprecated.
|
protected Serializable |
TransactionalQueueManager.doStore(QueueInfo queue,
Serializable object)
Deprecated.
|
boolean |
QueueTransactionContext.offer(QueueInfo queue,
Serializable item,
long offerTimeout)
Deprecated.
|
boolean |
QueueInfo.offer(Serializable o,
int room,
long timeout)
Deprecated.
|
boolean |
QueueInfoDelegate.offer(Serializable o,
int room,
long timeout)
Deprecated.
Offer to append a new member to the end of the queue
|
Serializable |
QueueTransactionContext.peek(QueueInfo queue)
Deprecated.
|
Serializable |
QueueTransactionContext.poll(QueueInfo queue,
long pollTimeout)
Deprecated.
|
void |
QueueTransactionContext.untake(QueueInfo queue,
Serializable item)
Deprecated.
|
void |
QueueInfo.untake(Serializable item)
Deprecated.
|
void |
QueueInfoDelegate.untake(Serializable item)
Deprecated.
Restore a previously removed member to the front of the queue
|
void |
QueueInfo.writeToObjectStore(Serializable data)
Deprecated.
|
void |
TakingQueueStoreDelegate.writeToObjectStore(Serializable data)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
List<Serializable> |
QueuePersistenceObjectStore.allKeys()
Deprecated.
|
List<Serializable> |
PartitionedObjectStoreWrapper.allKeys() |
List<Serializable> |
MonitoredObjectStoreWrapper.allKeys() |
List<Serializable> |
QueueStoreAdapter.allKeys()
Deprecated.
|
List<Serializable> |
PersistentObjectStorePartition.allKeys() |
List<Serializable> |
ManagedObjectStore.allKeys() |
List<Serializable> |
AbstractPartitionedObjectStore.allKeys() |
List<Serializable> |
SimpleMemoryObjectStore.allKeys() |
List<Serializable> |
ProvidedPartitionableObjectStoreWrapper.allKeys() |
List<Serializable> |
ObjectStorePartition.allKeys() |
List<Serializable> |
PartitionedInMemoryObjectStore.allKeys(String partitionName) |
List<Serializable> |
ProvidedPartitionableObjectStoreWrapper.allKeys(String partitionName) |
List<Serializable> |
PartitionedPersistentObjectStore.allKeys(String partitionName) |
List<String> |
PartitionedInMemoryObjectStore.allPartitions() |
List<String> |
ProvidedPartitionableObjectStoreWrapper.allPartitions() |
List<String> |
PartitionedPersistentObjectStore.allPartitions() |
void |
InMemoryObjectStore.clear() |
void |
ProvidedObjectStoreWrapper.clear() |
void |
QueuePersistenceObjectStore.clear()
Deprecated.
|
void |
PartitionedObjectStoreWrapper.clear() |
void |
MonitoredObjectStoreWrapper.clear() |
void |
QueueStoreAdapter.clear()
Deprecated.
|
void |
PersistentObjectStorePartition.clear() |
void |
ManagedObjectStore.clear() |
void |
AbstractPartitionedObjectStore.clear() |
void |
SimpleMemoryObjectStore.clear() |
void |
ObjectStorePartition.clear() |
void |
PartitionedInMemoryObjectStore.clear(String partitionName) |
void |
ProvidedPartitionableObjectStoreWrapper.clear(String partitionName) |
void |
PartitionedPersistentObjectStore.clear(String partitionName) |
void |
QueuePersistenceObjectStore.close()
Deprecated.
|
void |
PartitionedObjectStoreWrapper.close() |
void |
MonitoredObjectStoreWrapper.close() |
void |
QueueStoreAdapter.close()
Deprecated.
|
void |
PersistentObjectStorePartition.close() |
void |
ManagedObjectStore.close() |
void |
AbstractPartitionedObjectStore.close() |
void |
SimpleMemoryObjectStore.close() |
void |
ProvidedPartitionableObjectStoreWrapper.close() |
void |
ObjectStorePartition.close() |
void |
PartitionedInMemoryObjectStore.close(String partitionName) |
void |
ProvidedPartitionableObjectStoreWrapper.close(String partitionName) |
void |
PartitionedPersistentObjectStore.close(String partitionName) |
protected List<Serializable> |
QueuePersistenceObjectStore.collectAllKeys()
Deprecated.
|
boolean |
InMemoryObjectStore.contains(Serializable key) |
boolean |
ProvidedObjectStoreWrapper.contains(Serializable key) |
boolean |
PartitionedObjectStoreWrapper.contains(Serializable key) |
boolean |
MonitoredObjectStoreWrapper.contains(Serializable key) |
boolean |
QueueStoreAdapter.contains(Serializable key)
Deprecated.
|
boolean |
PersistentObjectStorePartition.contains(Serializable key) |
boolean |
ManagedObjectStore.contains(Serializable key) |
boolean |
AbstractPartitionedObjectStore.contains(Serializable key) |
boolean |
AbstractObjectStore.contains(Serializable key) |
boolean |
ObjectStorePartition.contains(Serializable key) |
boolean |
PartitionedInMemoryObjectStore.contains(Serializable key,
String partitionName) |
boolean |
ProvidedPartitionableObjectStoreWrapper.contains(Serializable key,
String partitionName) |
boolean |
PartitionedPersistentObjectStore.contains(Serializable key,
String partitionName) |
protected void |
PersistentObjectStorePartition.createDirectory(File directory) |
protected File |
PersistentObjectStorePartition.createFileToStoreObject() |
protected File |
PersistentObjectStorePartition.createOrRetrievePartitionDescriptorFile() |
protected void |
QueuePersistenceObjectStore.createStoreDirectory(File directory)
Deprecated.
|
protected File |
QueuePersistenceObjectStore.createStoreFile(Serializable key)
Deprecated.
|
protected void |
QueuePersistenceObjectStore.deleteStoreFile(File file)
Deprecated.
|
protected void |
PersistentObjectStorePartition.deleteStoreFile(File file) |
protected T |
QueuePersistenceObjectStore.deserialize(File file)
Deprecated.
|
protected PersistentObjectStorePartition.StoreValue<T> |
PersistentObjectStorePartition.deserialize(File file) |
void |
PartitionedInMemoryObjectStore.disposePartition(String partitionName) |
void |
ProvidedPartitionableObjectStoreWrapper.disposePartition(String partitionName) |
void |
PartitionedPersistentObjectStore.disposePartition(String partitionName) |
void |
MuleObjectStoreManager.disposeStore(ObjectStore<? extends Serializable> store) |
protected boolean |
QueuePersistenceObjectStore.doContains(Serializable key)
Deprecated.
|
protected abstract boolean |
AbstractObjectStore.doContains(Serializable key) |
protected T |
QueuePersistenceObjectStore.doRemove(Serializable key)
Deprecated.
|
protected abstract T |
AbstractObjectStore.doRemove(Serializable key) |
protected T |
QueuePersistenceObjectStore.doRetrieve(Serializable key)
Deprecated.
|
protected abstract T |
AbstractObjectStore.doRetrieve(Serializable key) |
protected void |
QueuePersistenceObjectStore.doStore(Serializable key,
T value)
Deprecated.
|
protected abstract void |
AbstractObjectStore.doStore(Serializable key,
T value) |
protected void |
SimpleMemoryObjectStore.doStore(Serializable key,
T value) |
protected void |
QueuePersistenceObjectStore.ensureStoreDirectoryExists(File outputFile)
Deprecated.
|
void |
PersistentObjectStorePartition.expire(int entryTTL,
int maxEntries) |
void |
PartitionedInMemoryObjectStore.expire(int entryTTL,
int maxEntries) |
void |
PartitionedPersistentObjectStore.expire(int entryTTL,
int maxEntries) |
void |
PartitionedInMemoryObjectStore.expire(int entryTTL,
int maxEntries,
String partitionName) |
void |
PartitionedPersistentObjectStore.expire(int entryTTL,
int maxEntries,
String partitionName) |
void |
QueuePersistenceObjectStore.open()
Deprecated.
|
void |
PartitionedObjectStoreWrapper.open() |
void |
MonitoredObjectStoreWrapper.open() |
void |
QueueStoreAdapter.open()
Deprecated.
|
void |
PersistentObjectStorePartition.open() |
void |
ManagedObjectStore.open() |
void |
AbstractPartitionedObjectStore.open() |
void |
SimpleMemoryObjectStore.open() |
void |
ProvidedPartitionableObjectStoreWrapper.open() |
void |
PartitionedPersistentObjectStore.open() |
void |
ObjectStorePartition.open() |
void |
PartitionedInMemoryObjectStore.open(String partitionName) |
void |
ProvidedPartitionableObjectStoreWrapper.open(String partitionName) |
void |
PartitionedPersistentObjectStore.open(String partitionName) |
T |
InMemoryObjectStore.remove(Serializable key) |
T |
ProvidedObjectStoreWrapper.remove(Serializable key) |
T |
PartitionedObjectStoreWrapper.remove(Serializable key) |
T |
MonitoredObjectStoreWrapper.remove(Serializable key) |
T |
QueueStoreAdapter.remove(Serializable key)
Deprecated.
|
T |
PersistentObjectStorePartition.remove(Serializable key) |
T |
ManagedObjectStore.remove(Serializable key) |
T |
AbstractPartitionedObjectStore.remove(Serializable key) |
T |
AbstractObjectStore.remove(Serializable key) |
T |
ObjectStorePartition.remove(Serializable key) |
T |
PartitionedInMemoryObjectStore.remove(Serializable key,
String partitionName) |
T |
ProvidedPartitionableObjectStoreWrapper.remove(Serializable key,
String partitionName) |
T |
PartitionedPersistentObjectStore.remove(Serializable key,
String partitionName) |
T |
InMemoryObjectStore.retrieve(Serializable key) |
T |
ProvidedObjectStoreWrapper.retrieve(Serializable key) |
T |
PartitionedObjectStoreWrapper.retrieve(Serializable key) |
T |
MonitoredObjectStoreWrapper.retrieve(Serializable key) |
T |
QueueStoreAdapter.retrieve(Serializable key)
Deprecated.
|
T |
PersistentObjectStorePartition.retrieve(Serializable key) |
T |
ManagedObjectStore.retrieve(Serializable key) |
T |
AbstractPartitionedObjectStore.retrieve(Serializable key) |
T |
AbstractObjectStore.retrieve(Serializable key) |
T |
ObjectStorePartition.retrieve(Serializable key) |
T |
PartitionedInMemoryObjectStore.retrieve(Serializable key,
String partitionName) |
T |
ProvidedPartitionableObjectStoreWrapper.retrieve(Serializable key,
String partitionName) |
T |
PartitionedPersistentObjectStore.retrieve(Serializable key,
String partitionName) |
protected void |
PersistentObjectStorePartition.serialize(File outputFile,
PersistentObjectStorePartition.StoreValue<T> storeValue) |
protected void |
QueuePersistenceObjectStore.serialize(T value,
File outputFile)
Deprecated.
|
void |
TextFileObjectStore.store(Serializable id,
String item) |
void |
InMemoryObjectStore.store(Serializable id,
T value) |
void |
ProvidedObjectStoreWrapper.store(Serializable key,
T value) |
void |
PartitionedObjectStoreWrapper.store(Serializable key,
T value) |
void |
MonitoredObjectStoreWrapper.store(Serializable key,
T value) |
void |
QueueStoreAdapter.store(Serializable key,
T value)
Deprecated.
|
void |
PersistentObjectStorePartition.store(Serializable key,
T value) |
void |
ManagedObjectStore.store(Serializable key,
T value) |
void |
AbstractPartitionedObjectStore.store(Serializable key,
T value) |
void |
AbstractObjectStore.store(Serializable key,
T value) |
void |
ObjectStorePartition.store(Serializable key,
T value) |
void |
PartitionedInMemoryObjectStore.store(Serializable key,
T value,
String partitionName) |
void |
ProvidedPartitionableObjectStoreWrapper.store(Serializable key,
T value,
String partitionName) |
void |
PartitionedPersistentObjectStore.store(Serializable key,
T value,
String partitionName) |
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.