org.yamcs.artemis

Class ArtemisPpService

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.yamcs.artemis.AbstractArtemisTranslatorService

org.yamcs.artemis.ArtemisPpService

All Implemented Interfaces:

com.google.common.util.concurrent.Service

public class ArtemisPpService
extends AbstractArtemisTranslatorService

takes Parameter data from yarch streams and publishes it to hornetq address (reverse of ActiveMQPpProvider) To avoid a ping-pong effect: - it creates a queue with a filter on hornet side - it remembers a thread local version of the tuple in transition on yarch side

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

Field Summary

Fields inherited from class org.yamcs.artemis.AbstractArtemisTranslatorService

ARTEMIS_URL_KEY, UNIQUEID, UNIQUEID_HDR_NAME

Constructor Summary

Constructors

Constructor and Description
ArtemisPpService(String instance, List<String> streamNames)

Method Summary

Methods inherited from class org.yamcs.artemis.AbstractArtemisTranslatorService

doStart, doStop, getServerLocator, toString

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

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync

Methods inherited from class java.lang.Object

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

Constructor Detail

ArtemisPpService

public ArtemisPpService(String instance,
                        List<String> streamNames)
                 throws ConfigurationException

Throws:

ConfigurationException