|
xmlBlaster 1.6.2 API | ||||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||||
| 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) |
| 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.engine |
| Classes in org.xmlBlaster.engine that implement I_Entry | |
class |
MsgUnitWrapper
Wraps a publish() message into an entry for a persistence cache. |
| Uses of I_Entry in org.xmlBlaster.engine.msgstore |
| Subinterfaces of I_Entry in org.xmlBlaster.engine.msgstore | |
interface |
I_MapEntry
|
| Uses of I_Entry in org.xmlBlaster.engine.queuemsg |
| Classes in org.xmlBlaster.engine.queuemsg that implement I_Entry | |
class |
MsgQueueHistoryEntry
Wraps an publish() message into an entry for a sorted queue. |
class |
MsgQueueUpdateEntry
Wraps an publish() message into an entry for a sorted queue. |
class |
ReferenceEntry
Wraps an publish() message into an entry for a sorted queue. |
class |
SessionEntry
SessionEntry |
class |
SubscribeEntry
SubscribeEntry |
class |
TopicEntry
Wraps an publish() message into an entry for a persistence cache. |
| Methods in org.xmlBlaster.engine.queuemsg that return I_Entry | |
I_Entry |
ServerEntryFactory.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) |
| Methods in org.xmlBlaster.engine.queuemsg with parameters of type I_Entry | |
byte[] |
ServerEntryFactory.toBlob(I_Entry entry)
Parses the specified entry to a byte array (serializing). |
| Uses of I_Entry in org.xmlBlaster.util.queue |
| Subinterfaces of I_Entry in org.xmlBlaster.util.queue | |
interface |
I_QueueEntry
|
| Methods in org.xmlBlaster.util.queue that return 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. |
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) |
| 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. |
boolean[] |
I_Queue.removeRandom(I_Entry[] queueEntries)
Removes the given entries. |
int |
I_Queue.removeRandom(I_Entry entry)
Removes the given entry. |
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 with parameters of type I_Entry | |
int |
CacheQueueInterceptorPlugin.removeRandom(I_Entry entry)
|
private boolean[] |
CacheQueueInterceptorPlugin.removePossibleSwappedEntries(boolean[] ret,
I_Entry[] queueEntries)
The given ret array will be updated with the result of the removing from the persistent queue. |
private boolean[] |
CacheQueueInterceptorPlugin.removeRandomNoNotify(I_Entry[] queueEntries)
|
boolean[] |
CacheQueueInterceptorPlugin.removeRandom(I_Entry[] queueEntries)
|
| Uses of I_Entry in org.xmlBlaster.util.queue.jdbc |
| Methods in org.xmlBlaster.util.queue.jdbc with parameters of type I_Entry | |
long |
JdbcManagerCommonTable.modifyEntry(java.lang.String queueName,
I_Entry entry,
I_Entry oldEntry)
modifies a row in the specified queue table |
private boolean |
JdbcManagerCommonTable.addSingleEntry(java.lang.String queueName,
I_Entry entry,
java.sql.Connection conn)
Adds a row to the specified queue table |
boolean |
JdbcManagerCommonTable.addEntry(java.lang.String queueName,
I_Entry entry)
Adds a row to the specified queue table |
private int[] |
JdbcManagerCommonTable.addEntriesSingleMode(java.sql.Connection conn,
java.lang.String queueName,
I_Entry[] entries)
|
int[] |
JdbcManagerCommonTable.addEntries(java.lang.String queueName,
I_Entry[] entries)
Adds several rows to the specified queue table in batch mode to improve performance |
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. |
private boolean |
JdbcQueueCommonTablePlugin.put(I_Entry entry)
Internally used for I_MapEntry and I_QueueEntry |
int |
JdbcQueueCommonTablePlugin.removeRandom(I_Entry entry)
|
boolean[] |
JdbcQueueCommonTablePlugin.removeRandom(I_Entry[] queueEntries)
|
int[] |
JdbcManagerCommonTableDelegate.addEntries(java.lang.String queueName,
I_Entry[] entries)
|
long |
JdbcManagerCommonTableDelegate.modifyEntry(java.lang.String queueName,
I_Entry entry,
I_Entry oldEntry)
|
| 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 1.6.2 API | ||||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||||