org.yamcs.api.artemis

Class Protocol

java.lang.Object

org.yamcs.api.artemis.Protocol

public class Protocol
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.activemq.artemis.api.core.SimpleString	CMDQUEUE_CONTROL_ADDRESS address where command queue control commands can be sent
static org.apache.activemq.artemis.api.core.SimpleString	CMDQUEUE_INFO_ADDRESS address where all the Command Queues and command stationed in the Queues are registered there is also a queue with the same name that can be browsed to get the initial list
static org.apache.activemq.artemis.api.core.SimpleString	DATA_TO_HEADER_NAME
static String	DATA_TYPE_HEADER_NAME used to send chunks of data in a stream
static String	ERROR_MSG_HEADER_NAME
static String	ERROR_TYPE_HEADER_NAME
static String	HDR_EVENT_NAME used to send one shot events (publish/subscribe)
static String	IN_VM_FACTORY
static org.apache.activemq.artemis.api.core.SimpleString	LINK_CONTROL_ADDRESS address where link control messages can be sent
static org.apache.activemq.artemis.api.core.SimpleString	LINK_INFO_ADDRESS address where all the I/O Links are registered (e.g.
static String	MSG_TYPE_HEADER_NAME
static org.apache.activemq.artemis.api.core.SimpleString	REPLYTO_HEADER_NAME
static String	REQUEST_TYPE_HEADER_NAME
static org.apache.activemq.artemis.api.core.SimpleString	YAMCS_SERVER_CONTROL_ADDRESS
static org.apache.activemq.artemis.api.core.SimpleString	YPROCESSOR_CONTROL_ADDRESS address where channel control commands can be sent
static org.apache.activemq.artemis.api.core.SimpleString	YPROCESSOR_INFO_ADDRESS address where all the Channels are registered there is also a queue with the same name that can be browsed to get the initial list
static org.apache.activemq.artemis.api.core.SimpleString	YPROCESSOR_STATISTICS_ADDRESS address where channel statistics are published regularly

Constructor Summary

Constructors

Constructor and Description
Protocol()

Method Summary

Modifier and Type	Method and Description
static void	closeKiller() Close killer (used in order to reduce warnings during maven builds
static com.google.protobuf.MessageLite	decode(org.apache.activemq.artemis.api.core.client.ClientMessage msg, com.google.protobuf.MessageLite.Builder builder)
static com.google.protobuf.MessageLite.Builder	decodeBuilder(org.apache.activemq.artemis.api.core.client.ClientMessage msg, com.google.protobuf.MessageLite.Builder builder)
static void	encode(org.apache.activemq.artemis.api.core.client.ClientMessage msg, com.google.protobuf.MessageLite ml)
static boolean	endOfStream(org.apache.activemq.artemis.api.core.client.ClientMessage msg)
static org.apache.activemq.artemis.api.core.SimpleString	getEventRealtimeAddress(String instance)
static org.apache.activemq.artemis.api.core.SimpleString	getPacketAddress(String instance, String streamName)
static org.apache.activemq.artemis.api.core.SimpleString	getPacketRealtimeAddress(String instance)
static org.apache.activemq.artemis.api.core.SimpleString	getParameterRealtimeAddress(String instance)
static org.apache.activemq.artemis.api.core.SimpleString	getReplayControlAddress(String instance)
static org.apache.activemq.artemis.api.core.SimpleString	getYarchIndexControlAddress(String instance)
static org.apache.activemq.artemis.api.core.SimpleString	getYarchRetrievalControlAddress(String instance)
static void	killProducerOnConsumerClosed(org.apache.activemq.artemis.api.core.client.ClientProducer p, org.apache.activemq.artemis.api.core.SimpleString a) Closes producer when a consumer for address a has been detected as dead

Methods inherited from class java.lang.Object

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

Field Detail

MSG_TYPE_HEADER_NAME

public static final String MSG_TYPE_HEADER_NAME

See Also:

Constant Field Values

REQUEST_TYPE_HEADER_NAME

public static final String REQUEST_TYPE_HEADER_NAME

See Also:

Constant Field Values

ERROR_MSG_HEADER_NAME

public static final String ERROR_MSG_HEADER_NAME

See Also:

Constant Field Values

ERROR_TYPE_HEADER_NAME

public static final String ERROR_TYPE_HEADER_NAME

See Also:

Constant Field Values

DATA_TO_HEADER_NAME

public static final org.apache.activemq.artemis.api.core.SimpleString DATA_TO_HEADER_NAME

YAMCS_SERVER_CONTROL_ADDRESS

public static final org.apache.activemq.artemis.api.core.SimpleString YAMCS_SERVER_CONTROL_ADDRESS

REPLYTO_HEADER_NAME

public static final org.apache.activemq.artemis.api.core.SimpleString REPLYTO_HEADER_NAME

IN_VM_FACTORY

public static final String IN_VM_FACTORY

See Also:

Constant Field Values

DATA_TYPE_HEADER_NAME

public static final String DATA_TYPE_HEADER_NAME

used to send chunks of data in a stream

See Also:

Constant Field Values

HDR_EVENT_NAME

public static final String HDR_EVENT_NAME

used to send one shot events (publish/subscribe)

See Also:

Constant Field Values

LINK_INFO_ADDRESS

public static final org.apache.activemq.artemis.api.core.SimpleString LINK_INFO_ADDRESS

address where all the I/O Links are registered (e.g. tmprovide and tcuplinker) there is also a queue with the same name that can be browsed to get the initial list

LINK_CONTROL_ADDRESS

public static final org.apache.activemq.artemis.api.core.SimpleString LINK_CONTROL_ADDRESS

address where link control messages can be sent

YPROCESSOR_INFO_ADDRESS

public static final org.apache.activemq.artemis.api.core.SimpleString YPROCESSOR_INFO_ADDRESS

address where all the Channels are registered there is also a queue with the same name that can be browsed to get the initial list

YPROCESSOR_CONTROL_ADDRESS

public static final org.apache.activemq.artemis.api.core.SimpleString YPROCESSOR_CONTROL_ADDRESS

address where channel control commands can be sent

YPROCESSOR_STATISTICS_ADDRESS

public static final org.apache.activemq.artemis.api.core.SimpleString YPROCESSOR_STATISTICS_ADDRESS

address where channel statistics are published regularly

CMDQUEUE_INFO_ADDRESS

public static final org.apache.activemq.artemis.api.core.SimpleString CMDQUEUE_INFO_ADDRESS

address where all the Command Queues and command stationed in the Queues are registered there is also a queue with the same name that can be browsed to get the initial list

CMDQUEUE_CONTROL_ADDRESS

public static final org.apache.activemq.artemis.api.core.SimpleString CMDQUEUE_CONTROL_ADDRESS

address where command queue control commands can be sent

Constructor Detail

Protocol

public Protocol()

Method Detail

getReplayControlAddress

public static org.apache.activemq.artemis.api.core.SimpleString getReplayControlAddress(String instance)

getYarchRetrievalControlAddress

public static org.apache.activemq.artemis.api.core.SimpleString getYarchRetrievalControlAddress(String instance)

getYarchIndexControlAddress

public static org.apache.activemq.artemis.api.core.SimpleString getYarchIndexControlAddress(String instance)

getEventRealtimeAddress

public static org.apache.activemq.artemis.api.core.SimpleString getEventRealtimeAddress(String instance)

getParameterRealtimeAddress

public static org.apache.activemq.artemis.api.core.SimpleString getParameterRealtimeAddress(String instance)

getPacketRealtimeAddress

public static org.apache.activemq.artemis.api.core.SimpleString getPacketRealtimeAddress(String instance)

getPacketAddress

public static org.apache.activemq.artemis.api.core.SimpleString getPacketAddress(String instance,
                                                                                 String streamName)

decode

public static com.google.protobuf.MessageLite decode(org.apache.activemq.artemis.api.core.client.ClientMessage msg,
                                                     com.google.protobuf.MessageLite.Builder builder)
                                              throws org.yamcs.api.YamcsApiException

Throws:

org.yamcs.api.YamcsApiException

decodeBuilder

public static com.google.protobuf.MessageLite.Builder decodeBuilder(org.apache.activemq.artemis.api.core.client.ClientMessage msg,
                                                                    com.google.protobuf.MessageLite.Builder builder)
                                                             throws org.yamcs.api.YamcsApiException

Throws:

org.yamcs.api.YamcsApiException

encode

public static void encode(org.apache.activemq.artemis.api.core.client.ClientMessage msg,
                          com.google.protobuf.MessageLite ml)

endOfStream

public static boolean endOfStream(org.apache.activemq.artemis.api.core.client.ClientMessage msg)

killProducerOnConsumerClosed

public static void killProducerOnConsumerClosed(org.apache.activemq.artemis.api.core.client.ClientProducer p,
                                                org.apache.activemq.artemis.api.core.SimpleString a)

Closes producer when a consumer for address a has been detected as dead

Parameters:

p -

a -

closeKiller

public static void closeKiller()

Close killer (used in order to reduce warnings during maven builds