Tim Fox, Clebert Suconic,
Method Summary |
void |
addQueueBinding(Binding binding)
|
void |
commit(long txID)
|
LargeServerMessage |
createLargeMessage()
|
void |
deleteDuplicateID(long recordID)
|
void |
deleteDuplicateIDTransactional(long txID,
long recordID)
|
void |
deleteMessage(long messageID)
|
void |
deleteMessageTransactional(long txID,
long queueID,
long messageID)
|
void |
deletePageTransactional(long txID,
long recordID)
|
void |
deleteQueueBinding(long queueBindingID)
|
long |
generateUniqueID()
|
long |
getCurrentUniqueID()
|
UUID |
getPersistentID()
|
void |
loadBindingJournal(java.util.List<QueueBindingInfo> queueBindingInfos)
|
void |
loadMessageJournal(PagingManager pagingManager,
ResourceManager resourceManager,
java.util.Map<java.lang.Long,Queue> queues,
java.util.Map<SimpleString,java.util.List<Pair<byte[],java.lang.Long>>> duplicateIDMap)
|
void |
prepare(long txID,
javax.transaction.xa.Xid xid)
|
void |
rollback(long txID)
|
void |
setPersistentID(UUID id)
|
void |
setUniqueIDSequence(long id)
|
void |
storeAcknowledge(long queueID,
long messageID)
|
void |
storeAcknowledgeTransactional(long txID,
long queueID,
long messageID)
|
void |
storeDuplicateID(SimpleString address,
byte[] duplID,
long recordID)
|
void |
storeDuplicateIDTransactional(long txID,
SimpleString address,
byte[] duplID,
long recordID)
|
void |
storeMessage(ServerMessage message)
|
void |
storeMessageTransactional(long txID,
ServerMessage message)
|
void |
storePageTransaction(long txID,
PageTransactionInfo pageTransaction)
|
void |
storeReference(long queueID,
long messageID)
|
void |
storeReferenceTransactional(long txID,
long queueID,
long messageID)
|
void |
updateDeliveryCount(MessageReference ref)
|
void |
updateDuplicateID(SimpleString address,
byte[] duplID,
long recordID)
|
void |
updateDuplicateIDTransactional(long txID,
SimpleString address,
byte[] duplID,
long recordID)
|
void |
updateScheduledDeliveryTime(MessageReference ref)
|
void |
updateScheduledDeliveryTimeTransactional(long txID,
MessageReference ref)
|
getPersistentID
UUID getPersistentID()
setPersistentID
void setPersistentID(UUID id)
throws java.lang.Exception
- Throws:
java.lang.Exception
generateUniqueID
long generateUniqueID()
getCurrentUniqueID
long getCurrentUniqueID()
setUniqueIDSequence
void setUniqueIDSequence(long id)
storeMessage
void storeMessage(ServerMessage message)
throws java.lang.Exception
- Throws:
java.lang.Exception
storeReference
void storeReference(long queueID,
long messageID)
throws java.lang.Exception
- Throws:
java.lang.Exception
deleteMessage
void deleteMessage(long messageID)
throws java.lang.Exception
- Throws:
java.lang.Exception
storeAcknowledge
void storeAcknowledge(long queueID,
long messageID)
throws java.lang.Exception
- Throws:
java.lang.Exception
updateDeliveryCount
void updateDeliveryCount(MessageReference ref)
throws java.lang.Exception
- Throws:
java.lang.Exception
updateScheduledDeliveryTime
void updateScheduledDeliveryTime(MessageReference ref)
throws java.lang.Exception
- Throws:
java.lang.Exception
storeDuplicateID
void storeDuplicateID(SimpleString address,
byte[] duplID,
long recordID)
throws java.lang.Exception
- Throws:
java.lang.Exception
updateDuplicateID
void updateDuplicateID(SimpleString address,
byte[] duplID,
long recordID)
throws java.lang.Exception
- Throws:
java.lang.Exception
deleteDuplicateID
void deleteDuplicateID(long recordID)
throws java.lang.Exception
- Throws:
java.lang.Exception
storeMessageTransactional
void storeMessageTransactional(long txID,
ServerMessage message)
throws java.lang.Exception
- Throws:
java.lang.Exception
storeReferenceTransactional
void storeReferenceTransactional(long txID,
long queueID,
long messageID)
throws java.lang.Exception
- Throws:
java.lang.Exception
storeAcknowledgeTransactional
void storeAcknowledgeTransactional(long txID,
long queueID,
long messageID)
throws java.lang.Exception
- Throws:
java.lang.Exception
updateScheduledDeliveryTimeTransactional
void updateScheduledDeliveryTimeTransactional(long txID,
MessageReference ref)
throws java.lang.Exception
- Throws:
java.lang.Exception
deleteMessageTransactional
void deleteMessageTransactional(long txID,
long queueID,
long messageID)
throws java.lang.Exception
- Throws:
java.lang.Exception
storeDuplicateIDTransactional
void storeDuplicateIDTransactional(long txID,
SimpleString address,
byte[] duplID,
long recordID)
throws java.lang.Exception
- Throws:
java.lang.Exception
updateDuplicateIDTransactional
void updateDuplicateIDTransactional(long txID,
SimpleString address,
byte[] duplID,
long recordID)
throws java.lang.Exception
- Throws:
java.lang.Exception
deleteDuplicateIDTransactional
void deleteDuplicateIDTransactional(long txID,
long recordID)
throws java.lang.Exception
- Throws:
java.lang.Exception
createLargeMessage
LargeServerMessage createLargeMessage()
prepare
void prepare(long txID,
javax.transaction.xa.Xid xid)
throws java.lang.Exception
- Throws:
java.lang.Exception
commit
void commit(long txID)
throws java.lang.Exception
- Throws:
java.lang.Exception
rollback
void rollback(long txID)
throws java.lang.Exception
- Throws:
java.lang.Exception
storePageTransaction
void storePageTransaction(long txID,
PageTransactionInfo pageTransaction)
throws java.lang.Exception
- Throws:
java.lang.Exception
deletePageTransactional
void deletePageTransactional(long txID,
long recordID)
throws java.lang.Exception
- Throws:
java.lang.Exception
loadMessageJournal
void loadMessageJournal(PagingManager pagingManager,
ResourceManager resourceManager,
java.util.Map<java.lang.Long,Queue> queues,
java.util.Map<SimpleString,java.util.List<Pair<byte[],java.lang.Long>>> duplicateIDMap)
throws java.lang.Exception
- Throws:
java.lang.Exception
addQueueBinding
void addQueueBinding(Binding binding)
throws java.lang.Exception
- Throws:
java.lang.Exception
deleteQueueBinding
void deleteQueueBinding(long queueBindingID)
throws java.lang.Exception
- Throws:
java.lang.Exception
loadBindingJournal
void loadBindingJournal(java.util.List<QueueBindingInfo> queueBindingInfos)
throws java.lang.Exception
- Throws:
java.lang.Exception
Copyright © 2006 JBoss Inc. All Rights Reserved.