org.hornetq.core.paging.cursor

Class PagedReferenceImpl

java.lang.Object

org.hornetq.core.paging.cursor.PagedReferenceImpl

All Implemented Interfaces:

PagedReference, MessageReference

public class PagedReferenceImpl
extends Object
implements PagedReference

A InternalReference

Author:

clebert

Constructor Summary

Constructors

Constructor and Description
PagedReferenceImpl(PagePosition position, PagedMessage message, PageSubscription subscription)

Method Summary

Methods

Modifier and Type	Method and Description
void	acknowledge()
void	acknowledge(Transaction tx)
MessageReference	copy(Queue queue)
void	decrementDeliveryCount()
int	getDeliveryCount()
ServerMessage	getMessage()
int	getMessageMemoryEstimate() We define this method aggregation here because on paging we need to hold the original estimate, so we need to perform some extra steps on paging.
PagedMessage	getPagedMessage()
int	getPersistedCount()
PagePosition	getPosition()
Queue	getQueue()
long	getScheduledDeliveryTime()
void	handled()
void	incrementDeliveryCount()
boolean	isPaged()
void	setDeliveryCount(int deliveryCount)
void	setPersistedCount(int count)
void	setScheduledDeliveryTime(long scheduledDeliveryTime)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

PagedReferenceImpl

public PagedReferenceImpl(PagePosition position,
                  PagedMessage message,
                  PageSubscription subscription)

Method Detail

getMessage

public ServerMessage getMessage()

Specified by:

getMessage in interface MessageReference

getPagedMessage

public PagedMessage getPagedMessage()

Specified by:

getPagedMessage in interface PagedReference

getPosition

public PagePosition getPosition()

Specified by:

getPosition in interface PagedReference

isPaged

public boolean isPaged()

Specified by:

isPaged in interface MessageReference

setPersistedCount

public void setPersistedCount(int count)

Specified by:

setPersistedCount in interface MessageReference

getPersistedCount

public int getPersistedCount()

Specified by:

getPersistedCount in interface MessageReference

getMessageMemoryEstimate

public int getMessageMemoryEstimate()

Description copied from interface: MessageReference

We define this method aggregation here because on paging we need to hold the original estimate, so we need to perform some extra steps on paging.

Specified by:

getMessageMemoryEstimate in interface MessageReference

Returns:

copy

public MessageReference copy(Queue queue)

Specified by:

copy in interface MessageReference

getScheduledDeliveryTime

public long getScheduledDeliveryTime()

Specified by:

getScheduledDeliveryTime in interface MessageReference

Returns:

The time in the future that delivery will be delayed until, or zero if no scheduled delivery will occur

setScheduledDeliveryTime

public void setScheduledDeliveryTime(long scheduledDeliveryTime)

Specified by:

setScheduledDeliveryTime in interface MessageReference

getDeliveryCount

public int getDeliveryCount()

Specified by:

getDeliveryCount in interface MessageReference

setDeliveryCount

public void setDeliveryCount(int deliveryCount)

Specified by:

setDeliveryCount in interface MessageReference

incrementDeliveryCount

public void incrementDeliveryCount()

Specified by:

incrementDeliveryCount in interface MessageReference

decrementDeliveryCount

public void decrementDeliveryCount()

Specified by:

decrementDeliveryCount in interface MessageReference

getQueue

public Queue getQueue()

Specified by:

getQueue in interface MessageReference

handled

public void handled()

Specified by:

handled in interface MessageReference

acknowledge

public void acknowledge()
                 throws Exception

Specified by:

acknowledge in interface MessageReference

Throws:

Exception

acknowledge

public void acknowledge(Transaction tx)
                 throws Exception

Specified by:

acknowledge in interface MessageReference

Throws:

Exception

toString

public String toString()

Overrides:

toString in class Object