|
xmlBlaster 2.2.0 API | |||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of XBStore in org.xmlBlaster.client.queuemsg |
---|
Methods in org.xmlBlaster.client.queuemsg with parameters of type XBStore | |
---|---|
I_Entry |
ClientEntryFactory.createEntry(XBStore store,
XBMeat meat,
XBRef ref)
|
private StorageId |
ClientEntryFactory.getStorageId(XBStore store)
|
Uses of XBStore in org.xmlBlaster.contrib.dbupdate |
---|
Fields in org.xmlBlaster.contrib.dbupdate with type parameters of type XBStore | |
---|---|
private java.util.Map<java.lang.String,XBStore> |
OneToThree.xbStoreMap
|
Methods in org.xmlBlaster.contrib.dbupdate that return XBStore | |
---|---|
XBStore |
OneToThree.getXBStore(XBDatabaseAccessor accessor,
Global glob,
StorageId oldStorageId)
|
Uses of XBStore in org.xmlBlaster.engine.queuemsg |
---|
Methods in org.xmlBlaster.engine.queuemsg with parameters of type XBStore | |
---|---|
I_Entry |
ServerEntryFactory.createEntry(XBStore store,
XBMeat meat,
XBRef ref)
|
private StorageId |
ServerEntryFactory.getStorageId(XBStore store)
|
Uses of XBStore in org.xmlBlaster.test.classtest.queue |
---|
Methods in org.xmlBlaster.test.classtest.queue that return XBStore | |
---|---|
private XBStore |
DesignQueues2008InitialTest.createSimpleStore(long id,
java.lang.String node,
java.lang.String storeType,
java.lang.String storePostfix)
|
Uses of XBStore in org.xmlBlaster.util.queue |
---|
Fields in org.xmlBlaster.util.queue declared as XBStore | |
---|---|
private XBStore |
StorageId.xbStore
|
Methods in org.xmlBlaster.util.queue that return XBStore | |
---|---|
XBStore |
StorageId.getXBStore()
returns an XBStore without having filled the id nor the flag1 member variables. |
Methods in org.xmlBlaster.util.queue with parameters of type XBStore | |
---|---|
I_Entry |
I_EntryFactory.createEntry(XBStore store,
XBMeat meat,
XBRef ref)
Added for 2008 Queues |
Uses of XBStore in org.xmlBlaster.util.queue.jdbc |
---|
Fields in org.xmlBlaster.util.queue.jdbc declared as XBStore | |
---|---|
private XBStore |
JdbcQueue.xbStore
|
Methods in org.xmlBlaster.util.queue.jdbc that return XBStore | |
---|---|
XBStore |
XBStoreFactory.get(long id,
java.sql.Connection conn,
int timeout)
|
XBStore |
XBStoreFactory.getByName(java.lang.String node,
java.lang.String type,
java.lang.String postfix,
java.sql.Connection conn,
int timeout)
|
XBStore |
XBDatabaseAccessor.getXBStore(StorageId uniqueQueueId)
|
Methods in org.xmlBlaster.util.queue.jdbc that return types with arguments of type XBStore | |
---|---|
java.util.List<XBStore> |
XBDatabaseAccessor.getAllOfType(java.lang.String node,
java.lang.String type)
|
java.util.List<XBStore> |
XBStoreFactory.getAllOfType(java.lang.String node,
java.lang.String type,
java.sql.Connection conn,
int timeout)
|
Methods in org.xmlBlaster.util.queue.jdbc with parameters of type XBStore | |
---|---|
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 |
private int[] |
XBDatabaseAccessor.addEntriesSingleMode(java.sql.Connection conn,
XBStore store,
I_Entry[] entries)
|
boolean |
XBDatabaseAccessorDelegate.addEntry(XBStore store,
I_Entry entry)
|
boolean |
XBDatabaseAccessor.addEntry(XBStore store,
I_Entry entry)
Adds a row to the specified queue table |
private boolean |
XBDatabaseAccessor.addSingleEntry(XBStore store,
I_Entry entry,
java.sql.Connection conn)
Adds a row to the specified queue table |
protected boolean |
XBFactory.checkSameStore(XBStore store,
XBEntry entry)
|
int |
XBDatabaseAccessorDelegate.cleanUp(XBStore store)
|
int |
XBDatabaseAccessor.cleanUp(XBStore store)
Cleans up the specified queue. |
long |
XBDatabaseAccessorDelegate.clearQueue(XBStore store)
|
long |
XBDatabaseAccessor.clearQueue(XBStore store)
|
long |
XBFactory.count(XBStore store,
java.sql.Connection conn,
int timeout)
Deletes the specified entries. |
private java.util.List<I_Entry> |
XBDatabaseAccessor.createEntries(XBStore store,
java.util.List<XBMeat> meatList,
java.util.List<XBRef> refList,
I_EntryFilter filter,
I_Storage storage)
|
private I_Entry |
XBDatabaseAccessor.createEntry(XBStore store,
XBMeat meat,
XBRef ref)
|
int |
XBRefFactory.deleteAllStore(XBStore store,
java.sql.Connection conn,
int timeout)
|
long |
XBDatabaseAccessorDelegate.deleteAllTransient(XBStore store)
|
long |
XBDatabaseAccessor.deleteAllTransient(XBStore store)
deletes all transient messages |
private long |
XBDatabaseAccessor.deleteEntries(java.sql.Connection conn,
XBStore store,
XBRef[] refs,
XBMeat[] meats)
|
int |
XBDatabaseAccessorDelegate.deleteEntries(XBStore store,
long refId,
long meatId)
|
long |
XBDatabaseAccessorDelegate.deleteEntries(XBStore store,
XBRef[] refs,
XBMeat[] meats)
|
long |
XBDatabaseAccessor.deleteEntries(XBStore store,
XBRef[] refs,
XBMeat[] meats)
Deletes the entries specified by the entries array. |
int |
XBDatabaseAccessor.deleteEntry(XBStore store,
long refId,
long meatId)
Deletes the entry specified |
long |
XBDatabaseAccessorDelegate.deleteFirstRefs(XBStore store,
long numOfEntries)
|
long |
XBDatabaseAccessor.deleteFirstRefs(XBStore store,
long numOfEntries)
Deletes number of entries specified by the argument list. |
long |
XBRefFactory.deleteList(XBStore store,
java.sql.Connection conn,
XBEntry[] entries,
int maxStLength,
int maxNumSt,
boolean commitInBetween,
int timeout)
Deletes the specified entries. |
long |
XBFactory.deleteList(XBStore store,
java.sql.Connection conn,
XBEntry[] entries,
int maxStLength,
int maxNumSt,
boolean commitInBetween,
int timeout)
Deletes the specified entries. |
long |
XBRefFactory.deleteWithLimit(XBStore store,
java.sql.Connection conn,
XBRef limitEntry,
boolean inclusive)
deletes the first numOfEntries of the queue until the limitEntry is reached. |
XBRef |
XBRefFactory.get(XBStore store,
long id,
java.sql.Connection conn,
int timeout)
|
XBMeat |
XBMeatFactory.get(XBStore store,
long id,
java.sql.Connection conn,
int timeout)
|
(package private) ReturnDataHolder |
XBRefFactory.getAndDeleteLowest(XBStore store,
java.sql.Connection conn,
int numOfEntries,
long numOfBytes,
int maxPriority,
long minUniqueId,
boolean leaveOne,
boolean doDelete,
int maxStLength,
int maxNumSt,
int timeout)
Under the same transaction it gets and deletes all the entries which fit into the constrains specified in the argument list. |
ReturnDataHolder |
XBDatabaseAccessorDelegate.getAndDeleteLowest(XBStore store,
int numOfEntries,
long numOfBytes,
int maxPriority,
long minUniqueId,
boolean leaveOne,
boolean doDelete,
I_Storage storage)
|
ReturnDataHolder |
XBDatabaseAccessor.getAndDeleteLowest(XBStore store,
int numOfEntries,
long numOfBytes,
int maxPriority,
long minUniqueId,
boolean leaveOne,
boolean doDelete,
I_Storage storage)
Under the same transaction it gets and deletes all the entries which fit into the constrains specified in the argument list. |
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<XBRef> |
XBRefFactory.getEntriesByPriority(XBStore store,
java.sql.Connection conn,
int numOfEntries,
long numOfBytes,
int minPrio,
int maxPrio,
boolean onlyId)
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.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<XBRef> |
XBRefFactory.getEntriesBySamePriority(XBStore store,
java.sql.Connection conn,
int numOfEntries,
long numOfBytes)
gets the first numOfEntries of the queue which have the same priority. |
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<XBMeat> |
XBMeatFactory.getFirstMeatEntries(XBStore store,
java.sql.Connection conn,
long numOfEntries,
long numOfBytes,
int timeout)
|
java.util.List<XBRef> |
XBRefFactory.getFirstRefEntries(XBStore store,
java.sql.Connection conn,
long numOfEntries,
long numOfBytes,
int timeout)
|
java.util.List<XBRef> |
XBRefFactory.getFirstRefEntriesStartAt(XBStore store,
java.sql.Connection conn,
long numOfEntries,
long numOfBytes,
int timeout,
I_QueueEntry firstEntryExlusive)
|
java.util.List<XBEntry> |
XBFactory.getList(XBStore store,
java.sql.Connection conn,
XBEntry[] entries,
int maxStLength,
int maxNumSt,
int timeout)
Gets the specified entries. |
private java.util.List<XBMeat> |
XBDatabaseAccessor.getMeatList(XBStore store,
java.sql.Connection conn,
XBMeat[] refs,
int maxStLength,
int maxNumSt,
int timeout)
|
EntryCount |
XBDatabaseAccessorDelegate.getNumOfAll(XBStore store)
|
EntryCount |
XBDatabaseAccessor.getNumOfAll(XBStore store)
Gets the real number of entries. |
EntryCount |
XBFactory.getNumOfAll(XBStore store,
java.sql.Connection conn)
Gets the real number of entries. |
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)
|
private java.util.List<XBRef> |
XBDatabaseAccessor.getRefList(XBStore store,
java.sql.Connection conn,
XBRef[] refs,
int maxStLength,
int maxNumSt,
int timeout)
|
java.util.List<XBRef> |
XBRefFactory.getWithLimit(XBStore store,
java.sql.Connection conn,
XBRef limitRef)
|
void |
XBMeatFactory.incrementRefCounters(XBStore store,
XBMeat meat,
long increment,
java.sql.Connection conn,
int timeout)
|
void |
XBStoreFactory.insert(XBStore xbStore,
java.sql.Connection conn,
int timeout)
Inserts an entry in the database |
long |
XBDatabaseAccessorDelegate.modifyEntry(XBStore store,
XBMeat entry,
XBMeat oldEntry,
boolean onlyRefCounters)
|
long |
XBDatabaseAccessor.modifyEntry(XBStore store,
XBMeat entry,
XBMeat oldEntry,
boolean onlyRefCounters)
modifies a row in the specified queue table |
long |
XBDatabaseAccessorDelegate.removeEntriesWithLimit(XBStore store,
XBRef limitEntry,
boolean inclusive)
|
long |
XBDatabaseAccessor.removeEntriesWithLimit(XBStore store,
XBRef limitEntry,
boolean inclusive)
deletes the first numOfEntries of the queue until the limitEntry is reached. |
private java.util.List<XBRef> |
XBRefFactory.rs2List(XBStore store,
java.sql.ResultSet rs,
long numOfEntries,
long numOfBytes,
boolean onlyId)
|
protected XBRef |
XBRefFactory.rsToEntry(XBStore store,
java.sql.ResultSet rs)
|
protected XBMeat |
XBMeatFactory.rsToEntry(XBStore store,
java.sql.ResultSet rs)
|
protected XBEntry |
XBStoreFactory.rsToEntry(XBStore store,
java.sql.ResultSet rs)
|
protected abstract XBEntry |
XBFactory.rsToEntry(XBStore store,
java.sql.ResultSet rs)
|
void |
XBMeatFactory.updateRefCounters(XBStore store,
XBMeat xbMeat,
java.sql.Connection conn,
int timeout)
Updates the XBMeat object. |
|
xmlBlaster 2.2.0 API | |||||||||
PREV NEXT | FRAMES NO FRAMES |