|
xmlBlaster 2.2.0 client API | |||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of I_Entry in org.xmlBlaster.client.dispatch |
---|
Method parameters in org.xmlBlaster.client.dispatch with type arguments of type I_Entry | |
---|---|
void |
ClientDispatchManager.handleSyncWorkerException(java.util.List<I_Entry> entryList,
java.lang.Throwable throwable)
Called by DispatchWorker if an Exception occured in sync mode Only on client side |
void |
ClientDispatchManager.handleWorkerException(java.util.List<I_Entry> entryList,
java.lang.Throwable throwable)
Called by DispatchWorker if an Exception occurred in async mode. |
java.util.ArrayList |
ClientDispatchManager.prepareMsgsFromQueue(java.util.List<I_Entry> entryList)
Here we prepare messages which are coming directly from the queue. |
static java.util.ArrayList |
ClientDispatchManager.prepareMsgsFromQueue(java.lang.String logId,
java.util.logging.Logger log,
I_Queue queue,
java.util.List<I_Entry> entryList)
|
Uses of I_Entry in org.xmlBlaster.client.queuemsg |
---|
Classes in org.xmlBlaster.client.queuemsg that implement I_Entry | |
---|---|
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. |
Methods in org.xmlBlaster.client.queuemsg that return I_Entry | |
---|---|
I_Entry |
ClientEntryFactory.createEntry(int priority,
long timestamp,
java.lang.String type,
boolean persistent,
long sizeInBytes,
java.io.InputStream is,
StorageId storageId)
Parses back the raw data to a I_Entry (deserializing) |
I_Entry |
ClientEntryFactory.createEntry(XBStore store,
XBMeat meat,
XBRef ref)
|
Methods in org.xmlBlaster.client.queuemsg with parameters of type I_Entry | |
---|---|
byte[] |
ClientEntryFactory.toBlob(I_Entry entry)
Parses the specified entry to a byte array (serializing). |
Uses of I_Entry in org.xmlBlaster.util.admin |
---|
Methods in org.xmlBlaster.util.admin that return types with arguments of type I_Entry | |
---|---|
java.util.List<I_Entry> |
I_AdminQueue.takeWithPriority(int numOfEntries,
long numOfBytes,
int minPriority,
int maxPriority)
Takes given number of entries out of the queue. |
Uses of I_Entry in org.xmlBlaster.util.dispatch |
---|
Method parameters in org.xmlBlaster.util.dispatch with type arguments of type I_Entry | |
---|---|
void |
I_DispatchManager.handleSyncWorkerException(java.util.List<I_Entry> entryList,
java.lang.Throwable throwable)
Called by DispatchWorker if an Exception occured in sync mode Only on client side |
void |
I_DispatchManager.handleWorkerException(java.util.List<I_Entry> entryList,
java.lang.Throwable throwable)
Called by DispatchWorker if an Exception occurred in async mode. |
java.util.ArrayList |
I_DispatchManager.prepareMsgsFromQueue(java.util.List<I_Entry> entryList)
Here we prepare messages which are coming directly from the queue. |
Uses of I_Entry in org.xmlBlaster.util.dispatch.plugins |
---|
Methods in org.xmlBlaster.util.dispatch.plugins that return types with arguments of type I_Entry | |
---|---|
java.util.List<I_Entry> |
I_MsgDispatchInterceptor.handleNextMessages(I_DispatchManager dispatchManager,
java.util.List<I_Entry> pushEntries)
If you returned true from doActivate() the worker thread will ask us to retrieve the next messages from the queue (dispatchManager.getQueue()). |
Method parameters in org.xmlBlaster.util.dispatch.plugins with type arguments of type I_Entry | |
---|---|
java.util.List<I_Entry> |
I_MsgDispatchInterceptor.handleNextMessages(I_DispatchManager dispatchManager,
java.util.List<I_Entry> pushEntries)
If you returned true from doActivate() the worker thread will ask us to retrieve the next messages from the queue (dispatchManager.getQueue()). |
Uses of I_Entry in org.xmlBlaster.util.dispatch.plugins.prio |
---|
Methods in org.xmlBlaster.util.dispatch.plugins.prio that return types with arguments of type I_Entry | |
---|---|
java.util.List<I_Entry> |
PriorizedDispatchPlugin.handleNextMessages(I_DispatchManager dispatchManager,
java.util.List<I_Entry> entries)
Enforced by I_MsgDispatchInterceptor. |
Method parameters in org.xmlBlaster.util.dispatch.plugins.prio with type arguments of type I_Entry | |
---|---|
java.util.List<I_Entry> |
PriorizedDispatchPlugin.handleNextMessages(I_DispatchManager dispatchManager,
java.util.List<I_Entry> entries)
Enforced by I_MsgDispatchInterceptor. |
Uses of I_Entry in org.xmlBlaster.util.queue |
---|
Subinterfaces of I_Entry in org.xmlBlaster.util.queue | |
---|---|
interface |
I_QueueEntry
|
Fields in org.xmlBlaster.util.queue with type parameters of type I_Entry | |
---|---|
java.util.ArrayList<I_Entry> |
ReturnDataHolder.list
|
Methods in org.xmlBlaster.util.queue that return I_Entry | |
---|---|
I_Entry |
I_EntryFactory.createEntry(int priority,
long timestamp,
java.lang.String type,
boolean persistent,
long sizeInBytes,
java.io.InputStream is,
StorageId storageId)
Parses back the raw data to a I_Entry (deserializing) |
I_Entry |
I_EntryFactory.createEntry(XBStore store,
XBMeat meat,
XBRef ref)
Added for 2008 Queues |
I_Entry |
I_EntryFilter.intercept(I_Entry entry,
I_Storage storage)
Invoked by the I_Map or I_Queue implementation when entries are read from the store. |
Methods in org.xmlBlaster.util.queue that return types with arguments of type I_Entry | |
---|---|
java.util.List<I_Entry> |
BlockingQueueWrapper.blockingPeek(int numOfEntries,
long timeout)
|
java.util.List<I_Entry> |
BlockingQueueWrapper.blockingPeekLowest(int numOfEntries,
long timeout,
I_QueueEntry limitEntry)
|
java.util.List<I_Entry> |
BlockingQueueWrapper.blockingPeekSamePriority(int numOfEntries,
long timeout)
|
java.util.List<I_Entry> |
BlockingQueueWrapper.blockingPeekWithPriority(int numOfEntries,
long timeout,
int minPrio,
int maxPrio)
|
java.util.List<I_Entry> |
BlockingQueueWrapper.blockingTakeLowest(int numOfEntries,
long timeout,
I_QueueEntry limitEntry)
|
java.util.List<I_Entry> |
BlockingQueueWrapper.blockingTakeWithPriority(int numOfEntries,
long timeout,
int minPrio,
int maxPrio)
|
java.util.List<I_Entry> |
I_Queue.getEntries(I_EntryFilter entryFilter)
Gets a copy of the entries (e.g the messages) in the queue. |
java.util.List<I_Entry> |
I_Queue.peek(int numOfEntries,
long numOfBytes)
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.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.peekSamePriority(int numOfEntries,
long numOfBytes)
Returns maximum the first num element in the queue of highest priority but does not remove it from that queue (leaves it untouched). |
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 |
java.util.List<I_Entry> |
I_Queue.peekWithPriority(int numOfEntries,
long numOfBytes,
int minPriority,
int maxPriority)
Returns maximum given number of entries from the queue (none blocking). |
java.util.List<I_Entry> |
BlockingQueueWrapper.I_BlockingQueueCb.queueOperation(I_Queue queue,
int numEntries,
long numBytes,
int minPrio,
int maxPrio,
I_QueueEntry limitEntry)
|
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. |
java.util.List<I_Entry> |
I_Queue.takeWithPriority(int numOfEntries,
long numOfBytes,
int minPriority,
int maxPriority)
Takes given number of entries out of the queue. |
Methods in org.xmlBlaster.util.queue with parameters of type I_Entry | |
---|---|
I_Entry |
I_EntryFilter.intercept(I_Entry entry,
I_Storage storage)
Invoked by the I_Map or I_Queue implementation when entries are read from the store. |
int |
I_Queue.removeRandom(I_Entry entry)
Removes the given entry. |
boolean[] |
I_Queue.removeRandom(I_Entry[] queueEntries)
Removes the given entries. |
byte[] |
I_EntryFactory.toBlob(I_Entry entry)
Parses the specified entry to a byte array (serializing). |
Uses of I_Entry in org.xmlBlaster.util.queue.cache |
---|
Methods in org.xmlBlaster.util.queue.cache that return types with arguments of type I_Entry | |
---|---|
java.util.List<I_Entry> |
CacheQueueInterceptorPlugin.getEntries(I_EntryFilter entryFilter)
|
java.util.List<I_Entry> |
CacheQueueInterceptorPlugin.peek(int numOfEntries,
long numOfBytes)
|
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.peekSamePriority(int numOfEntries,
long numOfBytes)
|
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. |
java.util.List<I_Entry> |
CacheQueueInterceptorPlugin.peekWithPriority(int numOfEntries,
long numOfBytes,
int minPriority,
int maxPriority)
|
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!! |
java.util.List<I_Entry> |
CacheQueueInterceptorPlugin.takeWithPriority(int numOfEntries,
long numOfBytes,
int minPriority,
int maxPriority)
|
Methods in org.xmlBlaster.util.queue.cache with parameters of type I_Entry | |
---|---|
int |
CacheQueueInterceptorPlugin.removeRandom(I_Entry entry)
|
boolean[] |
CacheQueueInterceptorPlugin.removeRandom(I_Entry[] queueEntries)
|
Uses of I_Entry in org.xmlBlaster.util.queue.jdbc |
---|
Methods in org.xmlBlaster.util.queue.jdbc that return types with arguments of type I_Entry | |
---|---|
java.util.List<I_Entry> |
XBDatabaseAccessorDelegate.getEntries(XBStore store,
int numOfEntries,
long numOfBytes,
I_EntryFilter entryFilter,
boolean isRef,
I_Storage storage)
|
java.util.List<I_Entry> |
XBDatabaseAccessor.getEntries(XBStore store,
int numOfEntries,
long numOfBytes,
I_EntryFilter entryFilter,
boolean isRef,
I_Storage storage)
gets the first numOfEntries of the queue. |
java.util.List<I_Entry> |
XBDatabaseAccessorDelegate.getEntries(XBStore store,
XBRef[] refs,
XBMeat[] meats)
|
java.util.List<I_Entry> |
XBDatabaseAccessor.getEntries(XBStore store,
XBRef[] refs,
XBMeat[] meats)
gets all the entries which have the dataid specified in the argument list. |
java.util.List<I_Entry> |
XBDatabaseAccessorDelegate.getEntriesByPriority(XBStore store,
int numOfEntries,
long numOfBytes,
int minPrio,
int maxPrio)
|
java.util.List<I_Entry> |
XBDatabaseAccessor.getEntriesByPriority(XBStore store,
int numOfEntries,
long numOfBytes,
int minPrio,
int maxPrio)
gets the first numOfEntries of the queue which have the priority in the range specified by prioMin and prioMax (inclusive). |
java.util.List<I_Entry> |
XBDatabaseAccessorDelegate.getEntriesBySamePriority(XBStore store,
int numOfEntries,
long numOfBytes)
|
java.util.List<I_Entry> |
XBDatabaseAccessor.getEntriesBySamePriority(XBStore store,
int numOfEntries,
long numOfBytes)
gets the first numOfEntries of the queue which have the same priority. |
java.util.List<I_Entry> |
XBDatabaseAccessorDelegate.getEntriesWithLimit(XBStore store,
I_Entry limitEntry,
I_Storage storage)
|
java.util.List<I_Entry> |
XBDatabaseAccessor.getEntriesWithLimit(XBStore store,
I_Entry limitEntry,
I_Storage storage)
gets the first numOfEntries of the queue until the limitEntry is reached. |
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)
|
Methods in org.xmlBlaster.util.queue.jdbc with parameters of type I_Entry | |
---|---|
int[] |
CommonTableDatabaseAccessor.addEntries(java.lang.String queueName,
I_Entry[] entries)
Adds several rows to the specified queue table in batch mode to improve performance |
int[] |
CommonTableDatabaseAccessorDelegate.addEntries(java.lang.String queueName,
I_Entry[] entries)
|
int[] |
XBDatabaseAccessorDelegate.addEntries(XBStore store,
I_Entry[] entries)
|
int[] |
XBDatabaseAccessor.addEntries(XBStore store,
I_Entry[] entries)
Adds several rows to the specified queue table in batch mode to improve performance |
boolean |
CommonTableDatabaseAccessor.addEntry(java.lang.String queueName,
I_Entry entry)
Adds a row to the specified queue table |
boolean |
XBDatabaseAccessorDelegate.addEntry(XBStore store,
I_Entry entry)
|
boolean |
XBDatabaseAccessor.addEntry(XBStore store,
I_Entry entry)
Adds a row to the specified queue table |
java.util.ArrayList |
CommonTableDatabaseAccessor.getEntriesWithLimit(StorageId storageId,
I_Entry limitEntry)
gets the first numOfEntries of the queue until the limitEntry is reached. |
java.util.List<I_Entry> |
XBDatabaseAccessorDelegate.getEntriesWithLimit(XBStore store,
I_Entry limitEntry,
I_Storage storage)
|
java.util.List<I_Entry> |
XBDatabaseAccessor.getEntriesWithLimit(XBStore store,
I_Entry limitEntry,
I_Storage storage)
gets the first numOfEntries of the queue until the limitEntry is reached. |
long |
CommonTableDatabaseAccessor.modifyEntry(java.lang.String queueName,
I_Entry entry,
I_Entry oldEntry)
modifies a row in the specified queue table |
long |
CommonTableDatabaseAccessorDelegate.modifyEntry(java.lang.String queueName,
I_Entry entry,
I_Entry oldEntry)
|
long |
CommonTableDatabaseAccessor.removeEntriesWithLimit(StorageId storageId,
I_Entry limitEntry,
boolean inclusive)
deletes the first numOfEntries of the queue until the limitEntry is reached. |
int |
JdbcQueue.removeRandom(I_Entry entry)
|
int |
JdbcQueueCommonTablePlugin.removeRandom(I_Entry entry)
|
boolean[] |
JdbcQueue.removeRandom(I_Entry[] queueEntries)
|
boolean[] |
JdbcQueueCommonTablePlugin.removeRandom(I_Entry[] queueEntries)
|
Uses of I_Entry in org.xmlBlaster.util.queue.ram |
---|
Methods in org.xmlBlaster.util.queue.ram with parameters of type I_Entry | |
---|---|
int |
RamQueuePlugin.removeRandom(I_Entry entry)
|
boolean[] |
RamQueuePlugin.removeRandom(I_Entry[] queueEntries)
|
Uses of I_Entry in org.xmlBlaster.util.queuemsg |
---|
Classes in org.xmlBlaster.util.queuemsg that implement I_Entry | |
---|---|
class |
DummyEntry
|
class |
MsgQueueEntry
Base class to enter xmlBlaster method invocations (messages) into an ordered queue. |
|
xmlBlaster 2.2.0 client API | |||||||||
PREV NEXT | FRAMES NO FRAMES |