public class RefsOperation extends TransactionOperationAbstract
Modifier and Type | Field and Description |
---|---|
protected boolean |
ignoreRedeliveryCheck
It will ignore redelivery check, which is used during consumer.close
to not perform reschedule redelivery check
|
Constructor and Description |
---|
RefsOperation(Queue queue,
StorageManager storageManager) |
Modifier and Type | Method and Description |
---|---|
void |
afterCommit(Transaction tx)
After commit shouldn't throw any exception.
|
void |
afterRollback(Transaction tx)
After rollback shouldn't throw any exception.
|
List<MessageReference> |
getListOnConsumer(long consumerID) |
List<MessageReference> |
getReferencesToAcknowledge() |
List<MessageReference> |
getRelatedMessageReferences() |
protected void |
rollbackRedelivery(Transaction tx,
MessageReference ref,
long timeBase,
Map<QueueImpl,LinkedList<MessageReference>> queueMap) |
void |
setIgnoreRedeliveryCheck() |
afterPrepare, beforeCommit, beforePrepare, beforeRollback
protected boolean ignoreRedeliveryCheck
public RefsOperation(Queue queue, StorageManager storageManager)
public void setIgnoreRedeliveryCheck()
public void afterRollback(Transaction tx)
TransactionOperationAbstract
Any verification has to be done on before rollback
afterRollback
in interface TransactionOperation
afterRollback
in class TransactionOperationAbstract
protected void rollbackRedelivery(Transaction tx, MessageReference ref, long timeBase, Map<QueueImpl,LinkedList<MessageReference>> queueMap) throws Exception
Exception
public void afterCommit(Transaction tx)
TransactionOperationAbstract
Any verification has to be done on before commit
afterCommit
in interface TransactionOperation
afterCommit
in class TransactionOperationAbstract
public List<MessageReference> getRelatedMessageReferences()
getRelatedMessageReferences
in interface TransactionOperation
getRelatedMessageReferences
in class TransactionOperationAbstract
public List<MessageReference> getListOnConsumer(long consumerID)
getListOnConsumer
in interface TransactionOperation
getListOnConsumer
in class TransactionOperationAbstract
public List<MessageReference> getReferencesToAcknowledge()
Copyright © 2018 JBoss by Red Hat. All rights reserved.