| org.cougaar.mts.base |
|
This package contains the core software components and
infrastructure for the the full Message Transport Service, including
key Aspects and LinkProtocols but excluding optional Aspects and
LinkProtocols.
For a more complete description of the MTS, see
Message Transport Service online manual
.
|
| Java Source File Name | Type | Comment |
| AbstractLinkSelectionPolicy.java | Class | An abstract base implementation of
LinkSelectionPolicy which handles the registration through the
LinkSelectionProvisionService . |
| AbstractSocketControlPolicy.java | Class | An abstract base implementation of
SocketControlPolicy which handles the registration through the
SocketControlProvisionService . |
| BoundComponent.java | Class | Root class of Components of the MTS. |
| CommFailureException.java | Class | This Exception indicates a
DestinationLink general
communications failure. |
| CougaarIOException.java | Class | Parent class of COUGAAR-specific
IOException s. |
| DestinationLink.java | Interface | The fifth station for outgoing messages. |
| DestinationLinkDelegateImplBase.java | Class | Convenience class for aspects which define
DestinationLink delegate classes. |
| DestinationQueue.java | Interface | The fourth station for an outgoing message is a DestinationQueue. |
| DestinationQueueDelegateImplBase.java | Class | Convenience class for aspects which define
DestinationQueue delegate classes. |
| DestinationQueueFactory.java | Class | This Component implements the
DestinationQueueProviderService , which makes DestinationQueues on
demand, and the
DestinationQueueMonitorService , which
allows clients to be notified of queue events. |
| DestinationQueueImpl.java | Class | The default, and for now only, implementation of
DestinationQueue . |
| DestinationQueueMonitorService.java | Interface | This is an MTS-internal service, accessible only to child
components of the MTS, that allows those components to examine the
state of any given DestinationQueue. |
| DestinationQueueProviderService.java | Interface | This is the factory service for getting a queue for a given
destination. |
| DontRetryException.java | Class | This kind of IOException should be thrown if the receiving node
wants to indicate to the sending Node that it should not retry
sending a given message even though that message failed to be
delivered. |
| LinkProtocol.java | Class | The parent class of all Link Protocols. |
| LinkProtocolFactory.java | Class | This class was originally designed to instantiate
LinkProtocol s, given a list of class names. |
| LinkProtocolService.java | Interface | |
| LinkSelectionPolicy.java | Interface | The selection of a
DestinationLink is handled by this MTS-internal
service, which is accessible only to MTS components. |
| LinkSelectionPolicyServiceProvider.java | Class | This
ServiceProvider provides the
LinkSelectionPolicy service. |
| LinkSelectionProvision.java | Class | The
ServiceProvider for the
LinkSelectionProvisionService . |
| LinkSelectionProvisionService.java | Interface | This MTS-internal service can be used to get and set the current
LinkSelectionPolicy . |
| LoopbackLinkProtocol.java | Class | This protocol Component handles intra-node message traffic. |
| MessageDeliverer.java | Interface | The first or second station for an outgoing message on the receive
side is a MessageDeliverer (first if no serialization, second
otherwise). |
| MessageDelivererDelegateImplBase.java | Class | Convenience class for aspects which define
MessageDeliverer delegate classes. |
| MessageDelivererFactory.java | Class | This
ServiceProvider provides the
MessageDeliverer service, which is implemented by a singleton MessageDelivererImpl. |
| MessageDelivererImpl.java | Class | The default, and for now only, implementation of
MessageDeliverer . |
| MessageProtectionServiceImpl.java | Class | This
ServiceProvider both provides and implements the
MessageProtectionService . |
| MessageQueue.java | Class | An abstract class which manages a circular queue of messages, and
runs its own thread to pop messages off that queue. |
| MessageReader.java | Interface | This is the first station in the receiver for serializling
LinkProtocols. |
| MessageReaderDelegateImplBase.java | Class | Convenience class for aspects which define
MessageReader delegate classes. |
| MessageReaderImpl.java | Class | Default implementatiom of
MessageReader that uses a trivial
ObjectInputStream extension to delegate calls to the
original
ObjectInput . |
| MessageReply.java | Class | This simple extension of
AttributedMessage should be used
only for replies. |
| MessageSecurityException.java | Class | This class of Exceptions is thrown by the security services if a
message fails to be delivered for security reasons and if the send
should therefore not be retried. |
| MessageSerializationException.java | Class | This class of Exceptions is thrown if a message fails to be
delivered for serialization reasons and if the send should
therefore not be retried. |
| MessageStreamsFactory.java | Class | This factory is used to create MessageReaders and MessageWriters
with a specific list of Aspects. |
| MessageTransportAspect.java | Interface | Abstract specification of a aspect in the message transport
subsystem. |
| MessageTransportException.java | Class | This Exception class contains the information for throwing an
exception for the invalid messages by the Message Transport Service
For the first version of this class the exceptions diffferentiated by the
int type passed in during construction. |
| MessageTransportRegistry.java | Class | The MessageTransportRegistry
ServiceProvider singleton is a
utility instance that helps certain pieces of the message transport
subsystem to find one another. |
| MessageTransportRegistryService.java | Interface | This is a utility/bookkeeping service for the MTS. |
| MessageTransportServiceProvider.java | Class | This Component and Container is the ServiceProvider for the
MessageTransportService . |
| MessageTransportServiceProxy.java | Class | Currently the only implementation of MessageTransportService. |
| MessageWriter.java | Interface | This is the final station in the sender for serializling
LinkProyocols. |
| MessageWriterDelegateImplBase.java | Class | Convenience class for aspects which define
MessageWriter delegate classes. |
| MessageWriterImpl.java | Class | Default implementatiom of
MessageWriter that uses a trivial
ObjectOutputStream extension to delegate calls to the
original
ObjectOutput . |
| MinCostLinkSelectionPolicy.java | Class | A cost-based
LinkSelectionPolicy that chooses the cheapest
link. |
| MisdeliveredMessageException.java | Class | This Exception is thrown when the message is delivered to a Node
that does not contain the target Agent, probably because the
agent has moved. |
| NameLookupException.java | Class | This Exception generally indicates a failed call to the White
Pages from within the MTS. |
| NameSupport.java | Interface | This utility service hides the grimy details of dealing with
NameServers and White Pages from the rest of the message transport
subsystem. |
| NameSupportDelegateImplBase.java | Class | Convenience class for aspects which define
NameSupport delegate classes. |
| NameSupportImpl.java | Class | This
ServiceProvider provides the
NameSupport service. |
| QueueFactory.java | Class | This abstraction provides 'listener' support to inform interested
parties when objects are removed from message queues. |
| QueueListener.java | Interface | This interface describes the queue events for which listeners can
be notifified via callback. |
| QueueProviderService.java | Interface | Generic service specialized by DestinationQueueProviderService and
SendQueueProviderService. |
| ReceiveLink.java | Interface | The final station in the message transport system before an
incoming message is delivered to an Agent. |
| ReceiveLinkDelegateImplBase.java | Class | Convenience class for aspects which define
ReceiveLink delegate classes. |
| ReceiveLinkFactory.java | Class | This
ServiceProvider both provides and implements the
ReceiveLinkProviderService . |
| ReceiveLinkImpl.java | Class | The only current implementation of ReceiveLink. |
| ReceiveLinkProviderService.java | Interface | This is the factory service for getting a ReceiveLink for a given
destination. |
| Router.java | Interface | The third station for an outgoing message. |
| RouterDelegateImplBase.java | Class | Convenience class for aspects which define
Router delegate classes. |
| RouterFactory.java | Class | This
ServiceProvider provides the
Router service. |
| RouterImpl.java | Class | The default, and for now only, implementation of Router. |
| RPCLinkProtocol.java | Class | This is the parent class of all
LinkProtocol s that use a
remote-procedure-call (rpc) semantics. |
| SendLink.java | Interface | SendLink is the first station after the MessageTransportService
implementation class. |
| SendLinkDelegateImplBase.java | Class | Convenience class for aspects which define
SendLink delegate classes. |
| SendLinkImpl.java | Class | The only implementation of
SendLink , instantiated once per
MessageTransportClient. |
| SendQueue.java | Interface | The second station for an outgoing message is a SendQueue. |
| SendQueueDelegateImplBase.java | Class | Convenience class for aspects which define
SendQueue delegate classes. |
| SendQueueFactory.java | Class | This
ServiceProvider provides and implements the
SendQueueProviderService . |
| SendQueueImpl.java | Class | The default, and for now only, implementation of
SendQueue .
The implementation of sendMessage simply adds the
message to the queue. |
| SendQueueProviderService.java | Interface | This is the factory service for getting a queue for a given
sender. |
| ServerSocketWrapper.java | Class | This class is a delegating
ServerSocket that simply passes
all methods to another socket. |
| SocketControlPolicy.java | Interface | This interface is a simple version of pluggable control over
network sockets. |
| SocketControlProvision.java | Class | This
ServiceProvider provides the
SocketControlProvisionService, the implementation of which is an
inner class. |
| SocketControlProvisionService.java | Interface | This MTS-internal service can be used to get and set the current
SocketControlPolicy . |
| SocketDelegateImplBase.java | Class | This class is a delegating
Socket that simply passes all
methods to another socket. |
| SocketFactory.java | Class | This is an RMISocketFactory that can wrap
ServerSocket s and
apply Aspect delegates to client
Socket s. |
| SocketFactorySPC.java | Class | Provide SocketFactoryService via the std (aspected) MTS for the rest of the world. |
| StandardAspect.java | Class | Default base Aspect class. |
| TransientIOException.java | Class | Special kind of IOException whose stack trace shouldn't be
logged. |
| UnregisteredNameException.java | Class | This Exception indicates a type of Link Protocol failure and it
is thrown when the destination address specified could not be
obtained from the Name Lookup Service i.e destination address is
not created yet. |
| UnresolvableReferenceException.java | Class | This Exception appears to be unused. |