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 and 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 and Description
ConnectionControl()

Method Summary

Methods

Modifier and Type	Method and 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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

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

Constructor Detail

ConnectionControl

public ConnectionControl()

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 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 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