Home » activemq-parent-5.3.1-source-release » org.apache » activemq » command » [javadoc | source]
public class: MessagePull [javadoc | source]

All Implemented Interfaces:

Used to pull messages on demand.
Field Summary
public static final  byte DATA_STRUCTURE_TYPE     
protected  ConsumerId consumerId     
protected  ActiveMQDestination destination     
protected  long timeout     
Fields inherited from org.apache.activemq.command.BaseCommand:
commandId,  responseRequired
Method from org.apache.activemq.command.MessagePull Summary:
configure,   getConsumerId,   getCorrelationId,   getDataStructureType,   getDestination,   getMessageId,   getTimeout,   setConsumerId,   setCorrelationId,   setDestination,   setMessageId,   setTimeout,   visit
Methods from org.apache.activemq.command.BaseCommand:
copy,   getCommandId,   getFrom,   getTo,   isBrokerInfo,   isMarshallAware,   isMessage,   isMessageAck,   isMessageDispatch,   isMessageDispatchNotification,   isResponse,   isResponseRequired,   isShutdownInfo,   isWireFormatInfo,   setCommandId,   setFrom,   setResponseRequired,   setTo,   toString,   toString
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.command.MessagePull Detail:
 public  void configure(ConsumerInfo info) 
    Configures a message pull from the consumer information
 public ConsumerId getConsumerId() 
 public String getCorrelationId() 
    An optional correlation ID which could be used by a broker to decide which messages are pulled on demand from a queue for a consumer
 public byte getDataStructureType() 
 public ActiveMQDestination getDestination() 
 public MessageId getMessageId() 
    An optional message ID which could be used by a broker to decide which messages are pulled on demand from a queue for a consumer
 public long getTimeout() 
 public  void setConsumerId(ConsumerId consumerId) 
 public  void setCorrelationId(String correlationId) 
 public  void setDestination(ActiveMQDestination destination) 
 public  void setMessageId(MessageId messageId) 
 public  void setTimeout(long timeout) 
 public Response visit(CommandVisitor visitor) throws Exception