org.yamcs.artemis

Class StreamAdapter

java.lang.Object

org.yamcs.artemis.StreamAdapter

All Implemented Interfaces:

org.apache.activemq.artemis.api.core.client.MessageHandler, StreamSubscriber

Deprecated.

@Deprecated
public class StreamAdapter
extends Object
implements StreamSubscriber, org.apache.activemq.artemis.api.core.client.MessageHandler

converts between hornet addresses and yamcs streams 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 this class is deprecated because it converts data in both directions whereas we want to be able to do it separately and have the incoming data as Data Links. The ActiveMQ XYZ Providers shall be used for ActiveMQ to stream translator and the ActiveMQXYZService (based on AbstractActiveMQTranslatorService) in the other direction. Currently used only for events - once event providers are also shown as data links, we should get rid of this.

Field Summary

Fields

Modifier and Type	Field and Description
static int	UNIQUEID Deprecated.
static String	UNIQUEID_HDR_NAME Deprecated.

Constructor Summary

Constructors

Constructor and Description
StreamAdapter(Stream stream, org.apache.activemq.artemis.api.core.SimpleString hornetAddress, TupleTranslator translator) Deprecated.

Method Summary

Modifier and Type	Method and Description
void	onMessage(org.apache.activemq.artemis.api.core.client.ClientMessage msg) Deprecated.
void	onTuple(Stream s, Tuple tuple) Deprecated.
void	quit() Deprecated.
void	streamClosed(Stream istream) Deprecated.
String	toString() Deprecated.

Methods inherited from class java.lang.Object

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

Field Detail

UNIQUEID_HDR_NAME

public static final String UNIQUEID_HDR_NAME

Deprecated.

See Also:

Constant Field Values

UNIQUEID

public static final int UNIQUEID

Deprecated.

Constructor Detail

StreamAdapter

public StreamAdapter(Stream stream,
                     org.apache.activemq.artemis.api.core.SimpleString hornetAddress,
                     TupleTranslator translator)
              throws org.apache.activemq.artemis.api.core.ActiveMQException,
                     YamcsApiException

Deprecated.

Throws:

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

YamcsApiException

Method Detail

onTuple

public void onTuple(Stream s,
                    Tuple tuple)

Deprecated.

Specified by:

onTuple in interface StreamSubscriber

streamClosed

public void streamClosed(Stream istream)

Deprecated.

Specified by:

streamClosed in interface StreamSubscriber

onMessage

public void onMessage(org.apache.activemq.artemis.api.core.client.ClientMessage msg)

Deprecated.

Specified by:

onMessage in interface org.apache.activemq.artemis.api.core.client.MessageHandler

quit

public void quit()

Deprecated.

toString

public String toString()

Deprecated.

Overrides:

toString in class Object