Uses of Class
org.xmlBlaster.util.queue.jdbc.XBStore

Packages that use XBStore

org.xmlBlaster.client.queuemsg
org.xmlBlaster.util.queue
org.xmlBlaster.util.queue.jdbc

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)

Uses of XBStore in org.xmlBlaster.util.queue

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

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
boolean	XBDatabaseAccessorDelegate.addEntry(XBStore store, I_Entry entry)
boolean	XBDatabaseAccessor.addEntry(XBStore store, I_Entry entry) 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.
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
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)
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.
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)
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.
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.