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.
Methods inherited from class 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 inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
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 java.lang.String connectedBrokers
reconnectTo
protected java.lang.String reconnectTo
token
protected byte[] token
rebalanceConnection
protected boolean rebalanceConnection
ConnectionControl
public ConnectionControl()
getDataStructureType
public byte getDataStructureType()
- Returns:
- The type of the data structure
visit
public Response visit(CommandVisitor visitor)
throws java.lang.Exception
- Throws:
java.lang.Exception
isConnectionControl
public boolean isConnectionControl()
- Specified by:
isConnectionControl
in interface Command
- Overrides:
isConnectionControl
in class BaseCommand
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 java.lang.String getConnectedBrokers()
- Returns:
- connected brokers.
setConnectedBrokers
public void setConnectedBrokers(java.lang.String connectedBrokers)
- Parameters:
connectedBrokers
- the connectedBrokers to set
getReconnectTo
public java.lang.String getReconnectTo()
- Returns:
- the reconnectTo
setReconnectTo
public void setReconnectTo(java.lang.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
Copyright © 2005-2016. All Rights Reserved.