Uses of Interface
org.xmlBlaster.util.queue.I_QueueEntry

Packages that use I_QueueEntry

org.xmlBlaster.client.dispatch
org.xmlBlaster.client.queuemsg
org.xmlBlaster.engine.dispatch
org.xmlBlaster.engine.queuemsg
org.xmlBlaster.test.classtest.queue
org.xmlBlaster.util.dispatch
org.xmlBlaster.util.queue
org.xmlBlaster.util.queue.cache
org.xmlBlaster.util.queue.jdbc
org.xmlBlaster.util.queue.ram
org.xmlBlaster.util.queuemsg

Uses of I_QueueEntry in org.xmlBlaster.client.dispatch

Methods in org.xmlBlaster.client.dispatch with parameters of type I_QueueEntry

void	ClientDispatchConnectionsHandler.createFakedReturnObjects(I_QueueEntry[] entries, java.lang.String state, java.lang.String stateInfo) If no connection is available but the message is for example save queued, we can generate here valid return objects
void	ClientDispatchManager.putPost(I_QueueEntry queueEntry)
void	ClientDispatchManager.putPost(I_QueueEntry[] queueEntries)
boolean	ClientDispatchManager.putPre(I_QueueEntry queueEntry)
boolean	ClientDispatchManager.putPre(I_QueueEntry[] queueEntries)

Uses of I_QueueEntry in org.xmlBlaster.client.queuemsg

Classes in org.xmlBlaster.client.queuemsg that implement I_QueueEntry

class	MsgQueueConnectEntry Wraps an connect() message into an entry for a sorted queue.
class	MsgQueueDisconnectEntry Wraps an disconnect() message into an entry for a sorted queue.
class	MsgQueueEraseEntry Wraps an erase() message into an entry for a sorted queue.
class	MsgQueueGetEntry Wraps an get() message into an entry for a sorted queue.
class	MsgQueuePublishEntry Wraps an publish() message into an entry for a sorted queue.
class	MsgQueueSubscribeEntry Wraps an subscribe() message into an entry for a sorted queue.
class	MsgQueueUnSubscribeEntry Wraps an unSubscribe() message into an entry for a sorted queue.

Uses of I_QueueEntry in org.xmlBlaster.engine.dispatch

Methods in org.xmlBlaster.engine.dispatch with parameters of type I_QueueEntry

void	CbDispatchConnectionsHandler.createFakedReturnObjects(I_QueueEntry[] entries, java.lang.String state, java.lang.String stateInfo) If no connection is available but the message is for example save queued, we can generate here valid return objects
void	ServerDispatchManager.putPost(I_QueueEntry queueEntry)
void	ServerDispatchManager.putPost(I_QueueEntry[] queueEntries)
boolean	ServerDispatchManager.putPre(I_QueueEntry queueEntry)
boolean	ServerDispatchManager.putPre(I_QueueEntry[] queueEntries)

Uses of I_QueueEntry in org.xmlBlaster.engine.queuemsg

Classes in org.xmlBlaster.engine.queuemsg that implement I_QueueEntry

class	MsgQueueHistoryEntry Wraps an publish() message into an entry for a sorted queue.
class	MsgQueueUpdateEntry Wraps an publish() message into an entry for a sorted queue.
class	ReferenceEntry Wraps an publish() message into an entry for a sorted queue.

Uses of I_QueueEntry in org.xmlBlaster.test.classtest.queue

Methods in org.xmlBlaster.test.classtest.queue with parameters of type I_QueueEntry

private int	I_QueueTest.assertCheckForTakeLowest(I_Queue queue, int numEntries, long numBytes, I_QueueEntry refEntry, boolean leaveOne, I_QueueEntry[] origEntries, int entriesLeft, int currentEntries, long size) returns the number of entries left in the queue after this processing operation
private int	I_QueueTest.assertCheckForTakeLowest(I_Queue queue, int numEntries, long numBytes, I_QueueEntry refEntry, boolean leaveOne, I_QueueEntry[] origEntries, int entriesLeft, int currentEntries, long size) returns the number of entries left in the queue after this processing operation
private void	I_QueueTest.checkSizeAndEntries(java.lang.String txt, I_QueueEntry[] queueEntries, I_Queue queue) Helper method to do a generic size check (size and number of entries)

Uses of I_QueueEntry in org.xmlBlaster.util.dispatch

Methods in org.xmlBlaster.util.dispatch with parameters of type I_QueueEntry

abstract void	DispatchConnectionsHandler.createFakedReturnObjects(I_QueueEntry[] entries, java.lang.String state, java.lang.String stateInfo) If no connection is available but the message is for example save queued, we can generate here valid return objects
void	I_DispatchManager.putPost(I_QueueEntry queueEntry)
void	I_DispatchManager.putPost(I_QueueEntry[] queueEntries)
boolean	I_DispatchManager.putPre(I_QueueEntry queueEntry)
boolean	I_DispatchManager.putPre(I_QueueEntry[] queueEntries)

Uses of I_QueueEntry in org.xmlBlaster.util.queue

Methods in org.xmlBlaster.util.queue that return I_QueueEntry

I_QueueEntry

I_Queue.peek() Returns the first element in the queue but does not remove it from that queue (leaves it untouched).

Methods in org.xmlBlaster.util.queue with parameters of type I_QueueEntry

java.util.List<I_Entry>	BlockingQueueWrapper.blockingPeekLowest(int numOfEntries, long timeout, I_QueueEntry limitEntry)
private java.util.List<I_Entry>	BlockingQueueWrapper.blockingQueueOperation(int numOfEntries, long timeout, int minPrio, int maxPrio, I_QueueEntry limitEntry, BlockingQueueWrapper.I_BlockingQueueCb cb) Blocks until at least numOfEntries are found in the queue, or the timeout has occured.
java.util.List<I_Entry>	BlockingQueueWrapper.blockingTakeLowest(int numOfEntries, long timeout, I_QueueEntry limitEntry)
int	I_QueueEntry.compare(I_QueueEntry m2) Needed for sorting in queue
boolean	I_QueueEntry.equals(I_QueueEntry m2) Needed for sorting in queue
java.util.List<I_Entry>	I_Queue.peekLowest(int numOfEntries, long numOfBytes, I_QueueEntry limitEntry, boolean leaveOne) Same as takeLowest but it does not remove the entries.
java.util.List<I_Entry>	I_Queue.peekStartAt(int numOfEntries, long numOfBytes, I_QueueEntry firstEntryExlusive) Returns maximum the first num element in the queue but does not remove it from that queue (leaves it untouched).
java.util.List<I_Entry>	I_Queue.peekWithLimitEntry(I_QueueEntry limitEntry) Deprecated. you should use directly removeWithLimitEntry
void	I_Queue.put(I_QueueEntry[] queueEntries, boolean ignorePutInterceptor) Puts one queue entry on top of the queue.
void	I_Queue.put(I_QueueEntry queueEntry, boolean ignorePutInterceptor) Puts one queue entry on top of the queue.
void	I_QueuePutListener.putPost(I_QueueEntry queueEntry) Called by I_Queue implementation before leaving put() and somebody has registered for such events.
void	I_QueuePutListener.putPost(I_QueueEntry[] queueEntries) Called by I_Queue implementation before leaving put() and somebody has registered for such events.
boolean	I_QueuePutListener.putPre(I_QueueEntry queueEntry) Called by I_Queue implementation when a put() is invoked and somebody has registered for such events
boolean	I_QueuePutListener.putPre(I_QueueEntry[] queueEntries) Called by I_Queue implementation when a put() is invoked and somebody has registered for such events
java.util.List<I_Entry>	BlockingQueueWrapper.I_BlockingQueueCb.queueOperation(I_Queue queue, int numEntries, long numBytes, int minPrio, int maxPrio, I_QueueEntry limitEntry)
long	I_Queue.removeHead(I_QueueEntry toEntry) removes the head of the queue until (but not included) the entry specified as the argument.
long	I_Queue.removeWithLimitEntry(I_QueueEntry limitEntry, boolean inclusive) It removes the entries which are higher than the entry specified in the argument list.
java.util.List<I_Entry>	I_Queue.takeLowest(int numOfEntries, long numOfBytes, I_QueueEntry limitEntry, boolean leaveOne) Takes entries from the back of the queue.

Uses of I_QueueEntry in org.xmlBlaster.util.queue.cache

Methods in org.xmlBlaster.util.queue.cache that return I_QueueEntry

I_QueueEntry

CacheQueueInterceptorPlugin.peek()

Methods in org.xmlBlaster.util.queue.cache with parameters of type I_QueueEntry

java.util.List<I_Entry>	CacheQueueInterceptorPlugin.peekLowest(int numOfEntries, long numOfBytes, I_QueueEntry limitEntry, boolean leaveOne) Aware: peekLowest is not implemented!!
java.util.List<I_Entry>	CacheQueueInterceptorPlugin.peekStartAt(int numOfEntries, long numOfBytes, I_QueueEntry firstEntryExlusive)
java.util.List<I_Entry>	CacheQueueInterceptorPlugin.peekWithLimitEntry(I_QueueEntry limitEntry) Deprecated.
void	CacheQueueInterceptorPlugin.put(I_QueueEntry[] queueEntries, boolean ignorePutInterceptor) All entries are stored into the transient queue.
void	CacheQueueInterceptorPlugin.put(I_QueueEntry queueEntry, boolean ignorePutInterceptor)
long	CacheQueueInterceptorPlugin.removeHead(I_QueueEntry toEntry)
long	CacheQueueInterceptorPlugin.removeWithLimitEntry(I_QueueEntry limitEntry, boolean inclusive)
java.util.List<I_Entry>	CacheQueueInterceptorPlugin.takeLowest(int numOfEntries, long numOfBytes, I_QueueEntry limitEntry, boolean leaveOne) Aware: takeLowest for more than one entry is not implemented!!
int	CacheQueueInterceptorPlugin.update(I_QueueEntry queueEntry) Updates the given message queue entry with a new value.

Uses of I_QueueEntry in org.xmlBlaster.util.queue.jdbc

Methods in org.xmlBlaster.util.queue.jdbc that return I_QueueEntry

I_QueueEntry	JdbcQueue.peek()
I_QueueEntry	JdbcQueueCommonTablePlugin.peek()
I_QueueEntry	JdbcQueue.take() Currently not supported by I_Queue.
I_QueueEntry	JdbcQueueCommonTablePlugin.take() Currently not supported by I_Queue.

Methods in org.xmlBlaster.util.queue.jdbc with parameters of type I_QueueEntry

java.util.List<XBRef>	XBRefFactory.getFirstRefEntriesStartAt(XBStore store, java.sql.Connection conn, long numOfEntries, long numOfBytes, int timeout, I_QueueEntry firstEntryExlusive)
java.util.List<I_Entry>	XBDatabaseAccessorDelegate.getRefEntries(XBStore store, int numOfEntries, long numOfBytes, I_EntryFilter entryFilter, I_Storage storage, I_QueueEntry firstEntryExlusive)
java.util.List<I_Entry>	XBDatabaseAccessor.getRefEntries(XBStore store, int numOfEntries, long numOfBytes, I_EntryFilter entryFilter, I_Storage storage, I_QueueEntry firstEntryExlusive)
java.util.ArrayList	JdbcQueue.peekLowest(int numEntries, long numBytes, I_QueueEntry limitEntry, boolean leaveOne)
java.util.ArrayList	JdbcQueueCommonTablePlugin.peekLowest(int numOfEntries, long numOfBytes, I_QueueEntry limitEntry, boolean leaveOne)
java.util.ArrayList	JdbcQueue.peekStartAt(int numOfEntries, long numOfBytes, I_QueueEntry firstEntryExlusive)
java.util.ArrayList	JdbcQueueCommonTablePlugin.peekStartAt(int numOfEntries, long numOfBytes, I_QueueEntry firstEntryExlusive)
java.util.ArrayList	JdbcQueue.peekWithLimitEntry(I_QueueEntry limitEntry) Deprecated.
java.util.ArrayList	JdbcQueueCommonTablePlugin.peekWithLimitEntry(I_QueueEntry limitEntry) Deprecated.
void	JdbcQueue.put(I_QueueEntry[] queueEntries, boolean ignorePutInterceptor)
void	JdbcQueueCommonTablePlugin.put(I_QueueEntry[] queueEntries, boolean ignorePutInterceptor)
void	JdbcQueue.put(I_QueueEntry queueEntry, boolean ignorePutInterceptor)
void	JdbcQueueCommonTablePlugin.put(I_QueueEntry queueEntry, boolean ignorePutInterceptor)
long	JdbcQueue.removeHead(I_QueueEntry toEntry)
long	JdbcQueueCommonTablePlugin.removeHead(I_QueueEntry toEntry)
long	JdbcQueue.removeWithLimitEntry(I_QueueEntry limitEntry, boolean inclusive)
long	JdbcQueueCommonTablePlugin.removeWithLimitEntry(I_QueueEntry limitEntry, boolean inclusive)
java.util.ArrayList	JdbcQueue.takeLowest(int numEntries, long numBytes, I_QueueEntry limitEntry, boolean leaveOne)
java.util.ArrayList	JdbcQueueCommonTablePlugin.takeLowest(int numOfEntries, long numOfBytes, I_QueueEntry limitEntry, boolean leaveOne)
int	JdbcQueue.update(I_QueueEntry queueEntry) Updates the given message queue entry with a new value.
int	JdbcQueueCommonTablePlugin.update(I_QueueEntry queueEntry) Updates the given message queue entry with a new value.

Uses of I_QueueEntry in org.xmlBlaster.util.queue.ram

Methods in org.xmlBlaster.util.queue.ram that return I_QueueEntry

I_QueueEntry	RamQueuePlugin.peek()
I_QueueEntry	RamQueuePlugin.take() Currently NOT supported by I_Queue.

Methods in org.xmlBlaster.util.queue.ram with parameters of type I_QueueEntry

java.util.ArrayList	RamQueuePlugin.peekLowest(int numOfEntries, long numOfBytes, I_QueueEntry limitEntry, boolean leaveOne)
java.util.ArrayList	RamQueuePlugin.peekStartAt(int numOfEntries, long numOfBytes, I_QueueEntry firstEntryExlusive)
java.util.ArrayList	RamQueuePlugin.peekWithLimitEntry(I_QueueEntry limitEntry) Deprecated.
void	RamQueuePlugin.put(I_QueueEntry[] msgArr, boolean ignorePutInterceptor) Put messages into the queue, blocks if take thread blocks synchronize
void	RamQueuePlugin.put(I_QueueEntry entry, boolean ignorePutInterceptor) Put a message into the queue, blocks if take thread blocks synchronize
long	RamQueuePlugin.removeHead(I_QueueEntry toEntry)
long	RamQueuePlugin.removeWithLimitEntry(I_QueueEntry limitEntry, boolean inclusive)
java.util.ArrayList	RamQueuePlugin.takeLowest(int numOfEntries, long numOfBytes, I_QueueEntry limitEntry, boolean leaveOne)
private java.util.ArrayList	RamQueuePlugin.takeOrPeekLowest(int numOfEntries, long numOfBytes, I_QueueEntry limitEntry, boolean leaveOne, boolean doDelete)

Uses of I_QueueEntry in org.xmlBlaster.util.queuemsg

Classes in org.xmlBlaster.util.queuemsg that implement I_QueueEntry

class	DummyEntry
class	MsgQueueEntry Base class to enter xmlBlaster method invocations (messages) into an ordered queue.

Methods in org.xmlBlaster.util.queuemsg with parameters of type I_QueueEntry

int	MsgQueueEntry.compare(I_QueueEntry m2) Needed for sorting the queue.
boolean	MsgQueueEntry.equals(I_QueueEntry m2) Needed for sorting in queue