org.apache.activemq.command
Class ProducerAck

java.lang.Object
  extended by org.apache.activemq.command.BaseCommand
      extended by 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
static byte DATA_STRUCTURE_TYPE
           
protected  ProducerId producerId
           
protected  int size
           
 
Fields inherited from class org.apache.activemq.command.BaseCommand
commandId, responseRequired
 
Constructor Summary
ProducerAck()
           
ProducerAck(ProducerId producerId, int size)
           
 
Method Summary
 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, 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
 

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)


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.