xmlBlaster 2.2.0 client API

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

Packages that use I_Entry
org.xmlBlaster.client.dispatch   
org.xmlBlaster.client.queuemsg   
org.xmlBlaster.util.admin   
org.xmlBlaster.util.dispatch   
org.xmlBlaster.util.dispatch.plugins   
org.xmlBlaster.util.dispatch.plugins.prio   
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_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

Copyright © 1999-2014 The xmlBlaster.org contributers.