org.apache.activemq.artemis.core.paging.cursor

Interface PagedReference

All Superinterfaces:

MessageReference

All Known Implementing Classes:

PagedReferenceImpl

public interface PagedReference
extends MessageReference

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.activemq.artemis.core.server.MessageReference

MessageReference.Factory

Method Summary

Modifier and Type	Method and Description
void	addPendingFlag() this method affects paging clean up It adds to the flag that prevents its page from cleanup.
PagedMessage	getPagedMessage()
PagePosition	getPosition()
long	getTransactionID()
boolean	isLargeMessage()
void	removePendingFlag() this method affects paging clean up It adds to the flag that prevents its page from cleanup.

Methods inherited from interface org.apache.activemq.artemis.core.server.MessageReference

acknowledge, acknowledge, acknowledge, acknowledge, copy, decrementDeliveryCount, emptyConsumerID, getConsumerId, getDeliveryCount, getLastValueProperty, getMessage, getMessageID, getMessageMemoryEstimate, getPersistedCount, getPersistentSize, getProtocolData, getQueue, getScheduledDeliveryTime, handled, hasConsumerId, incrementDeliveryCount, isAlreadyAcked, isDurable, isPaged, onDelivery, setAlreadyAcked, setConsumerId, setDeliveryCount, setPersistedCount, setProtocolData, setScheduledDeliveryTime

Method Detail

getPosition

PagePosition getPosition()

getPagedMessage

PagedMessage getPagedMessage()

isLargeMessage

boolean isLargeMessage()

getTransactionID

long getTransactionID()

addPendingFlag

void addPendingFlag()

this method affects paging clean up It adds to the flag that prevents its page from cleanup. It's a helper method to call the proper PageSubscription.addPendingDelivery(PagePosition)

See Also:

PageSubscription.addPendingDelivery(PagePosition)

removePendingFlag

void removePendingFlag()

this method affects paging clean up It adds to the flag that prevents its page from cleanup. It's a helper method to call the proper PageSubscription.addPendingDelivery(PagePosition)

See Also:

PageSubscription.addPendingDelivery(PagePosition)