org.yamcs.api.artemis

Class YamcsConnector

java.lang.Object

org.yamcs.api.artemis.YamcsConnector

All Implemented Interfaces:

org.apache.activemq.artemis.api.core.client.SessionFailureListener, org.apache.activemq.artemis.core.remoting.FailureListener

public class YamcsConnector
extends Object
implements org.apache.activemq.artemis.api.core.client.SessionFailureListener

this is like a yamcssession but performs reconnection and implements some callbacks to announce the state. to be used by all the gui data receivers (event viewer, archive browser, etc)

Author:

nm

Field Summary

Fields

Modifier and Type	Field and Description
protected org.yamcs.api.YamcsConnectionProperties	connectionParams
protected YamcsSession	yamcsSession

Constructor Summary

Constructors

Constructor and Description
YamcsConnector()
YamcsConnector(boolean retry)

Method Summary

Modifier and Type	Method and Description
void	addConnectionListener(ConnectionListener connectionListener)
void	beforeReconnect(org.apache.activemq.artemis.api.core.ActiveMQException e)
void	close()
Future<String>	connect(org.yamcs.api.YamcsConnectionProperties cp)
void	connectionFailed(org.apache.activemq.artemis.api.core.ActiveMQException e, boolean failedOver)
void	connectionFailed(org.apache.activemq.artemis.api.core.ActiveMQException e, boolean failedOver, String scaleDownTargetNodeID)
void	disconnect()
org.yamcs.api.YamcsConnectionProperties	getConnectionParams()
ExecutorService	getExecutor()
int	getMaxAttempts()
YamcsSession	getSession()
String	getUrl()
List<String>	getYamcsInstances()
boolean	isConnected()
boolean	isConnecting()
void	setMaxAttempts(int maxAttempts)

Methods inherited from class java.lang.Object

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

Field Detail

yamcsSession

protected YamcsSession yamcsSession

connectionParams

protected org.yamcs.api.YamcsConnectionProperties connectionParams

Constructor Detail

YamcsConnector

public YamcsConnector()

YamcsConnector

public YamcsConnector(boolean retry)

Method Detail

getMaxAttempts

public int getMaxAttempts()

setMaxAttempts

public void setMaxAttempts(int maxAttempts)

addConnectionListener

public void addConnectionListener(ConnectionListener connectionListener)

getYamcsInstances

public List<String> getYamcsInstances()

connect

public Future<String> connect(org.yamcs.api.YamcsConnectionProperties cp)

disconnect

public void disconnect()

getUrl

public String getUrl()

isConnected

public boolean isConnected()

isConnecting

public boolean isConnecting()

connectionFailed

public void connectionFailed(org.apache.activemq.artemis.api.core.ActiveMQException e,
                             boolean failedOver,
                             String scaleDownTargetNodeID)

Specified by:

connectionFailed in interface org.apache.activemq.artemis.core.remoting.FailureListener

connectionFailed

public void connectionFailed(org.apache.activemq.artemis.api.core.ActiveMQException e,
                             boolean failedOver)

Specified by:

connectionFailed in interface org.apache.activemq.artemis.core.remoting.FailureListener

beforeReconnect

public void beforeReconnect(org.apache.activemq.artemis.api.core.ActiveMQException e)

Specified by:

beforeReconnect in interface org.apache.activemq.artemis.api.core.client.SessionFailureListener

getSession

public YamcsSession getSession()

getConnectionParams

public org.yamcs.api.YamcsConnectionProperties getConnectionParams()

close

public void close()
           throws org.apache.activemq.artemis.api.core.ActiveMQException

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException

getExecutor

public ExecutorService getExecutor()