Package org.lsst.ccs.messaging
package org.lsst.ccs.messaging
Package defining the CCS Messaging interfaces.
It is built on top of the CCS Buses and it defines how messages are sent/received by the different components registered to the listen to the buses.
- Author:
- emarin, turri
-
ClassDescriptionThis interface provides messaging methods for a component (eg an agent) to be able to communicate on the buses.MBean to interact with the messaging layer.Agents that implement this interface are notified when an agent is connecting or has disconnected on the status busTracks agent connection and disconnection on the buses.Calls a BusMessagingLayer and adds all that is necessary to handle messages following application layer concerns.BusMessageForwarder<T extends BusMessage>A BusMessageForwarder receives a BusMessage from the transport layer and passes it to registered MessageListener.Interface to be implemented by Agent Services that wish to modify the content of an incoming BusMessage.Interface defining the access to the Transport Layer of BusesHandler for messaging deserialization errors.An interface to receive notifications when the cluster membership changes.The Command executor receives a command and executes it.Interface to be implemented by listeners that wish to be notified of messages received on the command bus.Originator of a command.Exception thrown by utility classes to indicate that a command has been rejected.Utility class to synchronously or asynchronously invoke or listen for events on the buses.A dummy lock used for preliminary implementation of the agent lock service.This exception is thrown when an agent tries to connect with a non unique name.Interface to be implemented by a BusMessagingLayer that provides cluster membership notifications natively.Interface for finding lock and level for an agent at the AgentMessagingLayer.A java util log Handler that forwards messages to the Log bus.Interface to be implemented by listeners that wish to be notified of messages received on the LOG bus.Marker interface to be implemented by bus message listeners.Entry point for receiving messages from the buses.MessagingAccessLayer.BusAccess<T extends BusMessage>Handler for processing received messages.Interface providing methods to connect/disconnect MessagingAccessLayer objects to/from the CCS buses and to send messages over the buses.Manages the creation of the messaging layer implementations.An interface for listening to outgoing messages.Interface to be implemented by listeners that wish to be notified of messages received on the status bus.Factory for
BusMessagingLayerinstances.