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
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionbooleanvoidconnect()voidconnectionFailed(ActiveMQException exception, boolean failedOver) Notifies that a connection has failed due to the specified exception.voidconnectionFailed(ActiveMQException exception, boolean failedOver, String scaleDownTargetNodeID) Notifies that a connection has failed due to the specified exception.void<T> TgetAttribute(String resourceName, String attributeName, Class<T> attributeClass, int timeout) <T> TinvokeOperation(String resourceName, String operationName, Object[] operationParams, Class<T> operationClass, int timeout) booleanbooleanisLocal()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
-
Constructor Details
-
ActiveMQTarget
-
-
Method Details
-
isLocal
public boolean isLocal() -
isConnected
public boolean isConnected()- Specified by:
isConnectedin interfaceTarget
-
connect
-
disconnect
- Specified by:
disconnectin interfaceTarget- Throws:
Exception
-
checkReadiness
public boolean checkReadiness()- Specified by:
checkReadinessin interfaceTarget
-
getAttribute
public <T> T getAttribute(String resourceName, String attributeName, Class<T> attributeClass, int timeout) throws Exception - Specified by:
getAttributein interfaceTarget- Throws:
Exception
-
invokeOperation
public <T> T invokeOperation(String resourceName, String operationName, Object[] operationParams, Class<T> operationClass, int timeout) throws Exception - Specified by:
invokeOperationin interfaceTarget- Throws:
Exception
-
connectionFailed
Description copied from interface:FailureListenerNotifies that a connection has failed due to the specified exception.- Specified by:
connectionFailedin interfaceFailureListener- Parameters:
exception- exception which has caused the connection to fail
-
connectionFailed
public void connectionFailed(ActiveMQException exception, boolean failedOver, String scaleDownTargetNodeID) Description copied from interface:FailureListenerNotifies that a connection has failed due to the specified exception.- Specified by:
connectionFailedin interfaceFailureListener- Parameters:
exception- exception which has caused the connection to failscaleDownTargetNodeID- the ID of the node to which messages are scaling down
-