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

Class MessageReferenceImpl

java.lang.Object

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

All Implemented Interfaces:

MessageReference

public class MessageReferenceImpl
extends Object
implements MessageReference

Implementation of a MessageReference

Constructor Summary

Constructors

Modifier	Constructor and Description
	MessageReferenceImpl()
	MessageReferenceImpl(MessageReferenceImpl other, Queue queue)
protected	MessageReferenceImpl(ServerMessage message, Queue queue)

Method Summary

Modifier and Type	Method and Description
void	acknowledge()
void	acknowledge(Transaction tx)
void	acknowledge(Transaction tx, AckReason reason)
MessageReference	copy(Queue queue)
void	decrementDeliveryCount()
boolean	equals(Object other)
Long	getConsumerId()
int	getDeliveryCount()
static int	getMemoryEstimate()
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.
int	getPersistedCount()
Object	getProtocolData() To be used on holding protocol specific data during the delivery.
Queue	getQueue()
long	getScheduledDeliveryTime()
void	handled()
int	hashCode()
void	incrementDeliveryCount()
boolean	isAlreadyAcked()
boolean	isPaged()
void	setAlreadyAcked()
void	setConsumerId(Long consumerID)
void	setDeliveryCount(int deliveryCount)
void	setPersistedCount(int persistedCount)
void	setProtocolData(Object protocolData) To be used on holding protocol specific data during the delivery.
void	setScheduledDeliveryTime(long scheduledDeliveryTime)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

MessageReferenceImpl

public MessageReferenceImpl()

MessageReferenceImpl

public MessageReferenceImpl(MessageReferenceImpl other,
                            Queue queue)

MessageReferenceImpl

protected MessageReferenceImpl(ServerMessage message,
                               Queue queue)

Method Detail

getProtocolData

public Object getProtocolData()

Description copied from interface: MessageReference

To be used on holding protocol specific data during the delivery. This will be only valid while the message is on the delivering queue at the consumer

Specified by:

getProtocolData in interface MessageReference

setProtocolData

public void setProtocolData(Object protocolData)

Description copied from interface: MessageReference

To be used on holding protocol specific data during the delivery. This will be only valid while the message is on the delivering queue at the consumer

Specified by:

setProtocolData in interface MessageReference

getPersistedCount

public int getPersistedCount()

Specified by:

getPersistedCount in interface MessageReference

Returns:

the persistedCount

setPersistedCount

public void setPersistedCount(int persistedCount)

Specified by:

setPersistedCount in interface MessageReference

Parameters:

persistedCount - the persistedCount to set

copy

public MessageReference copy(Queue queue)

Specified by:

copy in interface MessageReference

getMemoryEstimate

public static int getMemoryEstimate()

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

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

getMessage

public ServerMessage getMessage()

Specified by:

getMessage in interface MessageReference

getQueue

public Queue getQueue()

Specified by:

getQueue in interface MessageReference

handled

public void handled()

Specified by:

handled in interface MessageReference

setAlreadyAcked

public void setAlreadyAcked()

Specified by:

setAlreadyAcked in interface MessageReference

isAlreadyAcked

public boolean isAlreadyAcked()

Specified by:

isAlreadyAcked in interface MessageReference

isPaged

public boolean isPaged()

Specified by:

isPaged 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

acknowledge

public void acknowledge(Transaction tx,
                        AckReason reason)
                 throws Exception

Specified by:

acknowledge in interface MessageReference

Throws:

Exception

setConsumerId

public void setConsumerId(Long consumerID)

Specified by:

setConsumerId in interface MessageReference

getConsumerId

public Long getConsumerId()

Specified by:

getConsumerId 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:

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object other)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object