public class ProducerInfo extends BaseCommand
Modifier and Type | Field and Description |
---|---|
protected BrokerId[] |
brokerPath |
static byte |
DATA_STRUCTURE_TYPE |
protected ActiveMQDestination |
destination |
protected boolean |
dispatchAsync |
protected ProducerId |
producerId |
protected AtomicLong |
sentCount |
protected int |
windowSize |
commandId, responseRequired
Constructor and Description |
---|
ProducerInfo() |
ProducerInfo(ProducerId producerId) |
ProducerInfo(SessionInfo sessionInfo,
long producerId) |
Modifier and Type | Method and Description |
---|---|
ProducerInfo |
copy() |
void |
copy(ProducerInfo info) |
RemoveInfo |
createRemoveCommand() |
BrokerId[] |
getBrokerPath()
The route of brokers the command has moved through.
|
byte |
getDataStructureType() |
ActiveMQDestination |
getDestination() |
ProducerId |
getProducerId() |
long |
getSentCount() |
int |
getWindowSize()
Used to configure the producer window size.
|
void |
incrementSentCount() |
boolean |
isDispatchAsync()
If the broker should dispatch messages from this producer async.
|
void |
resetSentCount() |
void |
setBrokerPath(BrokerId[] brokerPath) |
void |
setDestination(ActiveMQDestination destination) |
void |
setDispatchAsync(boolean dispatchAsync) |
void |
setProducerId(ProducerId producerId) |
void |
setWindowSize(int windowSize) |
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 ActiveMQDestination destination
protected BrokerId[] brokerPath
protected boolean dispatchAsync
protected int windowSize
protected AtomicLong sentCount
public ProducerInfo()
public ProducerInfo(ProducerId producerId)
public ProducerInfo(SessionInfo sessionInfo, long producerId)
public ProducerInfo copy()
public void copy(ProducerInfo info)
public byte getDataStructureType()
public ProducerId getProducerId()
public void setProducerId(ProducerId producerId)
public ActiveMQDestination getDestination()
public void setDestination(ActiveMQDestination destination)
public RemoveInfo createRemoveCommand()
public BrokerId[] getBrokerPath()
public void setBrokerPath(BrokerId[] brokerPath)
public Response visit(CommandVisitor visitor) throws Exception
Exception
public boolean isDispatchAsync()
public void setDispatchAsync(boolean dispatchAsync)
public int getWindowSize()
public void setWindowSize(int windowSize)
public long getSentCount()
public void incrementSentCount()
public void resetSentCount()
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.