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 and 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 and Description
ProducerAck()
ProducerAck(ProducerId producerId, int size)

Method Summary

Modifier and Type	Method and 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

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)