Class RefsOperation
java.lang.Object
org.apache.activemq.artemis.core.transaction.TransactionOperationAbstract
org.apache.activemq.artemis.core.server.impl.RefsOperation
- All Implemented Interfaces:
TransactionOperation
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected booleanIt will ignore redelivery check, which is used during consumer.close to not perform reschedule redelivery check -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidAfter commit shouldn't throw any exception.voidAfter rollback shouldn't throw any exception.getListOnConsumer(long consumerID) booleanprotected voidrollbackRedelivery(Transaction tx, MessageReference ref, long timeBase, Map<QueueImpl, LinkedList<MessageReference>> queueMap) setDelivering(boolean delivering) voidvoidsetLingerSession(String lingerSessionId) Methods inherited from class org.apache.activemq.artemis.core.transaction.TransactionOperationAbstract
afterCommit, afterPrepare, beforeCommit, beforePrepare, beforeRollback
-
Field Details
-
ignoreRedeliveryCheck
protected boolean ignoreRedeliveryCheckIt will ignore redelivery check, which is used during consumer.close to not perform reschedule redelivery check
-
-
Constructor Details
-
RefsOperation
-
-
Method Details
-
setDelivering
-
isDelivering
public boolean isDelivering() -
setIgnoreRedeliveryCheck
public void setIgnoreRedeliveryCheck() -
afterRollback
Description copied from class:TransactionOperationAbstractAfter rollback shouldn't throw any exception.Any verification has to be done on before rollback
- Specified by:
afterRollbackin interfaceTransactionOperation- Overrides:
afterRollbackin classTransactionOperationAbstract
-
rollbackRedelivery
protected void rollbackRedelivery(Transaction tx, MessageReference ref, long timeBase, Map<QueueImpl, LinkedList<MessageReference>> queueMap) throws Exception- Throws:
Exception
-
afterCommit
Description copied from class:TransactionOperationAbstractAfter commit shouldn't throw any exception.Any verification has to be done on before commit
- Specified by:
afterCommitin interfaceTransactionOperation- Overrides:
afterCommitin classTransactionOperationAbstract
-
getRelatedMessageReferences
- Specified by:
getRelatedMessageReferencesin interfaceTransactionOperation- Overrides:
getRelatedMessageReferencesin classTransactionOperationAbstract
-
getListOnConsumer
- Specified by:
getListOnConsumerin interfaceTransactionOperation- Overrides:
getListOnConsumerin classTransactionOperationAbstract
-
getReferencesToAcknowledge
-
getLingerMessages
-
setLingerSession
-