Package org.apache.activemq.command
Class ConnectionControl
- java.lang.Object
-
- org.apache.activemq.command.BaseCommand
-
- org.apache.activemq.command.ConnectionControl
-
- All Implemented Interfaces:
Command
,DataStructure
public class ConnectionControl extends BaseCommand
Used to start and stop transports as well as terminating clients.
-
-
Field Summary
Fields Modifier and Type Field Description protected boolean
close
protected String
connectedBrokers
static byte
DATA_STRUCTURE_TYPE
protected boolean
exit
protected boolean
faultTolerant
protected boolean
rebalanceConnection
protected String
reconnectTo
protected boolean
resume
protected boolean
suspend
protected byte[]
token
-
Fields inherited from class org.apache.activemq.command.BaseCommand
commandId, responseRequired
-
-
Constructor Summary
Constructors Constructor Description ConnectionControl()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description String
getConnectedBrokers()
byte
getDataStructureType()
String
getReconnectTo()
byte[]
getToken()
boolean
isClose()
boolean
isConnectionControl()
boolean
isExit()
boolean
isFaultTolerant()
boolean
isRebalanceConnection()
boolean
isResume()
boolean
isSuspend()
void
setClose(boolean close)
void
setConnectedBrokers(String connectedBrokers)
void
setExit(boolean exit)
void
setFaultTolerant(boolean faultTolerant)
void
setRebalanceConnection(boolean rebalanceConnection)
void
setReconnectTo(String reconnectTo)
void
setResume(boolean resume)
void
setSuspend(boolean suspend)
void
setToken(byte[] token)
Response
visit(CommandVisitor visitor)
-
Methods inherited from class org.apache.activemq.command.BaseCommand
copy, getCommandId, getFrom, getTo, isBrokerInfo, isConsumerControl, isMarshallAware, isMessage, isMessageAck, isMessageDispatch, isMessageDispatchNotification, isResponse, isResponseRequired, isShutdownInfo, isWireFormatInfo, setCommandId, setFrom, setResponseRequired, setTo, toString, toString
-
-
-
-
Field Detail
-
DATA_STRUCTURE_TYPE
public static final byte DATA_STRUCTURE_TYPE
- See Also:
- Constant Field Values
-
suspend
protected boolean suspend
-
resume
protected boolean resume
-
close
protected boolean close
-
exit
protected boolean exit
-
faultTolerant
protected boolean faultTolerant
-
connectedBrokers
protected String connectedBrokers
-
reconnectTo
protected String reconnectTo
-
token
protected byte[] token
-
rebalanceConnection
protected boolean rebalanceConnection
-
-
Method Detail
-
getDataStructureType
public byte getDataStructureType()
- Returns:
- The type of the data structure
-
visit
public Response visit(CommandVisitor visitor) throws Exception
- Throws:
Exception
-
isConnectionControl
public boolean isConnectionControl()
- Specified by:
isConnectionControl
in interfaceCommand
- Overrides:
isConnectionControl
in classBaseCommand
-
isClose
public boolean isClose()
- Returns:
- Returns the close.
-
setClose
public void setClose(boolean close)
- Parameters:
close
- The close to set.
-
isExit
public boolean isExit()
- Returns:
- Returns the exit.
-
setExit
public void setExit(boolean exit)
- Parameters:
exit
- The exit to set.
-
isFaultTolerant
public boolean isFaultTolerant()
- Returns:
- Returns the faultTolerant.
-
setFaultTolerant
public void setFaultTolerant(boolean faultTolerant)
- Parameters:
faultTolerant
- The faultTolerant to set.
-
isResume
public boolean isResume()
- Returns:
- Returns the resume.
-
setResume
public void setResume(boolean resume)
- Parameters:
resume
- The resume to set.
-
isSuspend
public boolean isSuspend()
- Returns:
- Returns the suspend.
-
setSuspend
public void setSuspend(boolean suspend)
- Parameters:
suspend
- The suspend to set.
-
getConnectedBrokers
public String getConnectedBrokers()
- Returns:
- connected brokers.
-
setConnectedBrokers
public void setConnectedBrokers(String connectedBrokers)
- Parameters:
connectedBrokers
- the connectedBrokers to set
-
getReconnectTo
public String getReconnectTo()
- Returns:
- the reconnectTo
-
setReconnectTo
public void setReconnectTo(String reconnectTo)
- Parameters:
reconnectTo
- the reconnectTo to set
-
isRebalanceConnection
public boolean isRebalanceConnection()
- Returns:
- the rebalanceConnection
-
setRebalanceConnection
public void setRebalanceConnection(boolean rebalanceConnection)
- Parameters:
rebalanceConnection
- the rebalanceConnection to set
-
getToken
public byte[] getToken()
- Returns:
- the token
-
setToken
public void setToken(byte[] token)
- Parameters:
token
- the token to set
-
-