public class ProducerAck extends BaseCommand
Modifier and Type | Field and Description |
---|---|
static byte |
DATA_STRUCTURE_TYPE |
protected ProducerId |
producerId |
protected int |
size |
commandId, responseRequired
Constructor and Description |
---|
ProducerAck() |
ProducerAck(ProducerId producerId,
int size) |
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) |
copy, getCommandId, getFrom, getTo, isBrokerInfo, isConnectionControl, isConsumerControl, isMarshallAware, isMessage, isMessageAck, isMessageDispatch, isMessageDispatchNotification, isResponse, isResponseRequired, isShutdownInfo, isWireFormatInfo, setCommandId, setFrom, setResponseRequired, setTo, toString, toString
public static final byte DATA_STRUCTURE_TYPE
protected ProducerId producerId
protected int size
public ProducerAck()
public ProducerAck(ProducerId producerId, int size)
public void copy(ProducerAck copy)
public byte getDataStructureType()
public Response visit(CommandVisitor visitor) throws Exception
Exception
public ProducerId getProducerId()
public void setProducerId(ProducerId producerId)
public int getSize()
public void setSize(int size)
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.