org.apache.activemq.command
Class ProducerAck
java.lang.Object
org.apache.activemq.command.BaseCommand
org.apache.activemq.command.ProducerAck
- All Implemented Interfaces:
- Command, DataStructure
public class ProducerAck
- extends BaseCommand
A ProducerAck command is sent by a broker to a producer to let it know it has
received and processed messages that it has produced. The producer will be
flow controlled if it does not receive ProducerAck commands back from the
broker.
Methods inherited from class org.apache.activemq.command.BaseCommand |
copy, getCommandId, getFrom, getTo, isBrokerInfo, isConnectionControl, isMarshallAware, isMessage, isMessageAck, 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 |
DATA_STRUCTURE_TYPE
public static final byte DATA_STRUCTURE_TYPE
- See Also:
- Constant Field Values
producerId
protected ProducerId producerId
size
protected int size
ProducerAck
public ProducerAck()
ProducerAck
public ProducerAck(ProducerId producerId,
int size)
copy
public void copy(ProducerAck copy)
getDataStructureType
public byte getDataStructureType()
- Returns:
- The type of the data structure
visit
public Response visit(CommandVisitor visitor)
throws java.lang.Exception
- Throws:
java.lang.Exception
getProducerId
public ProducerId getProducerId()
- The producer id that this ack message is destined for.
setProducerId
public void setProducerId(ProducerId producerId)
getSize
public int getSize()
- The number of bytes that are being acked.
setSize
public void setSize(int size)
Copyright © 2005-2012. All Rights Reserved.