|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.command.BaseCommand
org.apache.activemq.command.MessageAck
public class MessageAck
Field Summary | |
---|---|
protected byte |
ackType
|
protected ConsumerId |
consumerId
|
protected String |
consumerKey
|
static byte |
DATA_STRUCTURE_TYPE
|
static byte |
DELIVERED_ACK_TYPE
Used to let the broker know that the message has been delivered to the client. |
protected ActiveMQDestination |
destination
|
protected MessageId |
firstMessageId
|
static byte |
INDIVIDUAL_ACK_TYPE
The ack case where a client wants only an individual message to be discarded. |
protected MessageId |
lastMessageId
|
protected int |
messageCount
|
static byte |
POSION_ACK_TYPE
In case the client want's to explicitly let the broker know that a message was not processed and the message was considered a poison message. |
static byte |
REDELIVERED_ACK_TYPE
In case the client want's to explicitly let the broker know that a message was not processed and it was re-delivered to the consumer but it was not yet considered to be a poison message. |
static byte |
STANDARD_ACK_TYPE
The standard ack case where a client wants the message to be discarded. |
protected TransactionId |
transactionId
|
Fields inherited from class org.apache.activemq.command.BaseCommand |
---|
commandId, responseRequired |
Constructor Summary | |
---|---|
MessageAck()
|
|
MessageAck(MessageDispatch md,
byte ackType,
int messageCount)
|
Method Summary | |
---|---|
void |
copy(MessageAck copy)
|
byte |
getAckType()
|
ConsumerId |
getConsumerId()
|
byte |
getDataStructureType()
|
ActiveMQDestination |
getDestination()
|
MessageId |
getFirstMessageId()
|
MessageId |
getLastMessageId()
|
int |
getMessageCount()
The number of messages being acknowledged in the range. |
TransactionId |
getTransactionId()
|
boolean |
isDeliveredAck()
|
boolean |
isIndividualAck()
|
boolean |
isInTransaction()
|
boolean |
isMessageAck()
|
boolean |
isPoisonAck()
|
boolean |
isRedeliveredAck()
|
boolean |
isStandardAck()
|
void |
setAckType(byte ackType)
|
void |
setConsumerId(ConsumerId consumerId)
|
void |
setDestination(ActiveMQDestination destination)
|
void |
setFirstMessageId(MessageId firstMessageId)
|
void |
setLastMessageId(MessageId lastMessageId)
|
void |
setMessageCount(int messageCount)
|
void |
setMessageID(MessageId messageID)
A helper method to allow a single message ID to be acknowledged |
void |
setTransactionId(TransactionId transactionId)
|
Response |
visit(CommandVisitor visitor)
|
Methods inherited from class org.apache.activemq.command.BaseCommand |
---|
copy, getCommandId, getFrom, getTo, isBrokerInfo, isMarshallAware, isMessage, isMessageDispatch, isMessageDispatchNotification, isResponse, isResponseRequired, isShutdownInfo, isWireFormatInfo, setCommandId, setFrom, setResponseRequired, setTo, toString, toString |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
public static final byte DATA_STRUCTURE_TYPE
public static final byte DELIVERED_ACK_TYPE
public static final byte STANDARD_ACK_TYPE
public static final byte POSION_ACK_TYPE
public static final byte REDELIVERED_ACK_TYPE
public static final byte INDIVIDUAL_ACK_TYPE
protected byte ackType
protected ConsumerId consumerId
protected MessageId firstMessageId
protected MessageId lastMessageId
protected ActiveMQDestination destination
protected TransactionId transactionId
protected int messageCount
protected transient String consumerKey
Constructor Detail |
---|
public MessageAck()
public MessageAck(MessageDispatch md, byte ackType, int messageCount)
Method Detail |
---|
public void copy(MessageAck copy)
public byte getDataStructureType()
public boolean isMessageAck()
isMessageAck
in interface Command
isMessageAck
in class BaseCommand
public boolean isPoisonAck()
public boolean isStandardAck()
public boolean isDeliveredAck()
public boolean isRedeliveredAck()
public boolean isIndividualAck()
public ActiveMQDestination getDestination()
public void setDestination(ActiveMQDestination destination)
public TransactionId getTransactionId()
public void setTransactionId(TransactionId transactionId)
public boolean isInTransaction()
public ConsumerId getConsumerId()
public void setConsumerId(ConsumerId consumerId)
public byte getAckType()
public void setAckType(byte ackType)
public MessageId getFirstMessageId()
public void setFirstMessageId(MessageId firstMessageId)
public MessageId getLastMessageId()
public void setLastMessageId(MessageId lastMessageId)
public int getMessageCount()
public void setMessageCount(int messageCount)
public Response visit(CommandVisitor visitor) throws Exception
Exception
public void setMessageID(MessageId messageID)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |