Package 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.
-
-
Field Summary
Fields Modifier and Type Field Description static byte
DATA_STRUCTURE_TYPE
protected ProducerId
producerId
protected int
size
-
Fields inherited from class org.apache.activemq.command.BaseCommand
commandId, responseRequired
-
-
Constructor Summary
Constructors Constructor Description ProducerAck()
ProducerAck(ProducerId producerId, int size)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
copy(ProducerAck copy)
byte
getDataStructureType()
ProducerId
getProducerId()
The producer id that this ack message is destined for.int
getSize()
The number of bytes that are being acked.void
setProducerId(ProducerId producerId)
void
setSize(int size)
Response
visit(CommandVisitor visitor)
-
Methods inherited from class org.apache.activemq.command.BaseCommand
copy, getCommandId, getFrom, getTo, isBrokerInfo, isConnectionControl, isConsumerControl, isMarshallAware, isMessage, isMessageAck, isMessageDispatch, isMessageDispatchNotification, isResponse, isResponseRequired, isShutdownInfo, isWireFormatInfo, setCommandId, setFrom, setResponseRequired, setTo, toString, toString
-
-
-
-
Field Detail
-
DATA_STRUCTURE_TYPE
public static final byte DATA_STRUCTURE_TYPE
- See Also:
- Constant Field Values
-
producerId
protected ProducerId producerId
-
size
protected int size
-
-
Constructor Detail
-
ProducerAck
public ProducerAck()
-
ProducerAck
public ProducerAck(ProducerId producerId, int size)
-
-
Method Detail
-
copy
public void copy(ProducerAck copy)
-
getDataStructureType
public byte getDataStructureType()
- Returns:
- The type of the data structure
-
visit
public Response visit(CommandVisitor visitor) throws Exception
- Throws:
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)
-
-