|
xmlBlaster 1.6.2 client API | ||||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||||
| Uses of StorageId in org.xmlBlaster.client.queuemsg |
| Methods in org.xmlBlaster.client.queuemsg with parameters of type StorageId | |
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) |
| Constructors in org.xmlBlaster.client.queuemsg with parameters of type StorageId | |
MsgQueueConnectEntry(Global glob,
StorageId storageId,
ConnectQosData connectQosData)
Use this constructor if a new message object is fed by method connect(). |
|
MsgQueueConnectEntry(Global glob,
PriorityEnum priority,
StorageId storageId,
Timestamp timestamp,
long sizeInBytes,
ConnectQosData connectQosData)
For persistence recovery |
|
MsgQueueDisconnectEntry(Global glob,
StorageId storageId,
DisconnectQos disconnectQos)
Use this constructor if a new message object is fed by method disconnect(). |
|
MsgQueueDisconnectEntry(Global glob,
PriorityEnum priority,
StorageId storageId,
Timestamp timestamp,
long sizeInBytes,
DisconnectQos disconnectQos)
For persistence recovery |
|
MsgQueueSubscribeEntry(Global glob,
StorageId storageId,
QueryKeyData subscribeKeyData,
QueryQosData subscribeQosData)
Use this constructor if a new message object is fed by method subscribe(). |
|
MsgQueueSubscribeEntry(Global glob,
PriorityEnum priority,
StorageId storageId,
Timestamp timestamp,
long sizeInBytes,
QueryKeyData subscribeKeyData,
QueryQosData subscribeQosData)
For persistence recovery |
|
MsgQueueGetEntry(Global glob,
StorageId storageId,
GetKey getKey,
GetQos getQos)
Use this constructor for a get() request. |
|
MsgQueueGetEntry(Global glob,
PriorityEnum priority,
StorageId storageId,
Timestamp timestamp,
long sizeInBytes,
GetKey getKey,
GetQos getQos)
For persistence recovery |
|
MsgQueueUnSubscribeEntry(Global glob,
StorageId storageId,
UnSubscribeKey unSubscribeKey,
UnSubscribeQos unSubscribeQos)
Use this constructor if a new message object is fed by method unSubscribe(). |
|
MsgQueueUnSubscribeEntry(Global glob,
PriorityEnum priority,
StorageId storageId,
Timestamp timestamp,
long sizeInBytes,
UnSubscribeKey unSubscribeKey,
UnSubscribeQos unSubscribeQos)
For persistence recovery |
|
MsgQueueEraseEntry(Global glob,
StorageId storageId,
EraseKey eraseKey,
EraseQos eraseQos)
Use this constructor if a new message object is fed by method erase(). |
|
MsgQueueEraseEntry(Global glob,
PriorityEnum priority,
StorageId storageId,
Timestamp timestamp,
long sizeInBytes,
EraseKey eraseKey,
EraseQos eraseQos)
For persistence recovery |
|
MsgQueuePublishEntry(Global glob,
MsgUnit msgUnit,
StorageId storageId)
Use this constructor if a new message object is fed by method publish() (not oneway). |
|
MsgQueuePublishEntry(Global glob,
MsgUnit msgUnit,
StorageId storageId,
boolean oneway)
|
|
MsgQueuePublishEntry(Global glob,
MethodName entryType,
PriorityEnum priority,
StorageId storageId,
Timestamp publishEntryTimestamp,
long sizeInBytes,
MsgUnit msgUnit)
For persistence recovery |
|
| Uses of StorageId in org.xmlBlaster.util.queue |
| Methods in org.xmlBlaster.util.queue that return StorageId | |
static StorageId |
StorageId.valueOf(java.lang.String strippedStorageId)
Not functional, we have no guaranteed way to find out the real id from the stripped id. |
StorageId |
I_Storage.getStorageId()
Returns the unique ID of this queue. |
| Methods in org.xmlBlaster.util.queue with parameters of type StorageId | |
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 |
QueuePluginManager.getPlugin(PluginInfo pluginInfo,
StorageId storageId,
QueuePropertyBase props)
|
EventHelper |
StorageEventHandler.generateEventHelper(StorageId storageId)
Create an EventHelper instance which matches exactly the givne storageId (no wildcards). |
void |
I_Queue.initialize(StorageId storageId,
java.lang.Object userData)
Is called after the instance is created. |
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) |
void |
I_Entry.added(StorageId storageId)
Notification if this entry is added to storage. |
void |
I_Entry.removed(StorageId storageId)
Notification if this entry is removed from storage |
| Uses of StorageId in org.xmlBlaster.util.queue.cache |
| Methods in org.xmlBlaster.util.queue.cache that return StorageId | |
StorageId |
CacheQueueInterceptorPlugin.getStorageId()
Returns the unique ID of this queue |
| Methods in org.xmlBlaster.util.queue.cache with parameters of type StorageId | |
void |
CacheQueueInterceptorPlugin.initialize(StorageId uniqueQueueId,
java.lang.Object userData)
Is called after the instance is created. |
| Uses of StorageId in org.xmlBlaster.util.queue.jdbc |
| Methods in org.xmlBlaster.util.queue.jdbc that return StorageId | |
StorageId |
JdbcQueue.getStorageId()
Returns the unique ID of this queue |
StorageId |
JdbcQueueCommonTablePlugin.getStorageId()
Returns the unique ID of this queue |
| Methods in org.xmlBlaster.util.queue.jdbc with parameters of type StorageId | |
XBStore |
XBQueueFactory.getXBStore(StorageId uniqueQueueId)
|
ReturnDataHolder |
JdbcManagerCommonTable.getAndDeleteLowest(StorageId storageId,
int numOfEntries,
long numOfBytes,
int maxPriority,
long minUniqueId,
boolean leaveOne,
boolean doDelete)
Under the same transaction it gets and deletes all the entries which fit into the constrains specified in the argument list. |
java.util.ArrayList |
JdbcManagerCommonTable.getEntriesByPriority(StorageId storageId,
int numOfEntries,
long numOfBytes,
int minPrio,
int maxPrio,
I_EntryFilter entryFilter)
gets the first numOfEntries of the queue which have the priority in the range specified by prioMin and prioMax (inclusive). |
java.util.ArrayList |
JdbcManagerCommonTable.getEntriesBySamePriority(StorageId storageId,
int numOfEntries,
long numOfBytes)
gets the first numOfEntries of the queue which have the same priority. |
java.util.ArrayList |
JdbcManagerCommonTable.getEntries(StorageId storageId,
int numOfEntries,
long numOfBytes,
I_EntryFilter entryFilter)
gets the first numOfEntries of the queue. |
java.util.ArrayList |
JdbcManagerCommonTable.getEntriesWithLimit(StorageId storageId,
I_Entry limitEntry)
gets the first numOfEntries of the queue until the limitEntry is reached. |
long |
JdbcManagerCommonTable.removeEntriesWithLimit(StorageId storageId,
I_Entry limitEntry,
boolean inclusive)
deletes the first numOfEntries of the queue until the limitEntry is reached. |
java.util.ArrayList |
JdbcManagerCommonTable.getEntries(StorageId storageId,
long[] dataids)
gets all the entries which have the dataid specified in the argument list. |
void |
JdbcQueue.initialize(StorageId uniqueQueueId,
java.lang.Object userData)
Is called after the instance is created. |
void |
JdbcQueueCommonTablePlugin.initialize(StorageId uniqueQueueId,
java.lang.Object userData)
Is called after the instance is created. |
java.util.ArrayList |
JdbcManagerCommonTableDelegate.getEntries(StorageId storageId,
int numOfEntries,
long numOfBytes,
I_EntryFilter entryFilter)
|
| Uses of StorageId in org.xmlBlaster.util.queue.ram |
| Methods in org.xmlBlaster.util.queue.ram that return StorageId | |
StorageId |
RamQueuePlugin.getStorageId()
For verbose logging |
| Methods in org.xmlBlaster.util.queue.ram with parameters of type StorageId | |
void |
RamQueuePlugin.initialize(StorageId uniqueQueueId,
java.lang.Object userData)
Is called after the instance is created. |
| Uses of StorageId in org.xmlBlaster.util.queuemsg |
| Fields in org.xmlBlaster.util.queuemsg declared as StorageId | |
protected StorageId |
MsgQueueEntry.storageId
The queue to which this entry belongs (set in the constructors) |
| Methods in org.xmlBlaster.util.queuemsg that return StorageId | |
StorageId |
MsgQueueEntry.getStorageId()
To which queue do i belong |
| Methods in org.xmlBlaster.util.queuemsg with parameters of type StorageId | |
void |
MsgQueueEntry.added(StorageId storageId)
Notification if this entry is added to queue |
void |
MsgQueueEntry.removed(StorageId storageId)
Notification if this entry is removed from queue |
| Constructors in org.xmlBlaster.util.queuemsg with parameters of type StorageId | |
DummyEntry(Global glob,
PriorityEnum priority,
Timestamp timestamp,
StorageId storageId,
long sizeOfMsg,
boolean persistent)
This constructor is for internal creation from persistence only (passing the original timestamp). |
|
DummyEntry(Global glob,
PriorityEnum priority,
Timestamp timestamp,
StorageId storageId,
byte[] content,
boolean persistent)
|
|
DummyEntry(Global glob,
PriorityEnum priority,
StorageId storageId,
boolean persistent)
|
|
DummyEntry(Global glob,
PriorityEnum priority,
StorageId storageId,
long sizeOfMsg,
boolean persistent)
|
|
MsgQueueEntry(Global glob,
MethodName methodName,
PriorityEnum priority,
StorageId storageId,
boolean persistent)
|
|
MsgQueueEntry(Global glob,
java.lang.String entryType,
PriorityEnum priority,
StorageId storageId,
boolean persistent)
Creates a new queue entry object. |
|
MsgQueueEntry(Global glob,
java.lang.String entryType,
PriorityEnum priority,
Timestamp timestamp,
StorageId storageId,
boolean persistent)
This constructor is for internal creation from persistence only. |
|
|
xmlBlaster 1.6.2 client API | ||||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||||