|
xmlBlaster 2.2.0 client API | |||||||||
PREV NEXT | FRAMES NO FRAMES |
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.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)
|
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)
|
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 |
|
xmlBlaster 2.2.0 client API | |||||||||
PREV NEXT | FRAMES NO FRAMES |