Package | Description |
---|---|
com.scalagent.joram.mom.dest.ftp | |
com.scalagent.joram.mom.dest.scheduler | |
fr.dyade.aaa.agent | |
fr.dyade.aaa.common.encoding | |
fr.dyade.aaa.common.stream | |
fr.dyade.aaa.jndi2.distributed | |
fr.dyade.aaa.jndi2.server | |
fr.dyade.aaa.util | |
org.objectweb.joram.mom.dest |
The
org.objectweb.joram.mom.dest package holds the classes implementing the queue, topic and specialized destinations provided by JORAM's MOM. |
org.objectweb.joram.mom.dest.jmsbridge |
The
org.objectweb.joram.mom.dest.jmsbridge package provides utility classes used by the MOM destinations and proxies. |
org.objectweb.joram.mom.messages |
The
org.objectweb.joram.shared.messages package provides the implementation classes of the messages routed by the MOM. |
org.objectweb.joram.mom.notifications |
The
org.objectweb.joram.mom.notifications package holds the notifications used for interacting with the MOM destination agents. |
org.objectweb.joram.mom.proxies |
The
org.objectweb.joram.mom.proxies package holds the classes implementing the MOM proxy, basically linking external client applications to destination agents. |
org.objectweb.joram.mom.util | |
org.objectweb.joram.shared.client |
The
org.objectweb.joram.shared.client package holds the request and reply objects used in the client-provider interactions. |
org.ow2.joram.mom.amqp |
Modifier and Type | Class and Description |
---|---|
class |
FtpNot |
class |
FtpQueue
The
FtpQueue class implements the MOM queue behaviour,
basically storing messages and delivering them upon clients requests. |
Modifier and Type | Class and Description |
---|---|
class |
SchedulerQueue
This class overrides the default Queue behavior in order to allow timed
deliveries.
|
class |
SchedulerQueueNot
Notification from Scheduler to SchedulerQueue.
|
Modifier and Type | Class and Description |
---|---|
class |
Agent
The
Agent class represents the basic component in our model. |
class |
AgentCreateReply |
class |
AgentCreateRequest
This notification is used to ask aa agent creation to a remote
agent factory.
|
class |
AgentDeleteRequest |
(package private) class |
AgentFactory
Agent used to allow remote agent creation. |
class |
AgentId
An
AgentId allows for uniquely identifying and localizing
an agent throughout the distributed system. |
class |
CallbackNotification
Notification locally transmitting a
CountDownCallback . |
class |
DeleteAck
DeleteAck - Acknowledge for deleting an agent
|
class |
DeleteNot
This notification is used to ask an agent destruction
|
class |
ExceptionNotification
Notify by the engine to the sender of a notification when the corresponding
reaction throws an exception.
|
class |
ExpiredNot
The ExpiredNot holds an expired notification (timeout) which is sent to the
previously specified deadNotificationAgent.
|
class |
FlowControlNot
Deprecated.
|
class |
Message
The internal message structure.
|
class |
Notification
Class Notification is the root of the notifications hierarchy.
|
class |
SyncNotification
This notification is used to synchronously call a
local agent from a collocated thread.
|
class |
UnknownAgent
Notify by the engine to the sender of a notification when the target agent
does not exist.
|
class |
UnknownNotification
Notify by agents when there is no reaction allowed.
|
Modifier and Type | Method and Description |
---|---|
Encodable |
Message.Factory.createEncodable() |
Modifier and Type | Class and Description |
---|---|
class |
EncodableInteger
Encodable object that wraps an integer.
|
class |
EncodedString
Encodable object that wraps a string.
|
class |
EncodedStringList |
class |
SerializableWrapper
Encodable object that wraps a serializable object.
|
class |
StringPair
Encodable object representing a pair of strings.
|
Modifier and Type | Method and Description |
---|---|
Encodable |
StringPair.Factory.createEncodable() |
Encodable |
SerializableWrapper.Factory.createEncodable() |
Encodable |
EncodedStringList.Factory.createEncodable() |
Encodable |
EncodedString.Factory.createEncodable() |
Encodable |
EncodableInteger.Factory.createEncodable() |
Encodable |
EncodableFactory.createEncodable()
Creates an encodable object.
|
Modifier and Type | Class and Description |
---|---|
class |
Properties
This class implements a set of properties, which maps keys to values.
|
Modifier and Type | Class and Description |
---|---|
class |
InitJndiServerNot |
class |
JndiUpdateNot |
class |
SyncReplyNot |
class |
SyncRequestNot |
Modifier and Type | Class and Description |
---|---|
class |
Container |
class |
JndiReplyNot |
class |
JndiScriptReplyNot |
class |
JndiScriptRequestNot |
class |
TcpRequestNot
This notification must only be used inside an agent server.
|
Modifier and Type | Method and Description |
---|---|
private Encodable |
AbstractTransaction.isEncodable(Object object) |
Modifier and Type | Class and Description |
---|---|
class |
AcquisitionNot |
class |
AcquisitionQueue
The
AcquisitionQueue class implements the MOM acquisition queue
behavior, basically acquiring messages periodically or on client request,
using an AcquisitionModule . |
class |
AcquisitionTopic
The
AcquisitionTopic class implements the MOM acquisition topic
behavior, basically acquiring messages periodically or on client request,
using an AcquisitionModule . |
class |
AdminTopic
The
AdminTopic class implements the administration topic
behavior, basically processing administration requests. |
class |
AliasInQueue
The
AliasInQueue class forwards messages to a destination in an other
Joram server using the destination ID. |
class |
AliasQueue
The
AliasQueue class forwards messages to a destination in an other
Joram server using the destination ID. |
class |
ClusterQueue
The
ClusterQueue class implements the cluster queue behavior. |
class |
Destination
The
Destination class implements the common behavior of
MOM destinations. |
class |
DistributionQueue
The
DistributionQueue class implements the MOM distribution queue
behavior, delivering messages via the DistributionModule . |
class |
DistributionTopic
The
DistributionQueue class implements the MOM distribution topic
behavior, delivering messages via the DistributionModule . |
class |
ElasticTopic
Class describing a node of a scalable topic tree.
|
class |
Queue
The
Queue class implements the MOM queue behavior,
basically storing messages and delivering them upon clients requests. |
class |
QueueArrivalState |
class |
QueueDelivery
Class describing a delivered message waiting for acknowledge.
|
class |
QueueDeliveryTable |
class |
Topic
The
Topic class implements the MOM topic behavior,
basically distributing the received messages to subscribers. |
Modifier and Type | Method and Description |
---|---|
Encodable |
QueueDeliveryTable.Factory.createEncodable() |
Encodable |
QueueArrivalState.Factory.createEncodable() |
Encodable |
Queue.QueueFactory.createEncodable() |
Modifier and Type | Class and Description |
---|---|
class |
JMSBridgeAckNot
Deprecated.
|
class |
JMSBridgeDeliveryNot
Deprecated.
|
class |
JMSBridgeQueue
Deprecated.
|
class |
JMSBridgeTopic
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Encodable |
Message.MessageFactory.createEncodable() |
Modifier and Type | Class and Description |
---|---|
class |
AbortReceiveRequest |
class |
AbstractNotification
The
AbstractNotification class is the superclass of the
notifications exchanged by a client agent and a MOM destination agent. |
class |
AbstractReplyNot
An
AbstractReply is a reply sent by a destination agent to
a client agent. |
class |
AbstractRequestNot
An
AbstractRequest is a request sent by a client agent to
a destination agent. |
class |
AcknowledgeRequest
An
AcknowledgeRequest instance is used by a client agent
for acknowledging one or many messages on a queue. |
class |
AdminReplyNot
An
AdminReply is used by a destination agent for replying to
a client administration request. |
class |
AdminRequestNot
An
AdminRequest is used by a client agent for sending an
administration request to a destination agent. |
class |
BrowseReply
A
BrowseReply instance is used by a queue for replying
to a client BrowseRequest by sending a vector of its messages. |
class |
BrowseRequest
A
BrowseRequest instance is used by a client agent for
requesting a "view" of the messages on a queue, without actually consuming
them. |
class |
ClientMessages
A
ClientMessages instance is used by a client agent for
sending one or many messages to a destination. |
class |
ClientSubscriptionNot
Used by ElasticTopic.
|
class |
ClusterJoinAck |
class |
ClusterJoinNot |
class |
ClusterLBNot |
class |
ClusterRemoveNot |
class |
DenyRequest
A
DenyRequest instance is used by a client agent
for denying one or many messages on a queue. |
class |
ExceptionReply
An
ExceptionReply instance is used by a destination for
notifying a client of an exception thrown when processing a request. |
class |
FwdAdminRequestNot
An
AdminRequest is used by a client agent for sending an
administration request to a destination agent. |
class |
GetClientSubscriptions
Used by ElasticTopic.
|
class |
GetProxyIdListNot
Transient notification needed by the HA mode.
|
class |
GetProxyIdNot
Transient notification
|
class |
GetRightsReplyNot
This notification is used by a destination for sending the identifiers of its readers
and writers in response to a GetRightsRequest.
|
class |
GetRightsRequestNot
This request is used for requesting the rights about a destination.
|
class |
LBCycleLife |
class |
LBLoadingFactor |
class |
LBMessageGive |
class |
LBMessageHope |
class |
PingNot
An empty notification, sent to a destination to test whether it is currently
accessible.
|
class |
PongNot
A notification sent in response of a
PingNot . |
class |
QueueDeliveryTimeNot
Notification allowing to trigger delivery of delayed message.
|
class |
QueueMsgReply
A
QueueMsgReply instance is used by a queue for replying to a
ReceiveRequest by sending a message to a client. |
class |
ReceiveRequest
A
ReceiveRequest instance is used by a client agent for
requesting a message on a queue. |
class |
ReconnectSubscribersNot
Used by ElasticTopic
|
class |
RequestGroupNot |
class |
SubscribeReply
A
SubscribeReply instance is used by a topic agent
for acknowledging a SubscribeRequest notification. |
class |
SubscribeRequest
A
SubscribeRequest instance is used by a client agent
for subscribing to a topic. |
class |
TopicDeliveryTimeNot |
class |
TopicForwardNot
A
TopicForwardNot is a notification sent by a topic to
another topic part of the same cluster, or to its hierarchical father,
and holding a forwarded ClientMessages notification. |
class |
TopicMsgsReply
A
TopicMsgsReply instance is used by a topic for sending
messages to an agent client which subscribed to it. |
class |
UnsubscribeRequest
An
UnsubscribeRequest instance is used by a client agent
for unsubscribing to a topic. |
class |
WakeUpNot |
Modifier and Type | Method and Description |
---|---|
Encodable |
TopicForwardNot.Factory.createEncodable() |
Encodable |
ClientMessages.Factory.createEncodable() |
Modifier and Type | Class and Description |
---|---|
class |
AdminNotification
An
AdminNotification is sent during initialization by an
administrator's proxy for registering to the local administration topic. |
class |
ClientContext
The
ClientContext class holds the data related to a client
context. |
class |
ClientSubscription
The
ClientSubscription class holds the data of a client
subscription, and the methods managing the delivery and acknowledgement
of the messages. |
class |
CloseConnectionNot |
class |
CloseConnectionNot2 |
class |
GetConnectionNot |
class |
OpenConnectionNot |
class |
ProxyRequestGroupNot |
class |
RequestNot |
class |
ResetCollocatedConnectionsNot |
class |
ReturnConnectionNot |
class |
SendRepliesNot |
class |
SendReplyNot |
(package private) class |
SyncReply
A
SyncReply is a notification used by a proxy for
synchronizing a reply. |
class |
UserAgent
The
UserAgent class implements the MOM proxy behaviour,
basically forwarding client requests to MOM destinations and MOM
destinations replies to clients. |
class |
UserAgentArrivalState |
(package private) class |
Xid
The
Xid internal class is a utility class representing
a global transaction identifier. |
Modifier and Type | Method and Description |
---|---|
Encodable |
UserAgentArrivalState.UserAgentArrivalStateFactory.createEncodable() |
Encodable |
UserAgent.UserAgentFactory.createEncodable() |
Encodable |
ClientSubscription.ClientSubscriptionFactory.createEncodable() |
Encodable |
ClientContext.ClientContextFactory.createEncodable() |
Modifier and Type | Class and Description |
---|---|
class |
MessageIdListImpl |
class |
SynchronousAgent |
Modifier and Type | Method and Description |
---|---|
Encodable |
MessageIdListImplFactory.createEncodable() |
Encodable |
MessageIdListImpl.MessageIdListImplEncodableFactory.createEncodable() |
Modifier and Type | Class and Description |
---|---|
class |
AbstractJmsMessage
An
AbstractJmsMessage is a message exchanged between a
Joram client and its proxy. |
class |
AbstractJmsReply
An
AbstractJmsReply is sent by a proxy to a Joram client as a
reply to an AbstractJmsRequest . |
class |
AbstractJmsRequest
An
AbstractJmsRequest is a request sent by a Joram client
to its proxy. |
class |
ActivateConsumerRequest |
class |
AddClientIDReply
A
AddClientIDReply replies to a AddClientIDRequest . |
class |
AddClientIDRequest
A
AddClientIDRequest is sent by an setClientID on
Connection . |
class |
CnxCloseReply
A
CnxCloseReply replies to a CnxCloseRequest . |
class |
CnxCloseRequest
A
CnxCloseRequest is sent by a closing SOAP connection. |
class |
CnxConnectReply
A
CnxConnectReply is sent by a JMS proxy as a reply to a
connection CnxConnectRequest and holds the connection's key
and the proxy identifier. |
class |
CnxConnectRequest
A
CnxConnectRequest is sent by an opening
Connection . |
class |
CnxStartRequest
A
CnxStartRequest request is sent by a starting
Connection . |
class |
CnxStopRequest
A
CnxStopRequest is sent by a stopping Connection . |
class |
CommitRequest |
class |
ConsumerAckRequest
A
ConsumerAckRequest instance is used by a
MessageConsumer for acknowledging a received message. |
class |
ConsumerCloseSubRequest
A
ConsumerCloseSubRequest is sent by a closing durable
TopicSubscriber . |
class |
ConsumerDenyRequest
A
ConsumerDenyRequest instance is used by a
MessageConsumer for denying a received message. |
class |
ConsumerMessages
A
ConsumerMessages is used by a JMS proxy for sending messages
to a consumer. |
class |
ConsumerReceiveRequest
A
ConsumerReceiveRequest is sent by a
MessageConsumer when requesting a message. |
class |
ConsumerSetListRequest
A
ConsumerSetListRequest is sent by a
MessageConsumer on which a message listener is set. |
class |
ConsumerSubRequest
A
ConsumerSubRequest is sent by a constructing
MessageConsumer destinated to consume messages on a topic. |
class |
ConsumerUnsetListRequest
A
ConsumerUnsetListRequest is sent by a
MessageConsumer which listener is unset. |
class |
ConsumerUnsubRequest
A
ConsumerUnsubRequest is sent by a closing temporary
MessageConsumer on a topic, or by a Session
unsubscribing a durable subscriber. |
class |
GetAdminTopicReply
A
GetAdminTopicReply is sent by an administrator proxy for
notifying an administrator client of the identifier of the local admin
topic. |
class |
GetAdminTopicRequest
A
GetAdminTopicRequest is sent by a session for retrieving
the identifier of the local admin topic. |
class |
JmsRequestGroup |
class |
MomExceptionReply
A
MomExceptionReply instance is used by a JMS client proxy
to send a MomException back to a JMS client. |
class |
PingRequest |
class |
ProducerMessages
A
ProducerMessages instance is sent by a
MessageProducer when sending messages. |
class |
QBrowseReply
A
QBrowseReply instance is used by a JMS client proxy for
forwarding a BrowseReply destination notification,
actually replying to a client QBrowseRequest . |
class |
QBrowseRequest
A
QBrowseRequest instance is sent by a
QueueBrowser when requesting an enumeration. |
class |
ServerReply
A
ServerReply is used by a JMS proxy for
acknowledging the receipt of a synchronous AbstractJmsRequest
request. |
class |
SessAckRequest
A
SessAckRequest instance is used by a Session
for acknowledging the messages it consumed. |
class |
SessCreateDestReply
A
SessCreateTDReply is used by a JMS proxy for replying
to a SessCreate<TQ/TT>Request . |
class |
SessCreateDestRequest
A
SessCreateDestRequest is sent by a Session
for creating a destination. |
class |
SessDenyRequest
A
SessDenyRequest instance is used by a Session
for denying the messages it consumed. |
class |
TempDestDeleteRequest
A
TempDestDeleteRequest instance is sent by a
deleting temporary destination. |
class |
XACnxCommit
An
XACnxCommit instance is used by an XAConnection
for commiting the messages and acknowledgements it sent to the proxy. |
class |
XACnxPrepare
An
XACnxPrepare instance is used by an
XAConnection for sending messages and acknowledgements to
the proxy. |
class |
XACnxRecoverReply
A
XACnxRecoverReply replies to a
XACnxRecoverRequest and carries transaction identifiers. |
class |
XACnxRecoverRequest
A
XACnxRecoverRequest instance is used by an
XACnxion for recovering the identifiers of the TM's
prepared transactions. |
class |
XACnxRollback
An
XACnxRollback instance is used by an
XAConnection for rolling back the operations performed
during a transaction. |
Modifier and Type | Class and Description |
---|---|
class |
AMQPAgent
An
AMQPAgent is responsible of the communications with other Joram
AMQP servers. |
class |
AMQPRequestNot
Notification used to make a request to another Joram AMQP server.
|
class |
AMQPResponseNot
Notification used to answer a request coming from another Joram AMQP server.
|
class |
RestartNot
Notification used to tell other Joram AMQP servers that a server has
restarted.
|
Copyright © 2023 ScalAgent D.T.. All rights reserved.