org.apache.activemq.artemis.core.server.impl

Class RefsOperation

java.lang.Object

org.apache.activemq.artemis.core.transaction.TransactionOperationAbstract

org.apache.activemq.artemis.core.server.impl.RefsOperation

All Implemented Interfaces:

TransactionOperation

public class RefsOperation
extends TransactionOperationAbstract

Field Summary

Fields

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 Summary

Constructors

Constructor and Description
RefsOperation(Queue queue, AckReason reason, StorageManager storageManager)

Method Summary

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.
void	afterRollback(Transaction tx, boolean sorted)
List<MessageReference>	getLingerMessages()
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()
void	setLingerSession(String lingerSessionId)

Methods inherited from class org.apache.activemq.artemis.core.transaction.TransactionOperationAbstract

afterPrepare, beforeCommit, beforePrepare, beforeRollback

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

ignoreRedeliveryCheck

protected boolean ignoreRedeliveryCheck

It will ignore redelivery check, which is used during consumer.close to not perform reschedule redelivery check

Constructor Detail

RefsOperation

public RefsOperation(Queue queue,
                     AckReason reason,
                     StorageManager storageManager)

Method Detail

setIgnoreRedeliveryCheck

public void setIgnoreRedeliveryCheck()

afterRollback

public void afterRollback(Transaction tx)

Description copied from class: TransactionOperationAbstract

After rollback shouldn't throw any exception.

Any verification has to be done on before rollback

Specified by:

afterRollback in interface TransactionOperation

Overrides:

afterRollback in class TransactionOperationAbstract

afterRollback

public void afterRollback(Transaction tx,
                          boolean sorted)

rollbackRedelivery

protected void rollbackRedelivery(Transaction tx,
                                  MessageReference ref,
                                  long timeBase,
                                  Map<QueueImpl,LinkedList<MessageReference>> queueMap)
                           throws Exception

Throws:

Exception

afterCommit

public void afterCommit(Transaction tx)

Description copied from class: TransactionOperationAbstract

After commit shouldn't throw any exception.

Any verification has to be done on before commit

Specified by:

afterCommit in interface TransactionOperation

Overrides:

afterCommit in class TransactionOperationAbstract

getRelatedMessageReferences

public List<MessageReference> getRelatedMessageReferences()

Specified by:

getRelatedMessageReferences in interface TransactionOperation

Overrides:

getRelatedMessageReferences in class TransactionOperationAbstract

getListOnConsumer

public List<MessageReference> getListOnConsumer(long consumerID)

Specified by:

getListOnConsumer in interface TransactionOperation

Overrides:

getListOnConsumer in class TransactionOperationAbstract

getReferencesToAcknowledge

public List<MessageReference> getReferencesToAcknowledge()

getLingerMessages

public List<MessageReference> getLingerMessages()

setLingerSession

public void setLingerSession(String lingerSessionId)