org.apache.activemq.command
Class ProducerInfo
java.lang.Object
org.apache.activemq.command.BaseCommand
org.apache.activemq.command.ProducerInfo
- All Implemented Interfaces:
- Command, DataStructure
public class ProducerInfo
- extends BaseCommand
- Version:
- $Revision: 1.13 $
Methods inherited from class org.apache.activemq.command.BaseCommand |
copy, getCommandId, getFrom, getTo, isBrokerInfo, isMarshallAware, isMessage, isMessageAck, isMessageDispatch, isMessageDispatchNotification, isResponse, isResponseRequired, isShutdownInfo, isWireFormatInfo, setCommandId, setFrom, setResponseRequired, setTo, toString |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
DATA_STRUCTURE_TYPE
public static final byte DATA_STRUCTURE_TYPE
- See Also:
- Constant Field Values
producerId
protected ProducerId producerId
destination
protected ActiveMQDestination destination
brokerPath
protected BrokerId[] brokerPath
dispatchAsync
protected boolean dispatchAsync
ProducerInfo
public ProducerInfo()
ProducerInfo
public ProducerInfo(ProducerId producerId)
ProducerInfo
public ProducerInfo(SessionInfo sessionInfo,
long producerId)
copy
public ProducerInfo copy()
copy
public void copy(ProducerInfo info)
getDataStructureType
public byte getDataStructureType()
- Returns:
- The type of the data structure
getProducerId
public ProducerId getProducerId()
setProducerId
public void setProducerId(ProducerId producerId)
getDestination
public ActiveMQDestination getDestination()
setDestination
public void setDestination(ActiveMQDestination destination)
createRemoveCommand
public RemoveInfo createRemoveCommand()
getBrokerPath
public BrokerId[] getBrokerPath()
- The route of brokers the command has moved through.
setBrokerPath
public void setBrokerPath(BrokerId[] brokerPath)
visit
public Response visit(CommandVisitor visitor)
throws java.lang.Exception
- Throws:
java.lang.Exception
isDispatchAsync
public boolean isDispatchAsync()
- If the broker should dispatch messages from this producer async. Since sync
dispatch could potentally block the producer thread, this could be an important
setting for the producer.
setDispatchAsync
public void setDispatchAsync(boolean dispatchAsync)
Copyright © 2009 Apache Software Foundation. All Rights Reserved.