org.yamcs.artemis

Class ArtemisReplayServer

java.lang.Object

com.google.common.util.concurrent.AbstractExecutionThreadService

org.yamcs.artemis.ArtemisReplayServer

All Implemented Interfaces:

com.google.common.util.concurrent.Service

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

Provides capability to perform replays via ActiveMQ by initiating new processors. It allows to retrieve parameters via ActiveMQ

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
ArtemisReplayServer(String instance)

Method Summary

Modifier and Type	Method and Description
void	createReplay(org.apache.activemq.artemis.api.core.client.ClientMessage msg, 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

ArtemisReplayServer

public ArtemisReplayServer(String instance)
                    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 msg,
                         org.apache.activemq.artemis.api.core.SimpleString replyto,
                         org.apache.activemq.artemis.api.core.SimpleString dataAddress)
                  throws Exception

create a new packet replay object

Throws:

Exception

triggerShutdown

public void triggerShutdown()

Overrides:

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