xmlBlaster 2.2.0 API

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

Packages that use I_Queue
org.xmlBlaster.authentication   
org.xmlBlaster.client This is the Java client side package. 
org.xmlBlaster.client.dispatch   
org.xmlBlaster.contrib.replication   
org.xmlBlaster.engine The core implementation. 
org.xmlBlaster.engine.cluster   
org.xmlBlaster.engine.dispatch   
org.xmlBlaster.protocol.http.ajax   
org.xmlBlaster.test.classtest.queue   
org.xmlBlaster.util Java helper classes for server and client programming. 
org.xmlBlaster.util.dispatch   
org.xmlBlaster.util.dispatch.plugins.prio   
org.xmlBlaster.util.error   
org.xmlBlaster.util.queue   
org.xmlBlaster.util.queue.cache   
org.xmlBlaster.util.queue.jdbc   
org.xmlBlaster.util.queue.ram   
 

Uses of I_Queue in org.xmlBlaster.authentication
 

Fields in org.xmlBlaster.authentication declared as I_Queue
private  I_Queue SessionInfo.sessionQueue
          All MsgUnit which shall be delivered to the current session of the client are queued here to be ready to deliver.
private  I_Queue SubjectInfo.subjectQueue
          All MsgUnit which can't be delivered to the client (if he is not logged in) are queued here and are delivered when the client comes on line.
 

Methods in org.xmlBlaster.authentication that return I_Queue
private  I_Queue SubjectInfo.createSubjectQueue(CbQueueProperty prop)
           
 I_Queue SessionInfo.getSessionQueue()
          This queue holds all messages which where addressed to this session
 I_Queue SubjectInfo.getSubjectQueue()
          This queue holds all messages which where addressed to destination loginName
 

Uses of I_Queue in org.xmlBlaster.client
 

Fields in org.xmlBlaster.client declared as I_Queue
private  I_Queue XmlBlasterAccess.clientQueue
          Client side queue during connection failure
private  I_Queue StreamingCallback.queue
           
 

Methods in org.xmlBlaster.client that return I_Queue
 I_Queue XmlBlasterAccess.getQueue()
          Enforced by interface I_ConnectionHandler
 I_Queue I_ConnectionHandler.getQueue()
           
 

Uses of I_Queue in org.xmlBlaster.client.dispatch
 

Fields in org.xmlBlaster.client.dispatch declared as I_Queue
private  I_Queue ClientDispatchManager.msgQueue
           
 

Methods in org.xmlBlaster.client.dispatch that return I_Queue
 I_Queue ClientDispatchManager.getQueue()
           
 

Methods in org.xmlBlaster.client.dispatch with parameters of type I_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)
           
 

Constructors in org.xmlBlaster.client.dispatch with parameters of type I_Queue
ClientDispatchManager(Global glob, I_MsgErrorHandler failureListener, I_MsgSecurityInterceptor securityInterceptor, I_Queue msgQueue, I_ConnectionStatusListener connectionStatusListener, AddressBase[] addrArr, SessionName sessionName)
           
 

Uses of I_Queue in org.xmlBlaster.contrib.replication
 

Fields in org.xmlBlaster.contrib.replication declared as I_Queue
private  I_Queue ReplSlave.queue
          The queue associated to this slave.
 

Methods in org.xmlBlaster.contrib.replication with parameters of type I_Queue
 java.util.ArrayList I_ReplSlave.check(java.util.List<I_Entry> pushEntries, I_Queue queue)
           
 java.util.ArrayList ReplSlave.check(java.util.List<I_Entry> entries, I_Queue queue)
           
 

Uses of I_Queue in org.xmlBlaster.engine
 

Fields in org.xmlBlaster.engine declared as I_Queue
private  I_Queue TopicHandler.historyQueue
          MsgUnit references are stored in a persistent history queue.
 

Methods in org.xmlBlaster.engine that return I_Queue
 I_Queue TopicHandler.getHistoryQueue()
           
 I_Queue SubscriptionInfo.getMsgQueue()
          My destination queue.
private  I_Queue TopicHandler.initQueue(I_Queue queue, java.lang.String queueName)
          Creates a queue with the properties specified in the historyQueueProperty
 

Methods in org.xmlBlaster.engine with parameters of type I_Queue
 java.lang.String[] RequestBroker.deadMessage(MsgQueueEntry[] entries, I_Queue queue, java.lang.String reason)
          Publish dead letters, expired letters should be filtered away before.
private  I_Queue TopicHandler.initQueue(I_Queue queue, java.lang.String queueName)
          Creates a queue with the properties specified in the historyQueueProperty
 java.lang.String[] ServerScope.peekMessages(I_Queue queue, int numOfEntries, java.lang.String label, boolean forceReadableTimestamp, boolean forceReadableBase64)
           
 java.lang.String[] ServerScope.peekQueueMessagesToFile(I_Queue queue, int numOfEntries, java.lang.String path, java.lang.String label)
          Dumps given amount of messages from queue to file.
 

Uses of I_Queue in org.xmlBlaster.engine.cluster
 

Methods in org.xmlBlaster.engine.cluster that return I_Queue
 I_Queue ClusterNode.getConnectionQueue()
           
 

Uses of I_Queue in org.xmlBlaster.engine.dispatch
 

Fields in org.xmlBlaster.engine.dispatch declared as I_Queue
private  I_Queue ServerDispatchManager.msgQueue
           
 

Methods in org.xmlBlaster.engine.dispatch that return I_Queue
 I_Queue ServerDispatchManager.getQueue()
           
 

Methods in org.xmlBlaster.engine.dispatch with parameters of type I_Queue
static java.util.ArrayList ServerDispatchManager.prepareMsgsFromQueue(java.lang.String logId, java.util.logging.Logger log, I_Queue queue, java.util.List<I_Entry> entryList)
           
 

Constructors in org.xmlBlaster.engine.dispatch with parameters of type I_Queue
ServerDispatchManager(ServerScope glob, I_MsgErrorHandler failureListener, I_MsgSecurityInterceptor securityInterceptor, I_Queue msgQueue, I_ConnectionStatusListener connectionStatusListener, AddressBase[] addrArr, SessionName sessionName)
           
 

Uses of I_Queue in org.xmlBlaster.protocol.http.ajax
 

Fields in org.xmlBlaster.protocol.http.ajax declared as I_Queue
private  I_Queue BlasterInstance.updateQueue
           
 

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

Fields in org.xmlBlaster.test.classtest.queue declared as I_Queue
private  I_Queue I_QueueTest.queue
           
private  I_Queue I_QueueTest.QueuePutter.queue
           
private  I_Queue QueueThread.queue
           
private  I_Queue JdbcQueueTest.queue
           
private  I_Queue QueueServerEntryTest.queue
           
private  I_Queue CacheQueueDisconnectTest.queue
           
private  I_Queue[] QueueThreadingTest.queues
           
private  I_Queue[] QueueExtendedTest.queues
           
private  I_Queue[] CacheQueueTest.queues
           
 

Methods in org.xmlBlaster.test.classtest.queue with parameters of type I_Queue
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.bigEntries(I_Queue queue)
          Test bigEngtries(I_Queue) It tests the insertion and removal of entries which contain a large blob (2.1MB)
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)
private  void I_QueueTest.checkSizeAndEntries(java.lang.String txt, java.util.List<I_Entry> queueEntries, I_Queue queue)
           
private  void I_QueueTest.config(I_Queue queue)
          Tests initialize(), getProperties(), setProperties() and capacity()
private  void I_QueueTest.overflow(I_Queue queue)
          Test overflow(I_Queue) It tests if the overflow mechanism works OK
private  void I_QueueTest.peekMsg(I_Queue queue)
          Tests peek() and peek(int num) and remove() For a discussion of the sorting order see Javadoc of this class
private  void I_QueueTest.peekWithLimitEntry(I_Queue queue)
          Test testPeekWithLimitEntry(I_Queue)
private  void I_QueueTest.publishMsgBigEntry(I_Queue queue)
          Test bigEngtries(I_Queue) It tests the insertion and removal of entries which contain a large blob (2.1MB)
private  void I_QueueTest.putEntriesTwice(I_Queue queue)
          Test wrongOrder(I_Queue)
private  void I_QueueTest.putMsg(I_Queue queue)
          Tests put(MsgQueueEntry[]) and put(MsgQueueEntry) and clear()
 void CacheQueueTest.putPeekRemove(I_Queue refQueue)
           
private  void I_QueueTest.removeRandom(I_Queue queue)
          Test removeRandom(long[])
private  void I_QueueTest.removeWithPriority(I_Queue queue)
          Test removeWithPriority(long[])
private  void I_QueueTest.size1(I_Queue queue)
          Tests put(MsgQueueEntry[]) and put(MsgQueueEntry) and clear()
private  void I_QueueTest.sizesCheck(I_Queue queue)
          Test sizesCheck(I_Queue)
private  void I_QueueTest.takeLowest(I_Queue queue)
          Test takeLowest(I_Queue)
private  void I_QueueTest.wrongOrder(I_Queue queue)
          Test wrongOrder(I_Queue)
 

Constructors in org.xmlBlaster.test.classtest.queue with parameters of type I_Queue
I_QueueTest.QueuePutter(I_Queue queue, long delay, int numOfEntries, boolean ignoreInterceptor)
           
QueueThread(Global glob, java.lang.String name, I_Queue queue, java.util.logging.Logger log, int sweeps, int sizeOfMsg)
           
 

Uses of I_Queue in org.xmlBlaster.util
 

Methods in org.xmlBlaster.util with parameters of type I_Queue
 java.lang.String[] Global.peekQueueMessagesToFile(I_Queue queue, int numOfEntries, java.lang.String path, java.lang.String label)
          Dumps given amount of messages from queue to file.
 

Uses of I_Queue in org.xmlBlaster.util.dispatch
 

Fields in org.xmlBlaster.util.dispatch declared as I_Queue
private  I_Queue DispatchWorker.msgQueue
           
 

Methods in org.xmlBlaster.util.dispatch that return I_Queue
 I_Queue I_DispatchManager.getQueue()
           
 

Uses of I_Queue in org.xmlBlaster.util.dispatch.plugins.prio
 

Fields in org.xmlBlaster.util.dispatch.plugins.prio declared as I_Queue
private  I_Queue DispatchManagerEntry.holdbackQueue
           
 

Methods in org.xmlBlaster.util.dispatch.plugins.prio that return I_Queue
 I_Queue DispatchManagerEntry.getHoldbackQueue()
           
 

Methods in org.xmlBlaster.util.dispatch.plugins.prio with parameters of type I_Queue
 void DispatchManagerEntry.setHoldbackQueue(I_Queue holdbackQueue)
           
 

Uses of I_Queue in org.xmlBlaster.util.error
 

Methods in org.xmlBlaster.util.error that return I_Queue
 I_Queue I_MsgErrorInfo.getQueue()
          Access the queue where the entries are inside.
 I_Queue MsgErrorInfo.getQueue()
          Access the queue where the entries are inside.
 

Uses of I_Queue in org.xmlBlaster.util.queue
 

Fields in org.xmlBlaster.util.queue declared as I_Queue
private  I_Queue BlockingQueueWrapper.queue
           
 

Methods in org.xmlBlaster.util.queue that return I_Queue
 I_Queue QueuePluginManager.getPlugin(PluginInfo pluginInfo, StorageId storageId, QueuePropertyBase props)
           
 I_Queue QueuePluginManager.getPlugin(java.lang.String typeVersion, StorageId storageId, QueuePropertyBase props)
           
 I_Queue QueuePluginManager.getPlugin(java.lang.String type, java.lang.String version, StorageId storageId, QueuePropertyBase props)
          Return a new created (persistent) queue plugin.
 I_Queue BlockingQueueWrapper.getQueue()
           
 

Methods in org.xmlBlaster.util.queue with parameters of type I_Queue
 void BlockingQueueWrapper.init(I_Queue queue_)
           
 java.util.List<I_Entry> BlockingQueueWrapper.I_BlockingQueueCb.queueOperation(I_Queue queue, int numEntries, long numBytes, int minPrio, int maxPrio, I_QueueEntry limitEntry)
           
 

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

Classes in org.xmlBlaster.util.queue.cache that implement I_Queue
 class CacheQueueInterceptorPlugin
          Implements a queue cache.
 

Fields in org.xmlBlaster.util.queue.cache declared as I_Queue
private  I_Queue CacheQueueInterceptorPlugin.persistentQueue
           
private  I_Queue CacheQueueInterceptorPlugin.transientQueue
           
 

Methods in org.xmlBlaster.util.queue.cache that return I_Queue
 I_Queue CacheQueueInterceptorPlugin.getPersistentQueue()
          returns the persistent queue (null if no one defined)
 I_Queue CacheQueueInterceptorPlugin.getTransientQueue()
          returns the transient queue (null if no one defined)
 

Methods in org.xmlBlaster.util.queue.cache with parameters of type I_Queue
private  long CacheQueueInterceptorPlugin.checkEntriesAvailable(I_Queue queue, long valueToCheckAgainst, boolean ifFullThrowException, java.lang.String extraTxt)
           
private  long CacheQueueInterceptorPlugin.checkSpaceAvailable(I_Queue queue, long valueToCheckAgainst, boolean ifFullThrowException, java.lang.String extraTxt)
          Helper method to check the space left on a given queue.
 

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

Classes in org.xmlBlaster.util.queue.jdbc that implement I_Queue
 class JdbcQueue
          Persistence queue implementation on a DB based on JDBC.
 class JdbcQueueCommonTablePlugin
          Persistence queue implementation on a DB based on JDBC.
 

Methods in org.xmlBlaster.util.queue.jdbc with parameters of type I_Queue
 void XBDatabaseAccessor.registerQueue(I_Queue queue)
           
 void CommonTableDatabaseAccessor.registerQueue(I_Queue queue)
           
 void XBDatabaseAccessor.unregisterQueue(I_Queue queue)
           
 void CommonTableDatabaseAccessor.unregisterQueue(I_Queue queue)
           
 

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

Classes in org.xmlBlaster.util.queue.ram that implement I_Queue
 class RamQueuePlugin
          Queueing messages in RAM only, sorted after priority and timestamp
 


xmlBlaster 2.2.0 API

Copyright © 1999-2014 The xmlBlaster.org contributers.