Uses of Class
org.mule.api.store.ObjectStoreException

Packages that use ObjectStoreException

org.mule.api.store
org.mule.routing	Defines the core routing patterns supported by mule.
org.mule.routing.correlation
org.mule.transport.jdbc.store
org.mule.util.queue	A resource manager that allow access to transactional queues with optional persistence.
org.mule.util.store

Uses of ObjectStoreException in org.mule.api.store

Subclasses of ObjectStoreException in org.mule.api.store

class	ObjectAlreadyExistsException
class	ObjectDoesNotExistException
class	ObjectStoreNotAvaliableException This exception is thrown when the underlying to an ObjectStore's system fails.

Methods in org.mule.api.store that throw ObjectStoreException

List<Serializable>	ListableObjectStore.allKeys()
List<Serializable>	PartitionableObjectStore.allKeys(String partitionName)
List<String>	PartitionableObjectStore.allPartitions()
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)

Uses of ObjectStoreException in org.mule.routing

Methods in org.mule.routing that throw ObjectStoreException

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()
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)

Uses of ObjectStoreException in org.mule.routing.correlation

Methods in org.mule.routing.correlation that throw ObjectStoreException

protected EventGroup	EventCorrelator.addEventGroup(EventGroup group)
protected void	EventCorrelator.addProcessedGroup(Object id)
protected EventGroup	EventCorrelator.getEventGroup(String groupId)
protected boolean	EventCorrelator.isGroupAlreadyProcessed(Object id)
protected void	EventCorrelator.removeEventGroup(EventGroup group)

Uses of ObjectStoreException in org.mule.transport.jdbc.store

Methods in org.mule.transport.jdbc.store that throw ObjectStoreException

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)

Uses of ObjectStoreException in org.mule.util.queue

Methods in org.mule.util.queue that throw ObjectStoreException

protected Serializable	TransactionalQueueManager.doLoad(QueueInfo queue, Serializable id)
protected void	TransactionalQueueManager.doRemove(QueueInfo queue, Serializable id)
protected Serializable	TransactionalQueueManager.doStore(QueueInfo queue, Serializable object)
boolean	QueueTransactionContext.offer(QueueInfo queue, Serializable item, long offerTimeout)
boolean	QueueInfo.offer(Serializable o, int room, long timeout)
boolean	QueueInfoDelegate.offer(Serializable o, int room, long timeout) Offer to append a new member to the end of the queue
boolean	Queue.offer(Serializable object, long timeout)
Serializable	QueueTransactionContext.peek(QueueInfo queue)
Serializable	QueueTransactionContext.poll(QueueInfo queue, long pollTimeout)
void	Queue.put(Serializable object) Puts a new object in this queue and wait if necessary.
void	QueueTransactionContext.untake(QueueInfo queue, Serializable item)
void	QueueInfo.untake(Serializable item)
void	QueueInfoDelegate.untake(Serializable item) Restore a previously removed member to the front of the queue
void	Queue.untake(Serializable item)
void	QueueInfo.writeToObjectStore(Serializable data)
void	TakingQueueInfoDelegate.writeToObjectStore(Serializable data)

Uses of ObjectStoreException in org.mule.util.store

Methods in org.mule.util.store that throw ObjectStoreException

List<Serializable>	MonitoredObjectStoreWrapper.allKeys()
List<Serializable>	QueuePersistenceObjectStore.allKeys()
List<Serializable>	AbstractPartitionedObjectStore.allKeys()
List<Serializable>	QueueStoreAdapter.allKeys()
List<Serializable>	ObjectStorePartition.allKeys()
List<Serializable>	PartitionedObjectStoreWrapper.allKeys()
List<Serializable>	ManagedObjectStore.allKeys()
List<Serializable>	SimpleMemoryObjectStore.allKeys()
List<Serializable>	PartitionedPersistentObjectStore.allKeys(String partitionName)
List<Serializable>	PartitionedInMemoryObjectStore.allKeys(String partitionName)
List<String>	PartitionedPersistentObjectStore.allPartitions()
List<String>	PartitionedInMemoryObjectStore.allPartitions()
void	MonitoredObjectStoreWrapper.close()
void	QueuePersistenceObjectStore.close()
void	AbstractPartitionedObjectStore.close()
void	QueueStoreAdapter.close()
void	ObjectStorePartition.close()
void	PartitionedObjectStoreWrapper.close()
void	ManagedObjectStore.close()
void	SimpleMemoryObjectStore.close()
void	PartitionedPersistentObjectStore.close(String partitionName)
void	PartitionedInMemoryObjectStore.close(String partitionName)
protected List<Serializable>	QueuePersistenceObjectStore.collectAllKeys()
protected List<Serializable>	PartitionedPersistentObjectStore.collectAllKeys(String partitionName)
boolean	MonitoredObjectStoreWrapper.contains(Serializable key)
boolean	AbstractPartitionedObjectStore.contains(Serializable key)
boolean	QueueStoreAdapter.contains(Serializable key)
boolean	InMemoryObjectStore.contains(Serializable key)
boolean	ObjectStorePartition.contains(Serializable key)
boolean	AbstractObjectStore.contains(Serializable key)
boolean	PartitionedObjectStoreWrapper.contains(Serializable key)
boolean	ManagedObjectStore.contains(Serializable key)
boolean	PartitionedPersistentObjectStore.contains(Serializable key, String partitionName)
boolean	PartitionedInMemoryObjectStore.contains(Serializable key, String partitionName)
protected void	QueuePersistenceObjectStore.createStoreDirectory(File directory)
protected void	PartitionedPersistentObjectStore.createStoreDirectory(File directory)
protected File	QueuePersistenceObjectStore.createStoreFile(Serializable key)
protected File	PartitionedPersistentObjectStore.createStoreFile(Serializable key, String partitionName)
protected File	PartitionedPersistentObjectStore.createStorePartition(String partitionName)
protected void	QueuePersistenceObjectStore.deleteStoreFile(File file)
protected void	PartitionedPersistentObjectStore.deleteStoreFile(File file)
protected T	QueuePersistenceObjectStore.deserialize(File file)
protected T	PartitionedPersistentObjectStore.deserialize(File file)
void	PartitionedPersistentObjectStore.disposePartition(String partitionName)
void	PartitionedInMemoryObjectStore.disposePartition(String partitionName)
void	MuleObjectStoreManager.disposeStore(ObjectStore<? extends Serializable> store)
protected boolean	QueuePersistenceObjectStore.doContains(Serializable key)
protected abstract boolean	AbstractObjectStore.doContains(Serializable key)
protected T	QueuePersistenceObjectStore.doRemove(Serializable key)
protected abstract T	AbstractObjectStore.doRemove(Serializable key)
protected T	QueuePersistenceObjectStore.doRetrieve(Serializable key)
protected abstract T	AbstractObjectStore.doRetrieve(Serializable key)
protected void	QueuePersistenceObjectStore.doStore(Serializable key, T value)
protected abstract void	AbstractObjectStore.doStore(Serializable key, T value)
protected void	SimpleMemoryObjectStore.doStore(Serializable key, T value)
protected void	QueuePersistenceObjectStore.ensureStoreDirectoryExists(File outputFile)
protected void	PartitionedPersistentObjectStore.ensureStoreDirectoryExists(File outputFile)
void	PartitionedPersistentObjectStore.expire(int entryTTL, int maxEntries)
void	PartitionedInMemoryObjectStore.expire(int entryTTL, int maxEntries)
void	PartitionedPersistentObjectStore.expire(int entryTTL, int maxEntries, String partitionName)
void	PartitionedInMemoryObjectStore.expire(int entryTTL, int maxEntries, String partitionName)
void	MonitoredObjectStoreWrapper.open()
void	QueuePersistenceObjectStore.open()
void	PartitionedPersistentObjectStore.open()
void	AbstractPartitionedObjectStore.open()
void	QueueStoreAdapter.open()
void	ObjectStorePartition.open()
void	PartitionedObjectStoreWrapper.open()
void	ManagedObjectStore.open()
void	SimpleMemoryObjectStore.open()
void	PartitionedPersistentObjectStore.open(String partitionName)
void	PartitionedInMemoryObjectStore.open(String partitionName)
T	MonitoredObjectStoreWrapper.remove(Serializable key)
T	AbstractPartitionedObjectStore.remove(Serializable key)
T	QueueStoreAdapter.remove(Serializable key)
T	InMemoryObjectStore.remove(Serializable key)
T	ObjectStorePartition.remove(Serializable key)
T	AbstractObjectStore.remove(Serializable key)
T	PartitionedObjectStoreWrapper.remove(Serializable key)
T	ManagedObjectStore.remove(Serializable key)
T	PartitionedPersistentObjectStore.remove(Serializable key, String partitionName)
T	PartitionedInMemoryObjectStore.remove(Serializable key, String partitionName)
T	MonitoredObjectStoreWrapper.retrieve(Serializable key)
T	AbstractPartitionedObjectStore.retrieve(Serializable key)
T	QueueStoreAdapter.retrieve(Serializable key)
T	InMemoryObjectStore.retrieve(Serializable key)
T	ObjectStorePartition.retrieve(Serializable key)
T	AbstractObjectStore.retrieve(Serializable key)
T	PartitionedObjectStoreWrapper.retrieve(Serializable key)
T	ManagedObjectStore.retrieve(Serializable key)
T	PartitionedPersistentObjectStore.retrieve(Serializable key, String partitionName)
T	PartitionedInMemoryObjectStore.retrieve(Serializable key, String partitionName)
protected void	QueuePersistenceObjectStore.serialize(T value, File outputFile)
protected void	PartitionedPersistentObjectStore.serialize(T value, File outputFile)
void	TextFileObjectStore.store(Serializable id, String item)
void	MonitoredObjectStoreWrapper.store(Serializable key, T value)
void	AbstractPartitionedObjectStore.store(Serializable key, T value)
void	QueueStoreAdapter.store(Serializable key, T value)
void	InMemoryObjectStore.store(Serializable id, T value)
void	ObjectStorePartition.store(Serializable key, T value)
void	AbstractObjectStore.store(Serializable key, T value)
void	PartitionedObjectStoreWrapper.store(Serializable key, T value)
void	ManagedObjectStore.store(Serializable key, T value)
void	PartitionedPersistentObjectStore.store(Serializable key, T value, String partitionName)
void	PartitionedInMemoryObjectStore.store(Serializable key, T value, String partitionName)