org.yamcs.api.artemis

Class ArtemisEventProducer

java.lang.Object

org.yamcs.api.AbstractEventProducer

org.yamcs.api.artemis.ArtemisEventProducer

All Implemented Interfaces:

EventListener, ConnectionListener, EventProducer

public class ArtemisEventProducer
extends AbstractEventProducer
implements ConnectionListener

An EventProducer that publishes events over HornetQ

By default, repeated message are detected and reduced, resulting in pseudo events with a message like 'last event repeated X times'. This behaviour can be turned off.

Constructor Summary

Constructors

Constructor and Description
ArtemisEventProducer(YamcsConnectionProperties ycd)

Method Summary

Modifier and Type	Method and Description
void	close() Closes the connection to the server; the producer is unusable after this is called
void	connected(String url) Called after a successful connection to the yamcs server has been established.
void	connecting(String url) Called right before the initial connection to yamcs is being made.
void	connectionFailed(String url, YamcsException exception) Called when the initial connection to the yamcs server has failed, e.g.
void	disconnected() Called when the connection to the yamcs server is closed.
long	getMissionTime()
void	log(String message) Used to log messages.
void	sendEvent(Yamcs.Event event)
String	toString()

Methods inherited from class org.yamcs.api.AbstractEventProducer

flushEventBuffer, newEvent, sendError, sendInfo, sendWarning, setRepeatedEventReduction, setSeqNo, setSource

Methods inherited from class java.lang.Object

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

Constructor Detail

ArtemisEventProducer

public ArtemisEventProducer(YamcsConnectionProperties ycd)

Method Detail

connecting

public void connecting(String url)

Description copied from interface: ConnectionListener

Called right before the initial connection to yamcs is being made.

Specified by:

connecting in interface ConnectionListener

Parameters:

url - the url of the yamcs server

connected

public void connected(String url)

Description copied from interface: ConnectionListener

Called after a successful connection to the yamcs server has been established.

Note: when using a re-connecting YamcsConnector, this method is also called after a successful re-connection attempt.

Specified by:

connected in interface ConnectionListener

Parameters:

url - the url of the yamcs server

connectionFailed

public void connectionFailed(String url,
                             YamcsException exception)

Description copied from interface: ConnectionListener

Called when the initial connection to the yamcs server has failed, e.g. the maximum number of retry attempts has exceeded.

Specified by:

connectionFailed in interface ConnectionListener

Parameters:

url - the url of the yamcs server

exception - Optional cause of the connection failure, may be null.

disconnected

public void disconnected()

Description copied from interface: ConnectionListener

Called when the connection to the yamcs server is closed.

Specified by:

disconnected in interface ConnectionListener

log

public void log(String message)

Description copied from interface: ConnectionListener

Used to log messages.

Specified by:

log in interface ConnectionListener

Parameters:

message - the messages to be logged

close

public void close()

Description copied from interface: EventProducer

Closes the connection to the server; the producer is unusable after this is called

Specified by:

close in interface EventProducer

sendEvent

public void sendEvent(Yamcs.Event event)

Specified by:

sendEvent in interface EventProducer

toString

public String toString()

Overrides:

toString in class Object

getMissionTime

public long getMissionTime()

Specified by:

getMissionTime in class AbstractEventProducer