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