public class ConsumerControl extends BaseCommand
Modifier and Type | Field and Description |
---|---|
protected boolean |
close |
protected ConsumerId |
consumerId |
static byte |
DATA_STRUCTURE_TYPE |
protected ActiveMQDestination |
destination |
protected boolean |
flush |
protected int |
prefetch |
protected boolean |
start |
protected boolean |
stop |
commandId, responseRequired
Constructor and Description |
---|
ConsumerControl() |
Modifier and Type | Method and Description |
---|---|
ConsumerId |
getConsumerId() |
byte |
getDataStructureType() |
ActiveMQDestination |
getDestination() |
int |
getPrefetch() |
boolean |
isClose() |
boolean |
isFlush() |
boolean |
isStart() |
boolean |
isStop() |
void |
setClose(boolean close) |
void |
setConsumerId(ConsumerId consumerId) |
void |
setDestination(ActiveMQDestination destination) |
void |
setFlush(boolean flush) |
void |
setPrefetch(int prefetch) |
void |
setStart(boolean start) |
void |
setStop(boolean stop) |
Response |
visit(CommandVisitor visitor) |
copy, getCommandId, getFrom, getTo, isBrokerInfo, isConnectionControl, isMarshallAware, isMessage, isMessageAck, isMessageDispatch, isMessageDispatchNotification, isResponse, isResponseRequired, isShutdownInfo, isWireFormatInfo, setCommandId, setFrom, setResponseRequired, setTo, toString, toString
public static final byte DATA_STRUCTURE_TYPE
protected ConsumerId consumerId
protected boolean close
protected boolean stop
protected boolean start
protected boolean flush
protected int prefetch
protected ActiveMQDestination destination
public ActiveMQDestination getDestination()
public void setDestination(ActiveMQDestination destination)
public byte getDataStructureType()
public Response visit(CommandVisitor visitor) throws Exception
Exception
public boolean isClose()
public void setClose(boolean close)
close
- The close to set.public ConsumerId getConsumerId()
public void setConsumerId(ConsumerId consumerId)
consumerId
- The consumerId to set.public int getPrefetch()
public void setPrefetch(int prefetch)
prefetch
- The prefetch to set.public boolean isFlush()
public void setFlush(boolean flush)
flush
- the flush to setpublic boolean isStart()
public void setStart(boolean start)
start
- the start to setpublic boolean isStop()
public void setStop(boolean stop)
stop
- the stop to setCopyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.