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 booleancloseprotected StringconnectedBrokersstatic byteDATA_STRUCTURE_TYPEprotected booleanexitprotected booleanfaultTolerantprotected booleanrebalanceConnectionprotected StringreconnectToprotected booleanresumeprotected booleansuspendprotected 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 StringgetConnectedBrokers()bytegetDataStructureType()StringgetReconnectTo()byte[]getToken()booleanisClose()booleanisConnectionControl()booleanisExit()booleanisFaultTolerant()booleanisRebalanceConnection()booleanisResume()booleanisSuspend()voidsetClose(boolean close)voidsetConnectedBrokers(String connectedBrokers)voidsetExit(boolean exit)voidsetFaultTolerant(boolean faultTolerant)voidsetRebalanceConnection(boolean rebalanceConnection)voidsetReconnectTo(String reconnectTo)voidsetResume(boolean resume)voidsetSuspend(boolean suspend)voidsetToken(byte[] token)Responsevisit(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:
isConnectionControlin interfaceCommand- Overrides:
isConnectionControlin 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
-
-