Package org.apache.activemq.artemis.core.server.routing.targets

Class ActiveMQTarget

java.lang.Object

org.apache.activemq.artemis.core.server.routing.targets.AbstractTarget

org.apache.activemq.artemis.core.server.routing.targets.ActiveMQTarget

All Implemented Interfaces:

FailureListener, Target

public class ActiveMQTarget
extends AbstractTarget
implements FailureListener

Constructor Summary

Constructors

Constructor	Description
ActiveMQTarget(TransportConfiguration connector, String nodeID)

Method Summary

Modifier and Type	Method	Description
boolean	checkReadiness()
void	connect()
void	connectionFailed(ActiveMQException exception, boolean failedOver)	Notifies that a connection has failed due to the specified exception.
void	connectionFailed(ActiveMQException exception, boolean failedOver, String scaleDownTargetNodeID)	Notifies that a connection has failed due to the specified exception.
void	disconnect()
<T> T	getAttribute(String resourceName, String attributeName, Class<T> attributeClass, int timeout)
<T> T	invokeOperation(String resourceName, String operationName, Object[] operationParams, Class<T> operationClass, int timeout)
boolean	isConnected()
boolean	isLocal()

Methods inherited from class org.apache.activemq.artemis.core.server.routing.targets.AbstractTarget

fireConnectedEvent, fireDisconnectedEvent, getCheckPeriod, getConnector, getListener, getNodeID, getPassword, getUsername, setCheckPeriod, setListener, setNodeID, setPassword, setUsername, toString

Methods inherited from class java.lang.Object

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

Constructor Details

ActiveMQTarget

public ActiveMQTarget(TransportConfiguration connector,
 String nodeID)

Method Details

isLocal

public boolean isLocal()

Specified by:

isLocal in interface Target

isConnected

public boolean isConnected()

Specified by:

isConnected in interface Target

connect

public void connect()
             throws Exception

Specified by:

connect in interface Target

Throws:

Exception

disconnect

public void disconnect()
                throws Exception

Specified by:

disconnect in interface Target

Throws:

Exception

checkReadiness

public boolean checkReadiness()

Specified by:

checkReadiness in interface Target

getAttribute

public <T> T getAttribute(String resourceName,
 String attributeName,
 Class<T> attributeClass,
 int timeout)
                   throws Exception

Specified by:

getAttribute in interface Target

Throws:

Exception

invokeOperation

public <T> T invokeOperation(String resourceName,
 String operationName,
 Object[] operationParams,
 Class<T> operationClass,
 int timeout)
                      throws Exception

Specified by:

invokeOperation in interface Target

Throws:

Exception

connectionFailed

public void connectionFailed(ActiveMQException exception,
 boolean failedOver)

Description copied from interface: FailureListener

Notifies that a connection has failed due to the specified exception.

Specified by:

connectionFailed in interface FailureListener

Parameters:

exception - exception which has caused the connection to fail

connectionFailed

public void connectionFailed(ActiveMQException exception,
 boolean failedOver,
 String scaleDownTargetNodeID)

Description copied from interface: FailureListener

Notifies that a connection has failed due to the specified exception.

Specified by:

connectionFailed in interface FailureListener

Parameters:

exception - exception which has caused the connection to fail

scaleDownTargetNodeID - the ID of the node to which messages are scaling down