org.apache.activemq.command
Class ProducerInfo

java.lang.Object
  extended by org.apache.activemq.command.BaseCommand
      extended by org.apache.activemq.command.ProducerInfo
All Implemented Interfaces:
Command, DataStructure

public class ProducerInfo
extends BaseCommand


Field Summary
protected  BrokerId[] brokerPath
           
static byte DATA_STRUCTURE_TYPE
           
protected  ActiveMQDestination destination
           
protected  boolean dispatchAsync
           
protected  ProducerId producerId
           
protected  int windowSize
           
 
Fields inherited from class org.apache.activemq.command.BaseCommand
commandId, responseRequired
 
Constructor Summary
ProducerInfo()
           
ProducerInfo(ProducerId producerId)
           
ProducerInfo(SessionInfo sessionInfo, long producerId)
           
 
Method Summary
 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()
           
 int getWindowSize()
          Used to configure the producer window size.
 boolean isDispatchAsync()
          If the broker should dispatch messages from this producer async.
 void setBrokerPath(BrokerId[] brokerPath)
           
 void setDestination(ActiveMQDestination destination)
           
 void setDispatchAsync(boolean dispatchAsync)
           
 void setProducerId(ProducerId producerId)
           
 void setWindowSize(int windowSize)
           
 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

destination

protected ActiveMQDestination destination

brokerPath

protected BrokerId[] brokerPath

dispatchAsync

protected boolean dispatchAsync

windowSize

protected int windowSize
Constructor Detail

ProducerInfo

public ProducerInfo()

ProducerInfo

public ProducerInfo(ProducerId producerId)

ProducerInfo

public ProducerInfo(SessionInfo sessionInfo,
                    long producerId)
Method Detail

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 Exception
Throws:
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)

getWindowSize

public int getWindowSize()
Used to configure the producer window size. A producer will send up to the configured window size worth of payload data to the broker before waiting for an Ack that allows him to send more.


setWindowSize

public void setWindowSize(int windowSize)


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.