org.yamcs.artemis

Class ArtemisRetrievalServer

java.lang.Object

com.google.common.util.concurrent.AbstractExecutionThreadService

org.yamcs.artemis.ArtemisRetrievalServer

All Implemented Interfaces:

com.google.common.util.concurrent.Service

public class ArtemisRetrievalServer
extends com.google.common.util.concurrent.AbstractExecutionThreadService

Provides connection to the replay server via hornetq It allows to retrieve "raw" data (tm, events, cmd_history) but not parameters

Author:

nm

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Constructor Summary

Constructors

Constructor and Description
ArtemisRetrievalServer(ReplayServer replayServer)

Method Summary

Modifier and Type	Method and Description
void	createReplay(org.apache.activemq.artemis.api.core.client.ClientMessage requestMsg, org.apache.activemq.artemis.api.core.SimpleString replyto, org.apache.activemq.artemis.api.core.SimpleString dataAddress) create a new packet replay object
void	run()
protected void	startUp()
void	triggerShutdown()

Methods inherited from class com.google.common.util.concurrent.AbstractExecutionThreadService

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, executor, failureCause, isRunning, serviceName, shutDown, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

ArtemisRetrievalServer

public ArtemisRetrievalServer(ReplayServer replayServer)
                       throws org.apache.activemq.artemis.api.core.ActiveMQException,
                              YamcsApiException

Throws:

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

YamcsApiException

Method Detail

startUp

protected void startUp()

Overrides:

startUp in class com.google.common.util.concurrent.AbstractExecutionThreadService

run

public void run()

Specified by:

run in class com.google.common.util.concurrent.AbstractExecutionThreadService

createReplay

public void createReplay(org.apache.activemq.artemis.api.core.client.ClientMessage requestMsg,
                         org.apache.activemq.artemis.api.core.SimpleString replyto,
                         org.apache.activemq.artemis.api.core.SimpleString dataAddress)
                  throws YamcsException,
                         YamcsApiException,
                         IOException,
                         org.apache.activemq.artemis.api.core.ActiveMQException,
                         InvalidAuthenticationToken

create a new packet replay object

Parameters:

requestMsg - - message containing in the body the protobuf ReplayRequest

replyto - - address used to send the response message

dataAddress - - address used to send the data

Throws:

YamcsApiException

YamcsException

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

IOException

InvalidAuthenticationToken

triggerShutdown

public void triggerShutdown()

Overrides:

triggerShutdown in class com.google.common.util.concurrent.AbstractExecutionThreadService