Defines XML syntactic element for A3CML configuration file.
The class A3CMLDomain
describes an agent server domain.
A3CML XML parser using kxml.
The class A3CMLNat
describes a
network address translation.
The class A3CMLNetwork
describes a network component.
The class A3CMLProperty
describes a property.
The class PServer
describes a persistent agent server.
XML SAX Wrapper for A3 configuration file.
The class Server
describes an agent server.
The class A3CMLService
describes a service.
XML Wrapper interface for A3CML configuration file.
An AbstractJmsReply
is sent by a proxy to a Joram client as a
reply to an AbstractJmsRequest
.
Constructs an AbstractJmsReply
.
Constructs an AbstractJmsReply
.
An AbstractJmsRequest
is a request sent by a Joram client
to its proxy.
Constructs an AbstractJmsRequest
.
Constructs an AbstractJmsRequest
.
The AbstractNotification
class is the superclass of the
notifications exchanged by a client agent and a MOM destination agent.
Constructs an AbstractNotification
.
Constructs an AbstractNotification
.
An AbstractReply
is a reply sent by a destination agent to
a client agent.
Constructs an AbstractReply
.
Constructs an AbstractReply
.
An AbstractRequest
is a request sent by a client agent to
a destination agent.
Constructs an AbstractRequest
.
Constructs an AbstractRequest
.
An AccessException
is thrown by a destination when processing
a request of a client which does not have valid rights for this request.
Constructs an AccessException
instance.
Acknowledges a message successfuly delivered to the foreign JMS server.
An AcknowledgeRequest
instance is used by a client agent
for acknowledging one or many messages on a queue.
Constructs an AcknowledgeRequest
instance.
Constructs an AcknowledgeRequest
instance.
The number of acknowledgements a message still expects from its
subscribers before having been fully consumed by them (field used
by JMS proxies).
Instance of action encapsulation class.
Instance of action encapsulation class.
Access to parse-action table.
Access to parse-action table.
Period of time between two activation of NetServerOut, it matchs to the
time between two requests from the client to the server when there is no
message to transmit from client to server.
An ActivationSpecImpl
instance holds configuration information
related to an endpoint deployment.
Constructs an ActivationSpecImpl
instance.
Adds a vector of denied messages' identifiers.
Adds a connection event listener.
Adds a dead message queue identifier to the reply.
Adds an agent in the listeners list.
Adds a message to deliver.
Adds a message to deliver.
Adds messages to deliver.
Adds a queue identifier to the reply.
send to joiningQueue a JoinQueueCluster not.
Adds a queue to a cluster.
Adds a new environment property to the environment of this
context.
Adds a topic identifier to the reply.
Adds a user to the table.
AdminAckStartStopNot is a notification.
The AdminDestinationItf
interface defines the method needed
by the administration topic for creating and initializing a destination
agent.
An AdminException
is an exception thrown by an administration
method.
Constructs an AdminException
instance.
The AdminHelper
class is a utility class providing methods
for building special configurations such as topics cluster or hierarchy,
queues cluster, etc.
Identifier of the destination's administrator.
Reserved stamp for admin AgentId
.
The AdministeredObject
class is the parent class of all
JORAM administered objects.
Constructs an empty administered object.
Constructs an administered object.
The AdminModule
class allows to set an administrator
connection to a given JORAM server, and provides administration and
monitoring methods at a server/platform level.
Name given by the administrator.
An AdminNotification
is sent by an administrator's proxy for
registering to the local administration topic.
A AdminProxy
service provides an interface to access
to administration functions in running agent servers.
An AdminReply
is used by a destination agent for replying to
a client administration request.
An AdminReply
is a reply sent by a
org.objectweb.joram.mom.dest.AdminTopic
topic and containing data or
information destinated to a client administrator.
Constructs an AdminReply
instance.
Constructs an AdminReply
instance.
Constructs an AdminReply
.
Constructs an AdminReply
.
AdminReplyNot is a notification.
An AdminRequest
is used by a client agent for sending an
administration request to a destination agent.
An AdminRequest
is a request sent by a client administrator
inside a org.objectweb.joram.shared.messages.Message
to an
org.objectweb.joram.mom.dest.AdminTopic
topic for requesting an
admin operation.
Constructs an AdminRequest
.
AdminRequestNot is a notification to
configure A3CMLConfig.
AdminStartStopNot is a notification to
start and stop networks, servers persitents,
servers transients and services.
An AdminTopic
agent is a MOM administration service, which
behaviour is provided by an AdminTopicImpl
instance.
Constructs an AdminTopic
agent.
The AdminTopicImpl
class implements the admin topic behaviour,
basically processing administration requests.
Constructs an AdminTopicImpl
instance.
The Agent
class represents the basic component in our model.
The non-existent target agent id.
Allocates a new Agent object.
Allocates a new Agent object.
Allocates a new Agent object.
Allocates a new Agent object.
Allocates a new Agent object.
Allocates a new Agent object.
Allocates a new Agent object.
Allocates a new Agent object.
Constructor used to build Well Known Services agents.
Creates a local administration agent.
This notification is used to ask aa agent creation to a remote
agent factory.
Thrown by the Agentfactory
when an error is
raised during the initialization.
Called to inform this agent that it is garbaged and that it should free
any active ressources that it has allocated.
Called to inform this agent that it is garbaged and that it should free
any active ressources that it has allocated.
Finalizes this proxy agent execution.
Identifier of the agent using this module.
Identifier of the agent destination.
An AgentId
allows for uniquely identifying and localizing
an agent throughout the distributed system.
Allocates a new AgentId
object.
Gives this agent an opportunity to initialize after having been deployed,
and each time it is loaded into memory.
Gives this agent an opportunity to initialize after having been deployed,
and each time it is loaded into memory.
Gives this agent an opportunity to initialize after having been deployed,
and each time it is loaded into memory.
Gives this agent an opportunity to initialize after having been deployed,
and each time it is loaded into memory.
Initializes the transient members of this agent.
(Re)initializes the agent when (re)loading.
The AgentObject
class represents ...
The AgentServer
class manages the global configuration
of an agent server.
Returns a javax.jms.Connection
connection instance for
a non managed application.
Internal boolean used for tagging local sendings.
AND - static field in class org.objectweb.joram.shared.selectors.
sym This class contains various methods for sorting and searching int arrays.
Counter of messages arrivals.
Hashtable that contain all Process
of running AgentServer
Dissociates a given connection handle and associates it to this
managed connection.
used to start script in a same reaction.
Returns true
if the destination might be deleted.
Cancels the timer and all its non executed tasks.
Cancels this task by removing it from the timer's tasks list, and
interrupting the timer thread if necessary.
Boolean variable used to stop the daemon properly.
Class Channel
realizes the interface for sending messages.
Constructs a new Channel
object (can only be used by
subclasses).
CUP v0.10j generated parser.
Constructor which sets the default scanner.
Clients call this method to check a selector syntax.
Checks the validity of the subscriber instance.
Checks the validity of the subscriber instance.
Method cleaning DriverOut.
Method cleaning the DriverOut
specified
by the key parameter (multi-connections mode).
Invalidates the created handles and prepares the physical connection
to be put back into a connection pool.
Method clearing the message body.
Empties the properties table.
A ClientMessages
instance is used by a client agent for
sending one or many messages to a destination.
Constructs a ClientMessages
instance.
Constructs a ClientMessages
instance.
Constructs a ClientMessages
instance.
Table of the destination readers and writers.
Returns a clone of this notification.
Interrupts the daemons and closes the connection.
Releases the daemon's resources.
Releases the daemon's resources.
Releases the daemon's resources.
API method for closing the connection; even if the connection appears
to be broken, closes the sessions.
Releases any resources attached to this daemon.
Releases the driver's resources.
Requests to close the physical connection.
Delegates the call to the wrapped JMS consumer.
Delegates the call to the wrapped producer.
Actually does nothing, closing of the session occurs while closing
the component's connection.
Closes the TCP connection.
Releases any resources attached to this daemon.
Releases any resources attached to this daemon.
API method inherited from session, but intercepted here for
adapting its behaviour to the XA context.
Closes all the connections.
true
if the consumer is closed.
true
if the producer is closed.
Constructs an empty cluster destination.
Constructs a cluster destination.
A ClusterQueue
agent is an agent hosting a MOM queue, and which
behaviour is provided by a ClusterQueueImpl
instance.
Constructs an empty queue.
Empty constructor for newInstance().
Constructs a cluster queue.
reference to clusterQueueImpl
The ClusterQueueImpl
class implements the MOM queue behaviour,
basically storing messages and delivering them upon clients requests or
delivering to an other cluster queue.
Constructs a ClusterQueueImpl
instance.
A ClusterRequest
instance is used by a client agent
for notifying a topic of the identifier of an other topic to set a
cluster with.
Constructs a ClusterRequest
instance.
key = agentId of ClusterQueue
value = rateOfFlow (Float)
Connection to the foreign JMS server.
The OutboundConnection
the session belongs to.
A CnxCloseReply
replies to a CnxCloseRequest
.
Constructs a CnxCloseReply
instance.
A CnxCloseRequest
is sent by a closing SOAP connection.
Constructs a CnxCloseRequest
instance.
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.
Constructs a CnxConnectReply
.
Constructs a CnxConnectReply
.
A CnxConnectRequest
is sent by an opening
Connection
.
Constructs a CnxConnectRequest
.
returns true
if the
parameter is a Connection
instance sharing the same
proxy identifier and connection key.
Connection factory object for connecting to the foreign JMS server.
ConnectionFactory JNDI name.
Period in milliseconds between two ping requests sent by the client
connection to the server; if the server does not receive any ping
request during more than 2 * cnxPendingTimer, the connection is
considered as dead and processed as required.
Period in milliseconds between two ping requests sent by the client
connection to the server; if the server does not receive any ping
request during more than 2 * cnxPendingTimer, the connection is
considered as dead and processed as required.
Period in milliseconds between two ping requests sent by the client
connection to the server; if the server does not receive any ping
request during more than 2 * cnxPendingTimer, the connection is
considered as dead and processed as required.
A CnxStartRequest
request is sent by a starting
Connection
.
Constructs a CnxStartRequest
instance.
A CnxStopRequest
is sent by a stopping Connection
.
Constructs a CnxStopRequest
instance.
Codes an AdministeredObject
as a Hashtable for travelling
through the SOAP protocol.
Codes a ClusterDestination
as a Hashtable for
travelling through the SOAP protocol.
Codes a ConnectionFactory
as a Hashtable for travelling
through the SOAP protocol.
Codes a Destination
as a Hashtable for travelling through the
SOAP protocol.
Method coding the SoapObjectItf
object into a Hashtable
transportable by the SOAP procotol.
code() - method in class org.objectweb.joram.client.jms.admin.
User Codes an User
instance as a Hashtable for travelling
through the SOAP protocol.
Codes an XAConnectionFactory
as a Hashtable for travelling
through the SOAP protocol.
Opens a connection with the collocated JORAM server.
Returns the name of the queue or the subscription the messages come
from.
COMMA - static field in class org.objectweb.joram.shared.selectors.
sym Commits the local transaction.
Commits the registered savings and deletions.
Forbidden call on a component's outbound session, throws a
IllegalStateException
instance.
API method inherited from session, but intercepted here for
forbidding its use in the XA context (as defined by the API).
Composes the name of this context with a name relative to
this context.
Composes the name of this context with a name relative to
this context: Not supported.
Adapts the current configuration to the specified persistent server.
Launches the connection process to the foreign JMS server.
Initializes the connection with the outside, up to creating
the input and output streams ois
and oos
.
Opens a connection dedicated to administering with the Joram server
which parameters are wrapped by a given
TopicConnectionFactory
.
Opens a TCP connection with the Joram server running on a given host and
listening to a given port.
Opens a TCP connection with the Joram server running on the default
"locahost" host and listening to the default 16010 port.
Duration in seconds during which connecting is attempted (connecting
might take time if the server is temporarily not reachable); the 0 value
is set for connecting only once and aborting if connecting failed.
Duration in seconds during which connecting is attempted (connecting
might take time if the server is temporarily not reachable); the 0 value
is set for connecting only once and aborting if connecting failed.
Duration in seconds during which connecting is attempted (connecting
might take time if the server is temporarily not reachable); the 0 value
is set for connecting only once and aborting if connecting failed.
Implements the javax.jms.Connection
interface.
Creates a Connection
instance.
Implements the javax.jms.ConnectionConsumer
interface.
Implements the javax.jms.ConnectionFactory
interface.
Constructs an empty ConnectionFactory
.
Constructs a ConnectionFactory
dedicated to a given server.
The ConnectionItf
interface defines the methods provided to
Connection
objects for actually exchanging requests and
replies with the Joram platform.
A ConnectionManager
is started as a service in each
MOM agent server for allowing connections with external clients.
Implements the javax.jms.ConnectionMetaData
interface.
A ConnectionRequest
instance wraps a user connection
request for performing unified messaging.
Constructs a ConnectionRequest
instance.
A ConsumerAckRequest
instance is used by a
MessageConsumer
for acknowledging a received message.
Constructs a ConsumerAckRequest
instance.
Constructs a ConsumerAckRequest
instance.
A ConsumerCloseSubRequest
is sent by a closing durable
TopicSubscriber
.
Constructs a ConsumerCloseSubRequest
.
Constructs a ConsumerCloseSubRequest
.
The ConsumerDaemon
thread allows to call
MessageConsumer.receive()
for requesting a foreign JMS
message without blocking the JORAM server.
Constructs a ReceiverDaemon
thread.
A ConsumerDenyRequest
instance is used by a
MessageConsumer
for denying a received message.
Constructs a ConsumerDenyRequest
instance.
Constructs a ConsumerDenyRequest
instance.
Constructs a ConsumerDenyRequest
instance.
A ConsumerMessages
is used by a JMS proxy for sending messages
to a consumer.
Constructs an empty ConsumerMessages
instance.
Constructs a ConsumerMessages
instance.
Constructs an empty ConsumerMessages
instance.
Constructs a ConsumerMessages
instance.
A ConsumerReceiveRequest
is sent by a
MessageConsumer
when requesting a message.
Constructs a ConsumerReceiveRequest
.
Constructs a ConsumerReceiveRequest
.
Table keeping the messages' consumers identifiers.
Session for getting messages from the foreign JMS destination.
A ConsumerSetListRequest
is sent by a
MessageConsumer
on which a message listener is set.
Constructs a ConsumerSetListRequest
.
Constructs a ConsumerSetListRequest
.
A ConsumerSubRequest
is sent by a constructing
MessageConsumer
destinated to consume messages on a topic.
Constructs a ConsumerSubRequest
.
Constructs a ConsumerSubRequest
.
A ConsumerUnsetListRequest
is sent by a
MessageConsumer
which listener is unset.
Constructs a ConsumerUnsetListRequest
.
Constructs a ConsumerUnsetListRequest
.
A ConsumerUnsubRequest
is sent by a closing temporary
MessageConsumer
on a topic, or by a Session
unsubscribing a durable subscriber.
Constructs a ConsumerUnsubRequest
.
Constructs a ConsumerUnsubRequest
.
This agent cannot be swapped and has
a reserved identifier on each agent server.
Tests if the specified agent id belongs to
role multiple.
Returns true if it exists a domain with this name, false otherwise.
Returns true if the configuration contains a server with specified id.
Returns true if the configuration contains a server with specified name.
Table keeping the messages' consumers contexts.
Reserved stamp for JMS topic AgentId
in charge ofsending control events.
The ConversionHelper
class is used for converting values
carried by messages into specified types, if possible.
Converts a standard JMS message into an
org.objectweb.joram.mom.shared.messages.Message
instance.
Converts a JORAM MOM message into a JMS message.
Returns copies of the naming contexts owned by the server
which identifier is specified.
Identifier of the replied request.
Stops violently an agent server from its id.
Stops violently an agent server from its id.
Stops violently an agent server from its id.
Admin method creating and deploying a dead message queue on the
local server.
Admin method creating a javax.jms.ConnectionFactory
instance for creating local connections.
create() - static method in class org.objectweb.joram.client.jms.
Queue Admin method creating and deploying a queue on the local server.
Admin method creating a javax.jms.QueueConnectionFactory
instance for creating local connections.
Admin method creating a javax.jms.QueueConnectionFactory
instance for creating TCP connections with the local server.
Admin method creating a javax.jms.ConnectionFactory
instance for creating TCP connections with the local server.
create() - static method in class org.objectweb.joram.client.jms.
Topic Admin method creating and deploying a topic on the local server.
Admin method creating a javax.jms.TopicConnectionFactory
instance for creating local connections.
Admin method creating a javax.jms.TopicConnectionFactory
instance for creating TCP connections with the local server.
Admin method creating a javax.jms.XAConnectionFactory
instance for creating local connections.
Admin method creating a javax.jms.XAQueueConnectionFactory
instance for creating local connections.
Admin method creating a javax.jms.XAQueueConnectionFactory
instance for creating TCP connections with the local server.
Admin method creating a javax.jms.XAConnectionFactory
instance for creating TCP connections with the local server.
Admin method creating a javax.jms.XATopicConnectionFactory
instance for creating local connections.
Admin method creating a javax.jms.XATopicConnectionFactory
instance for creating TCP connections with the local server.
Admin method creating and deploying a dead message queue on a given
server.
Admin method creating and deploying a queue on a given server.
Admin method creating and deploying a topic on a given server.
Admin method creating and deploying a queue on a given server.
Admin method creating and deploying a topic on a given server.
Admin method creating and deploying (or retrieving) a queue on a given
server with a given name.
Admin method creating and deploying (or retrieving) a topic on a given
server with a given name.
Admin method creating and deploying a queue on a given server.
Admin method creating and deploying a topic on a given server.
Admin method creating and deploying (or retrieving) a queue on a given
server.
Admin method creating and deploying (or retrieving) a topic on a given
server.
Admin method creating and deploying (or retrieving) a queue on the
local server.
Admin method creating and deploying (or retrieving) a topic on the
local server.
Admin method creating a javax.jms.QueueConnectionFactory
instance for creating TCP connections with a given server.
Admin method creating a javax.jms.ConnectionFactory
instance for creating TCP connections with a given server.
Admin method creating a javax.jms.TopicConnectionFactory
instance for creating TCP connections with a given server.
Admin method creating a javax.jms.XAQueueConnectionFactory
instance for creating TCP connections with a given server.
Admin method creating a javax.jms.XAConnectionFactory
instance for creating TCP connections with a given server.
Admin method creating a javax.jms.XATopicConnectionFactory
instance for creating TCP connections with a given server.
Admin method creating a user on the local server and instanciating the
corresponding User
object.
Admin method creating a user for a given server and instanciating the
corresponding User
object.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Requests a connection for the default user, eventually returns an
OutboundConnection
instance.
Method inherited from interface ConnectionFactory
.
Method inherited from interface ConnectionFactory
.
API method, implemented according to the communication protocol.
Method inherited from the ConnectionFactory
class.
Requests a connection for a given user, eventually returns an
OutboundConnection
instance.
Method inherited from the ConnectionFactory
class.
Method inherited from the ConnectionFactory
class.
Method inherited from the ConnectionFactory
class.
Method inherited from the ConnectionFactory
class.
Method inherited from the ConnectionFactory
class.
Method inherited from interface ConnectionFactory
,
implemented according to the communication protocol..
Method inherited from the ConnectionFactory
class.
Method inherited from the ConnectionFactory
class.
Method inherited from interface ConnectionFactory
,
implemented according to the communication protocol..
Method inherited from the ConnectionFactory
class.
Method inherited from the ConnectionFactory
class.
Forbidden call on an application or component's outbound connection,
throws a IllegalStateException
instance.
Forbidden call on an application or component's outbound connection,
throws a IllegalStateException
instance.
Forbidden call on an application or component's outbound connection,
throws a IllegalStateException
instance.
Method called in the non managed case for creating an
OutboundConnectionFactory
instance.
Method called in the non managed case for creating an
OutboundQueueConnectionFactory
instance.
Method called in the non managed case for creating an
OutboundTopicConnectionFactory
instance.
Method called by an application server (managed case) for creating an
OutboundConnectionFactory
instance.
Method called by an application server (managed case) for creating an
OutboundQueueConnectionFactory
instance.
Method called by an application server (managed case) for creating an
OutboundTopicConnectionFactory
instance.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
A CreateDestinationReply
instance replies to a
destination creation request, produced by the AdminTopic.
Constructs a CreateDestinationReply
instance.
A CreateDestinationRequest
instance requests the creation of a
destination on a given server.
Constructs a CreateDestinationRequest
instance.
Constructs a CreateDestinationRequest
instance.
Creates a driver for providing the connection with server's replies.
Creates a driver for the connection.
Forbidden call on an application or component's outbound connection,
throws a IllegalStateException
instance.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Creates a new physical connection to the underlying JORAM server,
and returns a ManagedConnectionImpl
instance for a
managed environment.
Creates a new PTP physical connection to the underlying JORAM server,
and returns a ManagedConnectionImpl
instance for a
managed environment.
Creates a new PubSub physical connection to the underlying JORAM server,
and returns a ManagedConnectionImpl
instance for a
managed environment.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Requests a PTP connection for the default user, eventually returns an
OutboundQueueConnection
instance.
Method inherited from interface QueueConnectionFactory
.
Requests a PTP connection for a given user, eventually returns an
OutboundConnection
instance.
API method, implemented according to the communication protocol.
Method inherited from the QueueConnectionFactory
class.
Method inherited from the QueueConnectionFactory
class.
Method inherited from interface QueueConnectionFactory
,
implemented according to the communication protocol.
Method inherited from the QueueConnectionFactory
class.
Method inherited from the QueueConnectionFactory
class.
Returns the unique authorized JMS session per connection wrapped in
an OutboundQueueSession
instance.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Returns the unique authorized JMS session per connection wrapped
in an OutboundSession
instance.
Creates a non-XA session.
Method inherited from interface XAConnection
.
Method inherited from interface XAConnection
.
Creates the bridge queue.
Creates the bridge topic.
Creates the dead message queue.
Creates the specific implementation.
Delegates the call to the wrapped JMS session.
Creates and binds a new context.
Creates and binds a new context.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Delegates the call to the wrapped JMS session.
Requests a PubSub connection for the default user, eventually returns an
OutboundTopicConnection
instance.
Method inherited from interface TopicConnectionFactory
.
Requests a PubSub connection for a given user, eventually returns an
OutboundConnection
instance.
API method, implemented according to the communication protocol.
Method inherited from the TopicConnectionFactory
class.
Method inherited from the TopicConnectionFactory
class.
Method inherited from interface TopicConnectionFactory
,
implemented according to the communication protocol.
Method inherited from the TopicConnectionFactory
class.
Method inherited from the TopicConnectionFactory
class.
Returns the unique authorized JMS session per connection wrapped in
an OutboundTopicSession
instance.
A CreateUserReply
instance replies to a user creation request,
produced by the AdminTopic.
Constructs a CreateUserReply
instance.
A CreateUserRequest
instance requests the creation of a JMS
user proxy.
Constructs a CreateUserRequest
instance.
API method, implemented according to the communication protocol.
Method inherited from the XAConnectionFactory
class.
Method inherited from the XAConnectionFactory
class.
Method inherited from the XAConnectionFactory
class.
Method inherited from the XAConnectionFactory
class.
Method inherited from the XAConnectionFactory
class.
Method inherited from the XAConnectionFactory
class.
API method, implemented according to the communication protocol.
Method inherited from the XAQueueConnectionFactory
class.
Method inherited from the XAQueueConnectionFactory
class.
Method inherited from interface XAConnection
.
Method inherited from interface XAConnection
.
API method, implemented according to the communication protocol..
Method inherited from the XATopicConnectionFactory
class..
Method inherited from the XATopicConnectionFactory
class..
Manager for connection pooling.
The Daemon class represents a basic active component in a server.
Allocates a new Daemon object.
Allocates a new Daemon object.
Logger used to trace joram admin activity, to be set using topic
org.objectweb.joram.client.jms.Admin
Logger used to trace joram activity, to be set using topic
org.objectweb.joram.client.jms.Client
Logger used to trace destinations activity, to be set using topic
org.objectweb.joram.shared.Destination
Logger used to trace proxies activity, to be set using topic
org.objectweb.joram.shared.Proxy
The DeadMQueue
class allows administrators to manipulate
dead message queues.
A DeadMQueue
agent is an agent hosting a MOM dead message
queue, and which behaviour is provided by a DeadMQueueImpl
instance.
Empty constructor for newInstance().
Constructs a DeadMQueue
agent.
Constructs a DeadMQueue
instance.
Constructs a DeadMQueue
instance.
The DeadMQueueImpl
class implements the MOM dead message queue
behaviour, basically storing dead messages and delivering them upon clients
requests.
Constructs a DeadMQueueImpl
instance.
debug - static field in class fr.dyade.aaa.util.
Debug flag used to remove huge logging
This class controls the debug traces printed to the audit file.
This class handles the debug traces.
Property name for A3 debug configuration directory.
Property name for A3 debug configuration filename
Decodes a Queue
which traveled through the SOAP protocol.
Implements the decode
abstract method defined in the
fr.dyade.aaa.jndi2.soap.SoapObjectItf
interface.
Decodes a Queue
which traveled through the SOAP protocol.
Initializes a SoapObjectItf
object given a coded Hashtable.
Decodes a TemporaryQueue
which traveled through the
SOAP protocol.
Decodes a TemporaryTopic
which traveled through the
SOAP protocol.
Decodes a Topic
which traveled through the SOAP protocol.
Decodes an User
which travelled through the SOAP protocol.
Implements the decode
abstract method defined in the
fr.dyade.aaa.jndi2.soap.SoapObjectItf
interface.
Default filename for A3 debug configuration
The DefaultConnectionManager
class is the default connection
manager provided with JORAM resource adapter, which intercepts connections
requests coming from non managed client applications.
Creates a DefaultConnectionManager
instance.
Permits this agent to destroy it.
Permits this agent to destroy it.
Admin method removing this destination from the platform.
Deletes the component, removes all persistent datas.
This operation always throws an IllegalStateException.
delete() - method in class org.objectweb.joram.client.jms.admin.
User Removes this user.
Permits this agent to destroy it.
Registers a message for future deletion.
DeleteAck - Acknowledge for deleting an agent
Deletes all persisted objects.
true
if the message target destination is deleted.
A DeleteDestination
instance requests the deletion of
a given destination.
Constructs a DeleteDestination
instance.
This notification is used to ask aaa agent destruction
This method deletes the proxy by notifying its connected clients,
denying the non acknowledged messages, deleting the temporary
destinations, removing the subscriptions.
A DeleteUser
instance requests the deletion of a user proxy
on a given server.
Constructs a DeleteUser
instance.
Try to deliver the received message to the right consumer.
Table holding the delivered messages before acknowledgement.
Overrides this QueueImpl
method; delivered messages are not
kept for acknowledgement or denying; validity of messages is
not checked and message fields are not updated; also, no sending to
any DMQ.
Actually tries to answer the pending "receive" requests.
The number of delivery attempts for this message.
denied - field in class org.objectweb.joram.shared.messages.
Message true
if the message has been denied at least once by a
consumer.
A DenyRequest
instance is used by a client agent
for denying one or many messages on a queue.
Constructs an DenyRequest
instance.
Constructs an DenyRequest
instance.
Constructs an DenyRequest
instance.
Foreign JMS destination object.
The destination the consumer gets its messages from.
The destination the producer sends messages to.
Identifier of the agent hosting the destination.
The reference of the DestinationImpl
instance providing this
this agent with its Destination behaviour.
Implements the javax.jms.Destination
interface and provides
JORAM specific administration and monitoring methods.
A Destination
agent is an agent hosting a MOM destination,
for example a Queue or a Topic.
Constructs an empty destination.
Empty constructor for newInstance().
Constructor with parameters for fixing the destination.
Constructs a Destination
agent.
Constructs a destination.
Constructor with parameters for fixing the destination and specifying its
identifier.
Constructs a destination.
A DestinationException
is thrown by a destination while
deleting if requesters are still active, and in a proxy method when trying
to access a non existing destination.
Constructs a DestinationException
instance.
The DestinationImpl
class implements the common behaviour of
MOM destinations.
Constructs a DestinationImpl
.
Destroys the physical connection to the underlying JORAM server.
Kill an agent server and remove it from the ASP table.
Destroys the named context and removes it from the namespace.
Destroys the named context and removes it from the namespace.
Closes the administration connection.
Closes the connection with the outside.
Class of a JNDI server that belongs to a distributed JNDI
configuration.
DIVIDE - static field in class org.objectweb.joram.shared.selectors.
sym Identifier of the dead message queue this destination must send its
dead messages to, if any.
Invoke a user supplied parse action.
Invoke a user supplied parse action.
Opens a connection with the foreign JMS server and creates the
JMS PTP resources for interacting with the foreign JMS queue.
Opens a connection with the foreign JMS server and creates the
JMS Pub/Sub resources for interacting with the foreign JMS topic.
Opens a connection with the foreign JMS server and creates the
JMS resources for interacting with the foreign JMS destination.
Admin method creating or retrieving a destination with a given name on a
given server, and returning its identifier.
return the cluster list (vector).
Domain (1st hop) used to access this server from current node.
Method specifically processing a
fr.dyade.aaa.agent.DeleteNot
instance.
Method specifically processing a
fr.dyade.aaa.agent.DeleteNot
instance.
Method specifically processing a
fr.dyade.aaa.agent.DeleteNot
instance.
Method specifically processing a
fr.dyade.aaa.agent.DeleteNot
instance.
Specializes this TopicImpl
reaction.
Overrides this QueueImpl
method; if the sent notification
was a QueueMsgReply
instance, putting the sent message back
in queue.
Method specifically processing an UnknownAgent
instance.
Method specifically processing an UnknownAgent
instance.
Method specializing the processing of a ClientMessages
instance.
Method specializing the reaction to a ClientMessages
instance.
overload doProcess(ClientMessages)
store all msgId in timeTable and visitTable,
store message and deliver message if consumer
wait.
Method specifically processing a ClientMessages
instance.
Method specifically processing a ClientMessages
instance.
propagate right to all cluster.
Method specifically processing a SetRightRequest
instance.
Method specifically processing a SetRightRequest
instance.
Overrides this DestinationImpl
method; deletion requests are
not accepted by AdminTopics.
Method implementing the reaction to a DeleteNot
notification requesting the deletion of the destination.
Method implementing the reaction to an UnknownAgent
notification.
Method implementing the reaction to a AdminRequest
notification notifying of the creation of an admin proxy.
Overrides this TopicImpl
method; a ClusterAck
is not expected by an AdminTopic.
Method implementing the reaction to a ClusterAck
notification sent by a topic requested to join the cluster.
Overrides this TopicImpl
method; if this AdminTopic is on
server0, new cluster fellow is notified to other fellows and other
fellows are notified to it.
Method implementing the reaction to a ClusterNot
notification sent by a fellow topic for notifying this topic
of a new cluster fellow.
Overrides this TopicImpl
method; AdminTopics do not
accept to join clusters other than their admin topics cluster.
Method implementing the reaction to a ClusterTest
notification sent by a fellow topic for testing if this topic might be
part of a cluster.
Overrides this TopicImpl
method; a FatherAck
acknowledges the process of creating a hierarchy of topics.
Method reacting to a FatherAck
notification coming from
the topic this topic requested as a father.
Overrides this TopicImpl
method; AdminTopics do not
accept to join a hierarchy.
Method reacting to a FatherTest
notification checking if it
can be a father to a topic.
Overrides this TopicImpl
method; the forwarded messages
contain admin requests and will be processed.
Method specializing the reaction to a TopicForwardNot
instance, carrying messages forwarded by a cluster fellow or a
hierarchical son.
Method implementing the reaction to a TopicForwardNot
instance, carrying messages forwarded by a cluster fellow or a
hierarchical son.
Method implementing the reaction to an UnclusterNot
notification sent by a topic leaving the cluster.
Overrides this QueueImpl
method;
AcknowledgeRequest
requests are actually not processed
in dead message queues.
Method implementing the reaction to an AcknowledgeRequest
instance, requesting messages to be acknowledged.
Method implementing the reaction to a
org.objectweb.joram.mom.notifications.AdminReply
notification replying to an administration request.
Overrides this QueueImpl
method; messages matching the
request's selector are actually sent as a reply; no cleaning nor DMQ
sending is done.
Method implementing the queue reaction to a BrowseRequest
instance, requesting an enumeration of the messages on the queue.
Overrides this DestinationImpl
method;
ClientMessages
notifications hold requests sent by an
administrator.
Overrides this DestinationImpl
method; the messages carried
by the ClientMessages
instance are stored in their arrival
order, WRITE right is not checked.
Method implementing the reaction to a ClientMessages
notification holding messages sent by a client.
Overrides this TopicImpl
method; AdminTopics do not
accept ClusterRequest
notifications.
Method implementing the reaction to a ClusterRequest
instance requesting to add a topic to the cluster, or to set a
cluster with a given topic.
Overrides this QueueImpl
method;
DenyRequest
requests are actually not processed
in dead message queues.
Method implementing the reaction to a DenyRequest
instance, requesting messages to be denied.
The messages are not consumed by an other cluster's queue
in a periode time, try to consume in this queue.
load balancing message give by an other cluster queue.
load balancing message hope by the "from" queue.
Method implementing the reaction to a Monit_FreeAccess
notification requesting the free access status of this destination.
Method implementing the reaction to a Monit_GetCluster
notification requesting the identifiers of the cluster's topics.
Method implementing the reaction to a Monit_GetDMQSettings
notification requesting the destination's DMQ settings.
Overrides this DestinationImpl
method for sending back
the threshold along with the DMQ id.
Method implementing the reaction to a Monit_GetFather
notification requesting the identifier of the hierarchical father.
Method implementing the reaction to a
Monit_GetPendingMessages
notification requesting the
number of pending messages.
Method implementing the reaction to a
Monit_GetPendingRequests
notification requesting the
number of pending requests.
Method implementing the reaction to a Monit_GetReaders
notification requesting the identifiers of the destination's readers.
Method implementing the reaction to a
Monit_GetSubscriptions
notification requesting the
number of subscriptions.
Method implementing the reaction to a Monit_GetWriters
notification requesting the identifiers of the destination's writers.
Method specializing the reaction to a ReceiveRequest
instance, requesting a message.
Method implementing the reaction to a ReceiveRequest
instance, requesting a message.
Overrides this DestinationImpl
method; AdminTopics do not
accept SetDMQRequest
notifications.
Overrides this DestinationImpl
method; this request is
not expected by a dead message queue.
Method implementing the reaction to a SetDMQRequest
notification setting the dead message queue identifier for this
destination.
Overrides this TopicImpl
method; AdminTopics do not
accept SetFatherRequest
notifications.
Method implementing the reaction to a SetFatherRequest
instance notifying this topic it is part of a hierarchy as a son.
Overrides this DestinationImpl
method; AdminTopics do not
accept SetRightRequest
notifications.
Method implementing the reaction to a SetRightRequest
notification requesting rights to be set for a user.
Overrides this QueueImpl
method; this request is
not expected by a dead message queue.
Method implementing the reaction to a SetThreshRequest
instance setting the threshold value for this queue.
Method implementing the reaction to a SpecialAdminRequest
notification requesting the special administration of the destination.
Method specializing the reaction to a SubscribeRequest
instance.
Method implementing the reaction to a SubscribeRequest
instance.
Overrides this TopicImpl
method; AdminTopics do not
accept UnclusterRequest
notifications.
Method implementing the reaction to an UnclusterRequest
instance requesting this topic to leave the cluster it is part of.
Overrides this TopicImpl
method; AdminTopics do not
accept UnsetFatherRequest
notifications.
Method implementing the reaction to an UnsetFatherRequest
instance notifying this topic to leave its father.
Method specializing the reaction to an UnsubscribeRequest
instance.
Method implementing the reaction to an UnsubscribeRequest
instance, requesting to remove a subscriber.
Method implementing the reaction to a
org.objectweb.joram.mom.proxies.AdminNotification
notification notifying of the creation of an admin proxy.
new queue come in cluster, update clusters.
set the same right to all cluster
wake up, and call factorCheck to evaluate the loading factor...
Reacts to BridgeAckNot
notifications holding the identifier
of a message successfuly delivered to the foreign JMS server.
Reacts to BridgeAckNot
notifications holding the identifier
of a message successfuly delivered to the foreign JMS server.
Reacts to BridgeDeliveryNot
notifications holding a message
received from the foreign JMS server.
Reacts to BridgeDeliveryNot
notifications holding a message
received from the foreign JMS server.
Method actually sending an AdminRequest
instance to
the platform and getting an AdminReply
instance.
DOUBLE - static field in class org.objectweb.joram.shared.selectors.
sym Abstract base class for drivers such as DriverIn
used by
ProxyAgent
.
Each Connection
holds a Driver
daemon for
listening to asynchronous replies coming from the connected server.
Constructor with default id.
Constructs a Driver
daemon.
Notification reporting the end of a driver execution.
Reacts to end of driver execution.
Creates a notification to be sent.
Constructor used in a multi-connections context.
Identifies the driver in the context of multi-connections.
The DriverMonitor
class is used by ProxyAgent
instances managing multi-connections for holding the elements composing a
connection set.
Method called by the ProxyAgent DriverIn
instances to
forward the notifications they got from their input streams.
Table holding the DriverMonitor
objects, each one holding a
connection set (a pair of drivers, a qout, ois, oos, ...).
Thrown to indicate that the specified domain already exist.
Constructs a new DuplicateDomainException
with no
detail message.
Constructs a new DuplicateDomainException
with the
specified detail message.
Thrown to indicate that the specified agent server already exist.
Constructs a new DuplicateServerException
with no
detail message.
Constructs a new DuplicateServerException
with the
specified detail message.
The number of acknowledgements a message still expects from its
durable subscribers before having been fully consumed by them (field used
by JMS proxies).
For persistent server, Id.
GE - static field in class org.objectweb.joram.shared.selectors.
sym Waits for an object to be pushed in the queue, and eventually returns
it without removing it.
Returns the acknowledgement mode.
Delegates the call to the wrapped JMS session.
Returns the vector of SessAckRequest
instances.
Returns an IP address for its server.
Returns the admin name of the destination.
A GetAdminTopicReply
is sent by an administrator proxy for
notifying an administrator client of the identifier of the local admin
topic.
Constructs a GetAdminTopicReply
instance.
Constructs a GetAdminTopicReply
instance.
A GetAdminTopicRequest
is sent by a session for retrieving
the identifier of the local admin topic.
Constructs a GetAdminTopicRequest
instance.
Returns the proxy's AgentId
identifier.
Returns the temporary destination's agent identifier.
Returns the agent identifier
of this agent.
Gets configuration of agent servers for a domain from the current
A3CMLConfig object.
Gets the starting arguments for service.
Checks the autoAck mode of this request.
Returns a property as a boolean value.
Returns the transaction branch qualifier.
Returns the transaction branch qualifier.
Returns the transaction branch qualifier.
Returns a branch qualifier.
Returns the array of bytes body of the message.
Returns the identifier of the last listener request, cancelled by this
request, queue mode only.
Overrides the Throwable
behavior
in order to handle the deserialization
of the cause that may fail if its class
is unknown.
Returns the class name of destination (queue, topic, ...).
Gets the class name for service.
Returns the AgentId of the client which right is set.
Returns the client context identifier.
Forbidden call on an application or component's outbound connection,
throws a IllegalStateException
instance.
return the number of Message send to cluster.
Monitoring method returning the list describing the cluster this topic
is part of.
Returns the connection this temporary queue belongs to,
null
if not known.
Returns the connection's key.
Returns the agent server configuration.
Gets configuration of agent servers from a XML file.
Gets a A3CMLConfig
serialialized object from file.
Returns a new OutboundConnection
instance for handling the
physical connection.
Returns the context of the notification.
Returns the replied request identifier.
Returns the reply identifier.
Returns the message correlation identifier.
Returns the dmqs identifiers.
get AgentId of AgentServer
Returns the default JndiServer id on the local agent server.
Returns the default JndiServer id on the local agent server.
Gets the identifier of the default administration topic on a given server.
get default AgentId of AgentAdmin
Returns the default JndiServer id on the given agent server.
Returns the default JndiServer id on the given agent server.
Returns the default dead message queue for the local server, null if not
set.
Returns the default dead message queue for a given server, null if not
set.
Returns default login name for connection.
Returns the default login password for connection.
Returns the default threshold value for the local server, -1 if not set.
Returns the default threshold value for a given server, -1 if not set.
Returns an AbstractJmsReply
delivered by the connected
server.
Returns an AbstractJmsReply
delivered by the connected
server.
Returns an AbstractJmsReply
delivered by the connected
server.
Delegates the call to the wrapped producer.
Returns the identifier of the target destination.
Returns the identifier of the target destination.
Returns the identifier of the target destination.
Returns the identifier of the target destination.
Returns the identifier of the target topic.
Returns the identifier of the target destination.
Returns the id of the created queue.
Returns the identifier of the destination the DMQ is set for.
Returns the identifier of the destination.
Returns the identifier of the destination.
Returns the identifier of the destination which DMQ is unset.
Returns the destination name.
return the appropriate destination of cluster
return the appropriate destination of cluster
Delegates the call to the wrapped producer.
Returns the message destination identifier.
Returns the name attributed to the destination.
Returns the list of all destinations that exist on the local server,
or an empty list if none exist.
Returns the list of all destinations that exist on a given server,
or an empty list if none exist.
Returns the destination type.
Delegates the call to the wrapped producer.
Delegates the call to the wrapped producer.
Monitoring method returning the dead message queue of this destination,
null if not set.
getDMQ() - method in class org.objectweb.joram.client.jms.admin.
User Returns the dead message queue for this user, null if not set.
Returns the identifier of the producer's dead message queue, if any.
Returns the DMQ identifier.
Returns the identifier of the DMQ.
Returns the identifier of the DMQ.
Returns the dead message queue identifier, null
for none.
Returns the identifier of the DMQ.
Returns the DMQ identifier.
Returns the description of a domain.
Gets configuration of agent servers by a domain from a Config object.
Gets configuration of agent servers by a list of domain from a Config object.
Returns the corresponding domain's name.
Returns the corresponding domain's name.
Returns true
if the request must not be acked by the
server.
Returns true
if the request must not be acked by the
server.
Returns a property as a double value.
Accesses read only property.
Method returning the driverKey identifying
the closing driver.
Returns true
for a durable subscription.
Returns the current JORAM release number.
Retrieves the environment in effect for this context.
Returns the exception wrapped by the reply.
Returns the exception wrapped by this reply.
Forbidden call on an application or component's outbound connection,
throws a IllegalStateException
instance.
Returns the message expiration time.
Returns the identifier of the father.
Returns the identifier of the hierarchical father.
Returns the identifier of the hierarchical father.
Returns the hierarchical father identifier.
Returns the transaction identifier format.
Returns the transaction identifier format.
Returns the transaction identifier format.
Returns a property as a float value.
Returns a format identifier.
Returns true
if READ access is free.
Returns true
if READ access is free.
Returns true
if WRITE access is free.
Returns true
if WRITE access is free.
Returns a global transaction identifier.
returns the list of global variables
Returns the global transaction identifier.
Returns the global transaction identifier.
Returns the global transaction identifier.
Monitoring method returning the hierarchical father of this topic,
null if none.
Returns the name of host hosting the server to create connections with.
Gets host name for this server.
Get the host name of an agent server.
Returns the request identifier, null if not used.
Method returning the id of the admin topic.
Returns the global unique identifier of the agent.
Returns the global unique identifier of the agent.
Returns the acknowledged message identifier.
Returns the denied message identifier.
Static method returning the default DMQ identifier.
Returns the identifier of the destination to delete.
Returns the identifier of the admin topic.
Returns the identifier of the message successfuly delivered to
the foreign JMS server.
Returns the message identifier.
Returns the acknowledged messages' identifiers.
Returns the denied messages' identifiers.
Returns the servers' identifiers.
Returns the vector of acknowledged messages identifiers.
Returns the vector of denyed messages identifiers.
Returns the info related to the processing of the request.
Returns the carried info.
Returns the identifier of the topic already part of a cluster, or chosen
as the initiator.
Retrieves an instance from the table.
Determines the integer value of the server property with the
specified name.
Determines the integer value of the server property with the
specified name.
Returns a property as a int value.
From a set of managed connections, returns the set of invalid ones.
Get the JVM argument for a particular agent server identified by its id.
Get the JVM argument for a particular agent server identified by its name.
Returns the identifier as an hashtable key.
Returns the identifier as an hashtable key.
Returns the wrapped AgentId
.
Gets the listeners list as an Enumeration
of AgentId
objects.
Returns the host name of the server the module is connected to.
Returns the port number of the server the module is connected to.
Returns the identifier of the server the module is connected to.
Returns this managed connection instance as a
LocalTransaction
instance for managing local transactions.
Returns default log topic for agents.
Returns default log topic for proxies.
Gets the log writer of this ManagedConnectionFactoryImpl
instance.
Gets the log writer for this ManagedConnectionImpl
instance.
Returns a property as a long value.
Returns the map body of the message.
Returns 0 as JORAM as no upper limit of active connections.
Returns the maximum number of work instances to be submitted.
Returns the message obtained from the foreign JMS server.
Returns the first sent message.
Returns the message wrapped by this reply.
Forbidden call on a component's outbound consumer, throws a
IllegalStateException
instance.
Forbidden call on a component's outbound session, throws a
IllegalStateException
instance.
Returns the messages carried by this reply.
Returns the messages to deliver.
Returns the produced messages.
Returns the vector of messages carried by this reply.
Returns the message selector.
Delegates the call to the wrapped JMS consumer.
Returns the metadata information for the underlying JORAM server.
Delegates the call to the wrapped JMS connection.
Returns the name of the administrator.
Returns this Agent
's name.
Returns this Agent
's name.
Returns the name of the destination.
Returns this daemon
's name.
Returns the name of the destination.
Returns name of driver, actually classname and driver id.
Returns this Engine
's name.
Returns this MessageConsumer
's name.
Returns this session's name.
Returns this Engine
's name.
getName() - method in class org.objectweb.joram.client.jms.admin.
User Returns the user name.
Method used by proxies for retrieving their name.
Returns a destination name.
Retrieves the full name of this context within its own namespace.
Retrieves the parser associated with the named context.
Retrieves the parser associated with the named context.
Returns the maximum number of agents loaded in memory.
Returns the new name of the user.
Returns the new password of the user.
Returns true
for not consuming the local messages.
Returns the noLocal parameter.
Returns the wrapped number.
Returns the wrapped value.
Returns the object body of the message.
Returns an instance of scnURLContext for a java URL.
Returns a factory given its reference.
Returns a property as an object.
Method returning the ois object.
Method returning the oos object.
Returns an optional header field value.
Returns the factory's configuration parameters.
Returns the factory's configuration parameters.
Returns the password of the administrator.
Returns the user password.
Returns the password of the user requesting a connection to the
underlying JORAM server.
Method used by proxies for retrieving their password.
Monitoring method returning the number of pending messages on this queue.
Monitoring method returning the number of pending requests on this queue.
Returns true
if the message is persistent.
Returns the port to be used for accessing the server.
Returns the message priority.
Delegates the call to the wrapped producer.
Returns the destination properties.
Returns the specified property.
Searches for the property with the specified key in the server property
list.
Searches for the property with the specified key in the server property
list.
Returns an enumeration of the properties names.
Returns the id of the user's proxy.
Returns the identifier of the user's proxy.
Returns the user's proxy identifier.
Returns the AgentId
of the proxy.
Returns the proxy's identifier
Returns the identifier of the user's proxy.
Method used by ConnectionManager
proxies to check their
clients identification.
Method returning the qout object.
Get this consumer's MessageQueue
.
Returns the consumer's queue.
Delegates the call to the wrapped producer.
Returns the identifier of the queue the threshold is set for.
Returns the identifier of the queue which threshold is unset.
Returns the vector of msg identifiers for a given queue.
Returns true
if the request is destinated to a queue.
Returns true
if the request is destinated to a queue.
Returns true
if the messages come from a queue.
Returns true
if the request is destinated to a queue.
Returns true
if the request is destinated to a queue.
Returns true
for a queue listener.
Returns true
if the request is destinated to a queue.
Returns true
if the request is destinated to a queue.
Returns the queues identifiers.
Returns the queues enumeration.
Monitoring method returning the list of all users that have a reading
permission on this destination, or an empty list if no specific readers
are set.
Sets the naming reference of an administered object.
Sets the naming reference of a destination.
Sets the naming reference of a connection factory.
Sets the naming reference of a destination.
Returns the naming reference of this factory.
Sets the naming reference of this user.
Sets the naming reference of an XA connection factory.
Service method: returns a Hashtable containing an
AbstractJmsReply
reply or MOM messages destinated to a
given connection context.
Returns an object related to the processing of the request.
Returns the carried object.
Returns the destination id the reply should be sent to.
Returns the SpecialAdmin request
Returns the request identifier.
Returns the request identifier.
Returns the request identifier.
Returns the resource adapter central authority instance.
Returns the resource adapter central authority instance.
Returns the right to set, (-)3 for (un)setting an admin right, (-)2 for
(un)setting a writing permission, (-)1 for (un)setting a reading
permission, and 0 for removing all the user's permissions.
Overrides the JndiServer
behavior.
Returns the root naming context owner
identifier.
Returns the selector of the request.
Returns the selector for filtering the messages.
Returns the selector for filtering messages.
Returns the selector for filtering the messages.
Returns the selector for filtering the messages.
Returns the selector of the request.
Returns the vector of ProducerMessages
instances.
Returns the description of a server.
Returns the description of a server.
Returns the id of the server where deploying the destination.
Returns the id of the server where deploying its proxy.
Returns the identifier of the target server.
Returns the identifier of the target server.
Returns the identifier of the target server.
Returns the identifier of the target server.
Returns the identifier of the server the DMQ is set for.
Returns the identifier of the server the threshold is set for.
Returns the id of the server to stop.
Returns the identifier of the server which default DMQ is unset.
Returns the identifier of the server which threshold is unset.
Gets a server identifier from its name.
Returns the identifier of the agent server which name is specified.
Gets server name for this server.
return the list of all set types defined in template
return the list of variables for a type
Returns the list of the platform's servers' identifiers.
Get the argument strings for a particular service on a particular
agent server identified by its id.
Get the argument strings for a particular service.
Get the argument strings for a particular service on a particular
agent server identified by its name.
Get the argument strings for a particular service running on a server
identified by its host.
Gets the argument strings for a particular service running on a server
identified by its host (searchs on all servers and associated transient).
Gets the description of services running on this server.
Returns a property as a short value.
Returns the number of transaction identifiers.
Returns the identifier of the son.
Returns the stream of bytes body of the message.
Returns a property as a String.
Returns the vector of msg identifiers for a given subscription.
Returns the name of the subscription.
Returns the subscriptions enumeration.
Returns the subscription durabbility.
Returns the name of the durable subscription.
Monitoring method returning the number of users that subscribes on
this topic.
Returns true
if the request was successful.
Returns the request target name.
Returns the identifier of the target destination or user.
Gets the String body of the message.
Static method returning the default threshold.
Monitoring method returning the threshold of this queue, -1 if not set.
Returns the threshold value.
Returns the threshold value.
Returns the threshold value, negative or zero for no threshold,
null
for unsetting the previous value.
Returns the threshold value.
Returns the threshold for this user, -1 if not set.
Returns the time-to-live parameter of this request, in milliseconds (0 for
immediate delivery, negative for infinite validity).
Returns the timer provided by the connection manager.
Returns the message time stamp.
Returns the time to live value in milliseconds.
Delegates the call to the wrapped producer.
Returns the identifier of a topic part of the target cluster.
Returns the identifier of the target topic.
Delegates the call to the wrapped producer.
Returns the consumer's topic.
Returns the identifier of the topic the target topic must set a
cluster with.
Returns the identifiers of the cluster's topics.
Returns the identifiers of the cluster's topics.
Returns the topics identifiers.
Returns the identifier of the topic joining the cluster, or the
initiator.
Returns the identifier of the topic leaving its cluster.
Returns the identifier of the topic which father is unset.
Delegates the call to the wrapped JMS session.
Returns the agent server transaction context.
Returns 0 as timeout feaure is not supported.
Returns the message type.
Returns the user identification.
Returns the identification of the user requesting a connection to the
underlying JORAM server.
Returns the name of the user to create.
Returns the name of the user to delete.
Returns the name of the user associated with the managed connection.
Returns the name of the user to update.
Returns the password of the user.
Returns the identifier of the future reader's proxy.
Returns the ProxId of the user the DMQ is set for.
Returns the identifier of the user's proxy the threshold is set for.
Returns the identifier of the user's proxy which DMQ is unset.
Returns the identifier of the user's proxy which threshold is unset.
Returns the list of all users that exist on the local server, or an empty
list if none exist.
Returns the vector of readers' or writers' identifiers.
Returns the list of all users that exist on a given server, or an empty
list if none exist.
Monitoring method returning the list of all users that have a writing
permission on this destination, or an empty list if no specific writers
are set.
Provides a XAResource
instance for managing distributed
transactions.
return XAResourceMngr of this connection.
return XAResourceMngr of this connection.
return XAResourceMngr of this connection.
Returns XA resources given an array of ActivationSpec instances.
Gets an agent server configuration from a XML file.
Gets an agent server configuration from a XML file.
GT - static field in class org.objectweb.joram.shared.selectors.
sym Main for a standard agent server.
Start the admin tool by creating the controller and the main window.
A ManagedConnectionFactoryImpl
instance manages
outbound connectivity to a given JORAM server.
Constructs a ManagedConnectionFactoryImpl
instance.
A ManagedConnectionImpl
instance wraps a physical connection
to an underlying JORAM server, and provides "handles" for handling this
physical connection.
A ManagedConnectionMetaDataImpl
instance provides information
related to a managed connection.
Constructs a ManagedConnectionMetaDataImpl
instance.
A ManagedQueueConnectionFactoryImpl
instance manages
PTP outbound connectivity to a given JORAM server.
Constructs a ManagedQueueConnectionFactoryImpl
instance.
A ManagedTopicConnectionFactoryImpl
instance manages
PubSub outbound connectivity to a given JORAM server.
Constructs a ManagedTopicConnectionFactoryImpl
instance.
MAP - static field in class org.objectweb.joram.shared.messages.
MessageType A map message carries an hashtable.
Implements the javax.jms.MapMessage
interface.
Destinations call this method to filter a message according to a selector.
Finds a matching connection from the candidate set of connections and
returns a ManagedConnectionImpl
instance.
Finds a matching connection from the candidate set of connections and
returns a ManagedConnectionImpl
instance.
Finds a matching connection from the candidate set of connections and
returns a ManagedConnectionImpl
instance.
Maximum reserved stamp for system services.
Maximum reserved stamp for well known services.
Central manager for outbound connectivity.
Generate news a3servers configurations depending of new template,
new properties and existing configuration.
Implements the javax.jms.Message
interface.
The Message
class actually provides the transport facility
for the data exchanged during MOM operations.
Constructs a Message
instance.
The parent interface for all messages consumers.
Implements the javax.jms.MessageConsumer
interface.
The MessageConverterModule
is a utility class used for
converting JORAM MOM messages into foreign JMS messages and foreign
JMS messages into JORAM MOM messages.
call in deliverMessages just after channel.sendTo(msg),
overload this methode to process a specific treatment.
call in deliverMessages just after channel.sendTo(msg),
overload this methode to process a specific treatment.
A MessageException
is thrown when an error occurs while
accessing a message.
Constructs a MessageException
instance.
The message listener of the session, if any.
The MessagePersistenceModule
class is a utility class used
by queues and proxies for persisting, retrieving and deleting messages.
Constructs a MessagePersistenceModule
instance.
Implements the javax.jms.MessageProducer
interface.
call in deliverMessages just after a remove message (invalid),
overload this methode to process a specific treatment.
call in deliverMessages just after a remove message (invalid),
overload this methode to process a specific treatment.
A MessageROException
is thrown when trying to write on a
READ-ONLY part of a message.
Constructs a MessageROException
instance.
Vector holding the messages before delivery.
The MessageType
interface defines the various types of
MOM messages.
A MessageValueException
is thrown when a value carried by a
message is incorrectly accessed or typed.
Constructs a MessageValueException
instance.
MIN_LONG - static field in class org.objectweb.joram.shared.selectors.
sym MINUS - static field in class org.objectweb.joram.shared.selectors.
sym Minimum reserved stamp for well known services.
Thrown when a naming context has not been found
whereas its parent naming context contains a
ContextRecord
indicating that
the naming context exists.
Constructs a MissingContextException
.
Thrown when a ContextRecord
has not been found
in a naming context.
Constructs a MissingRecordException
.
The MomException
class is the exception class thrown by the
MOM actors.
Constructs a MomException
containing a given description.
A MomExceptionReply
instance is used by a JMS client proxy
to send a MomException
back to a JMS client.
Constructs a MomExceptionReply
instance.
Constructs a MomExceptionReply
instance.
The MomTracing
class centralizes the log tracing for the MOM.
A Monit_FreeAccess
request is used by an administrator client
for checking the free access rights on a destination.
Constructs a Monit_FreeAccess
instance.
A Monit_FreeAccessRep
reply is used by a destination for
sending to an administrator client its free access settings.
Constructs a Monit_FreeAccessRep
instance.
A Monit_GetCluster
instance is used by an administrator for
requesting the identifiers of a cluster's topics.
Constructs a Monit_GetCluster
instance.
A Monit_GetClusterRep
reply is used by a topic for sending
the identifiers of its cluster's topics to the administrator.
Constructs a Monit_GetClusterRep
instance.
A Monit_GetDMQSettings
instance requests DMQ settings.
Constructs a Monit_GetDMQSettings
instance.
A Monit_GetDMQSettingsRep
instance is used by a destination
or a proxy for sending to an administrator client its DMQ settings.
Constructs a Monit_GetDMQSettingsRep
instance.
A Monit_GetFather
instance is used by an administrator for
requesting the identifier of a topic's father.
Constructs a Monit_GetFather
instance.
A Monit_GetFatherRep
reply is used by a topic for sending
the identifier of its hierarchical father to the administrator.
Constructs a Monit_GetFatherRep
instance.
A Monit_GetNumberRep
reply is used by a destination for
sending to an administrator client an integer value.
Constructs a Monit_GetNumberRep
.
A Monit_GetPendingMessages
request is used by an
administrator client for requesting the number of pending messages on
a queue agent.
Constructs a Monit_GetPendingMessages
.
A Monit_GetPendingRequests
request is used by an
administrator client for requesting the number of pending requests on
a queue agent.
Constructs a Monit_GetPendingRequests
.
A Monit_GetReaders
request is used by an administrator client
for requesting the identifiers of the readers on a destination.
Constructs a Monit_GetReaders
instance.
A Monit_GetSubscriptions
request is used by an
administrator client for requesting the number of subscriptions on
a topic agent.
Constructs a Monit_GetSubscriptions
.
A Monit_GetUsersRep
reply is used by a destination for
sending to an administrator client the identifiers of its readers or
writers.
Constructs a Monit_GetUsersRep
instance.
A Monit_GetWriters
request is used by an administrator client
for requesting the identifiers of the writers on a destination.
Constructs a Monit_GetWriters
instance.
A Monitor_GetCluster
instance requests the list of the topics
part of a cluster.
Constructs a Monitor_GetCluster
instance.
A Monitor_GetClusterRep
instance holds the identifiers of
a cluster's topics.
Constructs a Monitor_GetClusterRep
instance.
A Monitor_GetDestinations
instance requests the list of
the destinations of a given server.
Constructs a Monitor_GetDestinations
instance.
A Monitor_GetDestinationsRep
instance replies to a get
destinations monitoring request, and holds the destinations on a given
server.
A Monitor_GetDMQSettings
instance requests the DMQ settings
of a server, a user or a destination.
Constructs a Monitor_GetDMQSettings
instance.
Constructs a Monitor_GetDMQSettings
instance.
A Monitor_GetDMQSettingsRep
instance holds the dead message
queue and threshold settings of a server, a destination or a user.
Constructs a Monitor_GetDMQSettingsRep
instance.
A Monitor_GetFather
instance requests the identifier of a
topic father.
Constructs a Monitor_GetFather
instance.
A Monitor_GetFatherRep
instance holds the identifier of a
topic's hierarchical father.
Constructs a Monitor_GetFatherRep
instance.
A Monitor_GetFreeAccess
instance checks the free access
settings on a given destination.
Constructs a Monitor_GetFreeAccess
instance.
A Monitor_GetFreeAccessRep
instance carries the free access
settings of a destination.
Constructs a Monit_GetFreeAccessRep
instance.
A Monitor_GetNumberRep
instance is a reply wrapping an
integer value.
Constructs a Monitor_GetNumberRep
instance.
A Monitor_GetPendingMessages
instance requests the number of
pending messages on a given queue.
Constructs a Monitor_GetPendingMessages
instance.
A Monitor_GetPendingRequests
instance requests the number of
pending requests on a given queue.
Constructs a Monitor_GetPendingRequests
instance.
A Monitor_GetReaders
instance requests the list of
the readers on a given destination.
Constructs a Monitor_GetReaders
instance.
A Monitor_GetServersIds
instance requests the list of
the platform's servers' identifiers.
Constructs a Monitor_GetServersIds
instance.
A Monitor_GetServersIdsRep
instance holds the list of the
platform's servers' identifiers.
Constructs a Monitor_GetServersRep
instance.
A Monitor_GetSubscriptions
instance requests the number of
subscriptions on a given topic.
Constructs a Monitor_GetSubscriptions
instance.
A Monitor_GetUsers
instance requests the list of
the users of a given server.
Constructs a Monitor_GetUsers
instance.
A Monitor_GetUsersRep
instance replies to a get users,
readers or writers monitoring request.
Constructs a Monitor_GetUsersRep
instance.
A Monitor_GetWriters
instance requests the list of
the writers on a given destination.
Constructs a Monitor_GetWriters
instance.
A Monitor_Reply
instance is used by a
org.objectweb.joram.mom.dest.AdminTopic
topic for sending monitoring
information to a client monitorer.
Constructs a Monitor_Reply
instance.
A Monitor_Request
request is sent by a monitorer
inside a org.objectweb.joram.shared.messages.Message
to an
org.objectweb.joram.mom.dest.AdminTopic
topic for requesting an
monitoring operation.
queue of Notification
objects to be sent
true
if the proxy manages multiple connections.
true if proxy may handle multiple connection
Distributes the received notifications to the appropriate reactions.
Defines the reaction of the agent when receiving a notification.
Reacts to AgentAdmin
specific notifications.
Specializes this QueueImpl
method for processing the
specific bridge notifications.
Specializes this TopicImpl
method for processing the
specific bridge notifications.
Reactions to notifications are implemented by the
DestinationImpl class.
Distributes the received notifications to the appropriate reactions.
Defines the reaction of the agent when receiving a notification.
Reactions to notifications are implemented by the
DestinationImpl class.
Distributes the received notifications to the appropriate reactions.
Method implementing the ProxyAgent
reactions to
notifications.
Distributes the received notifications to the appropriate reactions.
Distributes the received notifications to the appropriate reactions.
Distributes the received notifications to the appropriate reactions.
Overrides the Agent
class react
method for
providing the JMS client proxy with its specific behaviour.
Reacts to notifications from proxy.
Method processing clients requests.
The readBag method is responsible for reading from the stream and
restoring the agent's transient state.
Gets a Notification
from the stream.
READ and WRITE access value.
Rebinds an object to the specified path.
Binds a name to an object, overwriting any existing binding.
Service method: decodes and rebinds an object.
Binds a name to an object, overwriting any existing binding.
Asynchronous method requesting a delivery from the foreign
JMS destination.
Notifies the daemon of a new "receive" request.
Delegates the call to the wrapped JMS consumer.
API method implemented in subclasses.
Delegates the call to the wrapped JMS consumer.
Synchronous method requesting an immediate delivery from the foreign
JMS destination.
Delegates the call to the wrapped JMS consumer.
A ReceiveRequest
instance is used by a client agent for
requesting a message on a queue.
Constructs a ReceiveRequest
instance.
true
if the queue is currently receiving messages.
Notifies the daemon to start reconnecting.
The ReconnectionDaemon
thread is responsible for reconnecting
the bridge module with the foreign JMS server in case of disconnection.
Constructs a ReconnectionDaemon
thread.
Delegates the call to the wrapped JMS session.
API method inherited from session, but intercepted here for
forbidding its use in the XA context (as defined by the API).
Recovers the prepared transactions identifiers.
Access to reduce_goto
table.
Access to reduce_goto
table.
Reference of the server's local AdminTopicImpl instance.
Naming reference of this instance.
Reinitializes the agent, that is reconnects its input and output.
The RemoteServer
class allows to handle remote JORAM servers.
Constructs a RemoteServer
instance.
The RemoteServerMBean
interface defines the administration
methods provided by the
RemoteServer
class.
Removes a connection event listener.
Removes an environment property from the environment of this
context.
Removes an agent from the listeners list.
Constructs a new network removal command.
removeQueue leave the cluster.
Leave a queue to a cluster.
Binds a new name to the object bound to an old name, and unbinds
the old name.
Binds a new name to the object bound to an old name, and unbinds
the old name.
Table holding the server replies to synchronous requests.
Reply object received from the platform.
the agent identified by 'reply' will receive a DeleteAck
when destruction complete
the agent identified by 'reply' will receive a DeleteAck
when destruction complete
Returns true
if the reply to destination is a queue.
Identifier of the client requesting a message, set by the queue if
storing the request.
A RequestException
is thrown by a destination or a proxy when
processing an invalid client request.
Constructs a RequestException
instance.
Vector holding the requests before reply or expiry.
Table holding requests related objects, either locks of synchronous
requests, or asynchronous consumers.
reset visited and gateway fields.
Resolves an IP address for its server, don't use an eventually caching
address.
Resolves the IP address for this hostname, don't use an eventually
caching address.
Restores logical clock information from persistent storage.
Restores component's information from persistent storage.
Creates a new role with the specified name.
Creates a new role with the specified name and AgentId.
This structure provides code for managing target agents registering
in a role.
Creates a new RoleMultiple with a specified name.
Rollsback the local transaction.
Rolls back all the registered saving and deletion requests.
Forbidden call on a component's outbound session, throws a
IllegalStateException
instance.
API method inherited from session, but intercepted here for
forbidding its use in the XA context (as defined by the API).
RPAREN - static field in class org.objectweb.joram.shared.selectors.
sym Actually executes the driver code.
Actually executes the driver code.
run() - method in class org.objectweb.joram.client.jms.
Driver The driver's listening loop.
Method never used by a component, does nothing.
run() - method in class org.objectweb.joram.client.jms.
Session API method.
Method called by the timer when the task is ready to execute.
API method inherited from session, but intercepted here for
adapting its behaviour to the XA context.
Boolean variable used to stop the daemon properly.
save configuration of agent servers (Config)
in a serialized file.
Saves the agent state unless not requested.
Saves logical clock information to persistent storage.
Saves information to persistent storage.
Registers a message for future saving.
Save an object state already serialized.
Save an object state already serialized.
Save an object state already serialized.
Save an object state already serialized.
Reserved stamp for SCAdmin proxy AgentId
.
Schedules a given task for execution after a given delay.
Reserved stamp for scheduler service AgentId
.
Context implementation for the "scn:comp" namespace.
Context factory for scnURLContext objects.
Script contains an AdminCmd vector.
Selector for filtering messages.
The Selector
class is used for filtering messages according
to their header fields and properties.
A SelectorException
is thrown when an error occurs while
parsing a selector expression.
Constructs a SelectorException
instance.
Table of subscribers' selectors.
Delegates the call to the wrapped producer.
Delegates the call to the wrapped producer.
Sends a message with default delivery parameters for an unidentified
message producer.
Sends a message with given delivery parameters for an unidentified
message producer.
Sends a message with the default delivery parameters.
Sends a message with given delivery parameters.
Delegates the call to the wrapped producer.
Delegates the call to the wrapped producer.
Sends a JMS request to the server.
Sending a JMS request through the TCP connection.
Sends a message to the foreign JMS queue.
Sends a message to the foreign JMS topic.
Sends a message to the foreign JMS destination.
Delegates the call to the wrapped producer.
Delegates the call to the wrapped producer.
Service method: passes a hashtable containing an
AbstractJmsRequest
client request or MOM messages to the
proxy.
Sends a notification to a given agent.
Sends a notification to the specified agent.
Method called by subclasses to directly send their notifications
to the right DriverOut
.
This method sends a notification to the agent which id is given in
parameter.
Sends a notification to an agent.
Sends a notification to an agent.
This method sends a notification to the agent which id is wrapped
in the specified role.
Sends a notification to all the agents registered in a role.
Sends an AbstractJmsReply
to a given client.
Sends a reply to the client connected through
the specified connection.
send to all queue in cluster.
Sends dead messages to the appropriate dead message queue.
Overwrites this DestinationImpl
method so that no messages
may be sent by the DMQ to itself.
Creates a filter built on top of the specified OutputStream
.
Description of an agent server.
hashtable of server description
Constructs a new node for a persistent agent server.
This property allow to configure the JMX server proxy, if it is
null JMX is not used.
A ServerReply
is used by a JMS proxy for
acknowledging the receipt of a synchronous AbstractJmsRequest
request.
Constructs a ServerReply
instance.
Constructs a ServerReply
instance.
Constructs a ServerReply
instance.
Hashtable of all servers (persitent and transient)
Description of alls servers in domain
Filename for servers storage
Description of a service.
Object which manages services.
sess - field in class org.objectweb.joram.client.jms.
Message If the message is actually consumed, the session that consumes it,
null
otherwise.
The session the producer belongs to.
An XA Session actually wraps what looks like a "normal" session object.
A SessAckRequest
instance is used by a Session
for acknowledging the messages it consumed.
Constructs a SessAckRequest
instance.
Constructs a SessAckRequest
instance.
A SessCreateTDReply
is used by a JMS proxy for replying
to a SessCreate<TQ/TT>Request
.
Constructs a SessCreateTDReply
instance.
Constructs a SessCreateTDReply
instance.
A SessCreateTQRequest
is sent by a QueueSession
for creating a TemporaryQueue
.
Constructs a SessCreateTQRequest
instance.
A SessCreateTTRequest
is sent by a TopicSession
for creating a TemporaryTopic
.
Constructs a SessCreateTTRequest
instance.
A SessDenyRequest
instance is used by a Session
for denying the messages it consumed.
Constructs a SessDenyRequest
instance.
Constructs a SessDenyRequest
instance.
Constructs a SessDenyRequest
instance.
Implements the javax.jms.Session
interface.
The OutboundSession
this consumer belongs to.
The OutboundSession
this producer belongs to.
Vector of the connection's sessions.
Sets the acknowledgement mode.
Sets the destination identifier.
Sets a property as a boolean value.
Sets a property as a byte value.
Sets the message body as an array of bytes.
Sets the identifier of the last listener request, cancelled by this
request, queue mode only.
Forbidden call on an application or component's outbound connection,
throws a IllegalStateException
instance.
A SetCluster
instance is used for adding a given topic
to a cluster an other topic is part of, or for creating a new cluster.
Constructs a SetCluster
instance.
Links two given topics in a cluster relationship.
Set the agent server configuration.
Service method: returns the identifier of a given user connection,
or -1 if it is not a valid user of the SOAP proxy.
Sets the JMS consumer on the foreign destination.
Sets the context of the notification.
Sets the replied request identifier.
Sets the message correlation identifier.
Marks the daemon's thread as either a daemon thread a user thread.
A SetDefaultDMQ
instance requests to set a given DMQ as the
default DMQ for a given server.
Sets a given dead message queue as the default DMQ for a given server
(null
for unsetting previous DMQ).
Constructs a SetDefaultDMQ
instance.
Sets a given dead message queue as the default DMQ for the local server
(null
for unsetting previous DMQ).
A SetDefaultThreshold
instance requests to set a given
threshold value as the default threshold for a given server.
Sets a given value as the default threshold for the local server (-1 for
unsetting previous value).
Sets a given value as the default threshold for a given server (-1 for
unsetting previous value).
Constructs a SetDefaultThreshold
instance.
Delegates the call to the wrapped producer.
Sets the destination name.
Sets the message destination.
A SetDestinationDMQ
instance requests to set a given DMQ as
the DMQ for a given destination.
Constructs a SetDestinationDMQ
instance.
Sets the destination type (either "javax.jms.Queue" or
"javax.jms.Topic").
API method; not taken into account.
Delegates the call to the wrapped producer.
Delegates the call to the wrapped producer.
Admin method setting or unsetting a dead message queue for this
destination.
Admin method setting a given dead message queue for this user.
Sets the identifier of the producer's dead message queue, if any.
A SetDMQRequest
instance is used by a client agent
for notifying a destination to which dead message queue it must send its
dead messages.
Constructs a SetDMQRequest
instance.
Sets the server ack policy.
Sets the server ack policy.
Sets a property as a double value.
Sets the durable attribute.
Forbidden call on an application or component's outbound connection,
throws a IllegalStateException
instance.
Sets the message expiration.
Updates the expiration time field, if needed.
A SetFather
instance is used for linking two topics in a
hierarchical relationship.
Constructs a SetFather
instance.
A SetFatherRequest
instance is used by a client agent
for notifying a topic it belongs to a hierarchy as the son of a given
topic.
Constructs a SetFatherRequest
instance.
Sets a property as a float value.
Admin method setting free reading access to this destination.
Admin method setting free writing access to this destination.
Links two given topics in a hierarchical relationship.
Sets the acknowledged message identifier.
Sets the denied message identifier.
Sets the identifier of the admin topic.
Sets the message identifier.
Sets the vector of identifiers.
Sets the vector of identifiers.
set nb of chars for indentation
Sets a property as an int value.
Sets the wrapped AgentId
.
Set the monolog Loggerfactory
Sets the log writer for this ManagedConnectionFactoryImpl
instance.
Sets the log writer for this ManagedConnectionImpl
instance.
Sets a property as a long value.
Sets a map as the body of the message.
Sets the maximum number of work instances to be submitted.
set a message to deliver.
Sets a message listener on the foreign JMS destination.
Forbidden call on a component's outbound consumer, throws a
IllegalStateException
instance.
Forbidden call on a component's outbound session, throws a
IllegalStateException
instance.
Sets the message selector.
Method setting the ProxyAgent
in multiConn mode.
Sets destinations' names, if any.
Sets the noLocal attribute.
Sets the updated
field to false
so that the
agent state is not saved after the current reaction; the field is set
back to true
for the next reaction.
Sets an object as the body of the message.
Sets an optional header field value.
Sets the message persistence mode.
Updates the network port.
Changes the priority of this daemon.
Sets the message priority.
Delegates the call to the wrapped producer.
Sets the destination properties.
Sets the bridge properties.
Sets the bridge properties.
Sets properties for the destination.
Sets the destination properties.
Sets properties for the destination.
Sets the proxy's identifier
Sets the queue denyings table.
Adds a queue to a cluster.
Sets the target destination type.
Sets the target destination type.
Sets the target destination type.
Sets the target destination type.
Sets the listener mode (queue or topic listener).
Sets the target destination type.
Sets the target destination type.
A SetQueueThreshold
instance requests to set a given
threshold value as the threshold for a given queue.
Constructs a SetQueueThreshold
instance.
A SetReader
instance requests the authorization for a given
user to be a reader on a given destination.
Admin method setting a given user as a reader on this destination.
Constructs a SetReader
instance.
Sets the naming reference of this factory.
Sets the destination to which a reply should be sent.
Sets the request identifier.
Sets the resource adapter central authority.
Sets the resource adapter central authority.
A SetRight
instance requests a given right to be granted to a
given user.
Constructs a SetRight
instance.
A SetRightRequest
instance is used by a client agent
for setting users right on a destination.
Constructs a SetRightRequest
instance.
Sets a property as a short value.
Sets the message body as a stream of bytes.
Sets a property as a String.
Sets the sub denyings table.
Sets the subscription name.
Sets the durability of the subscription.
Sets the name of the durable subscription.
Sets the request target name.
Sets a String as the body of the message.
Set the thread group to which this daemon's thread belongs.
Admin method setting or unsetting the threshold for this queue.
Admin method setting a given value as the threshold for this user.
A SetThreshRequest
instance is used by a client agent
for notifying a queue of its threshold value.
Constructs a SetThresholdRequest
instance.
Sets the message time stamp.
Sets the time to live value.
Delegates the call to the wrapped producer.
Returns false
as timeout feaure is not supported.
A SetUserDMQ
instance requests to set a given DMQ as the
DMQ for a given user.
Constructs a SetUserDMQ
instance.
Sets the user identification.
A SetUserThreshold
instance requests to set a given
threshold value as the threshold for a given user.
Constructs a SetUserThreshold
instance.
A SetWriter
instance requests the authorization for a given
user to be a writer on a given destination.
Admin method setting a given user as a writer on this destination.
Constructs a SetWriter
instance.
SHORT - static field in class org.objectweb.joram.shared.selectors.
sym Show the initialized dialog.
Show the initialized dialog.
Show the initialized dialog.
Show the initialized dialog.
Show the initialized dialog.
Interupts a thread that waits for long periods.
Interupts a thread that waits for long periods.
Interupts a thread that waits for long periods.
Gives the Byte value of an unsigned byte value.
silence use for idempotence.
A simple message carries an empty body.
SimpleNetwork
is a simple implementation of
StreamNetwork
class with a single connection at
a time.
Creates a new network component.
size - field in class fr.dyade.aaa.util.
Pipe Transforms this reply into a hashtable of primitive values that can
be vehiculated through the SOAP protocol.
Transforms this message into a table of primitive values that can
be vehiculated through the SOAP protocol.
Transforms this reply into a hashtable of primitive values that can
be vehiculated through the SOAP protocol.
Transforms this request into a hashtable of primitive values that can
be vehiculated through the SOAP protocol.
Codes an given object into a Hashtable transportable by the SOAP protocol.
Transforms a hashtable of primitive values into a
ConsumerMessages
reply.
Transforms a table of primitive values into a Message
instance.
Transforms a hashtable of primitive values into a
MomExceptionReply
reply.
Transforms a hastable of primitive values into a
ProducerMessages
request.
Transforms a hashtable of primitive values into a
QBrowseReply
reply.
Decodes a given Hashtable into an object.
The SoapObjectHelper
class provides static methods for
coding and decoding objects for the SOAP protocol.
The SoapObjectItf
interface must be implemented by any
object which may be registered and/or retrieved to/from JNDI through the
SOAP protocol.
The SoapProxyService
class implements the SOAP service
accessed by the JORAM clients using a SoapConnection
for
connecting to the MOM.
This class implements an IP Socket Address (IP address + port number)
Creates a socket address from a hostname and a port number.
Sorts the specified array of ints into ascending numerical order.
Sorts the specified range of the specified array of ints into
ascending numerical order.
An SpecialAdmin
is a request sent by
a client administrator inside a
org.objectweb.joram.shared.messages.Message
to an
org.objectweb.joram.mom.dest.AdminTopic
topic for
requesting an special admin operation.
use to add or remove ClusterQueue to cluster.
A SpecialAdminRequest
instance is used by a destination agent
to do special admimistration.
Constructs a SpecialAdminRequest
instance.
implement special process (see QueueImpl).
Abstract method to be implemented by subclasses for specifically
processing notifications.
The DestinationImpl
class calls this method for passing
notifications which have been partly processed, so that they are
specifically processed by the QueueImpl
class.
The DestinationImpl
class calls this method for passing
notifications which have been partly processed, so that they are
specifically processed by the TopicImpl
class.
Creates a new network component.
Causes this AgentServer to begin its execution.
API method for starting the connection.
Causes this daemon to begin execution.
Starts the driver execution.
Causes this engine to begin execution
Causes this network component to begin execution.
Causes this component to begin execution.
Causes this engine to begin execution
Causes this network component to begin execution.
Delegates the call to the wrapped JMS connection.
Causes this network component to begin execution.
Authorizes the use of the queue by producers.
Causes this network component to begin execution.
Initializes the adapter; starts, if needed, a collocated JORAM server,
and if needed again, administers it.
Service method: called by the SOAP client for instanciating the SOAP
service and starting the embedded JORAM server.
Enlists this resource in a given transaction.
Indicates start production.
Indicates start production.
Starts an agent server from its id.
Starts an agent server from its id.
Starts an agent server from its id.
Starts an agent server from its id.
Starts an agent server from its id.
Initializes parsing of a document.
Receive notification of the start of an element.
Constructs a new start network command.
StartScript contain a StartAdminCmd vector and a ServerDesc hashtable.
The StartupDaemon
thread is responsible for retrieving
the needed JMS administered objects from the JNDI server.
Constructs a StartupDaemon
thread.
A StateException
is thrown by a destination or a proxy when
processing a request in an invalid state.
Constructs a Statexception
instance.
Forces this AgentServer to stop executing.
API method for stopping the connection; even if the connection appears
to be broken, stops the sessions.
Forces the daemon to stop executing.
Stops the driver execution.
Forces the engine to stop executing
Forces the network component to stop executing.
Notifies the adapter to terminate the connections it manages, and if
needed, to shut down the collocated JORAM server.
Forces the component to stop executing.
Forces the engine to stop executing
Forces the network component to stop executing.
Forbidden call on an application or component's outbound connection,
throws a IllegalStateException
instance.
Forces the network component to stop executing.
Stops all drivers (non multiConn mode).
Stops the queue by returning when it is empty and prohibiting any
further producers call to the push
method.
Forces the network component to stop executing.
Forces this AgentServer to stop executing.
Method stopping the specified connection set (multi-connections mode).
Stops cleanly an agent server from its id.
Stops cleanly an agent server from its id.
Stops cleanly an agent server from its id.
Constructs a new stop network command.
Thrown by the push
method of the Queue
class
when the queue is actually stopping or stopped.
Constructs a new StoppedQueueException
with
no detail message.
StopScript contain a StopAdminCmd vector to stop networks, servers
and services.
Stops the platform local server.
Stops a given server of the platform.
A StopServerRequest
instance requests to stop a given server.
Constructs a StopServerRequest
instance.
Stops the ConnectionManager
service.
Stops the JndiServer
service.
Actually stores a message in the deliverables vector.
A stream message carries a bytes stream.
Implements the javax.jms.StreamMessage
interface.
StreamNetwork
is a base implementation of Network
class for TCP sockets.
Creates a new Network component
STRING - static field in class org.objectweb.joram.shared.selectors.
sym This class provides a set of static functions for building string
representations of complex structures.
A SubscribeReply
instance is used by a topic agent
for acknowledging a SubscribeRequest
notification.
Constructs a SubscribeReply
instance.
A SubscribeRequest
instance is used by a client agent
for subscribing to a topic.
Constructs a SubscribeRequest
instance.
Vector of subscribers' identifiers.
Returns true
if this reply replies to a successful request.
sym - class org.objectweb.joram.shared.selectors.
sym CUP generated class containing symbol constants.
This notification is used to synchronously call a
local agent from a collocated thread.
The request target is either a destination agent name, or a subscription
name.
A TcpConnection
links a Joram client and a Joram platform
with a TCP socket.
Handles the TCP connection.
Creates a TcpConnection
instance.
Creates a new TCP connection.
A TcpConnectionFactory
instance is a factory of
TCP connections.
Constructs an empty TcpConnectionFactory
instance.
Constructs a TcpConnectionFactory
instance.
Listens to the TCP connections from the JMS clients.
Creates a new connection listener
A TcpDriver
gets server deliveries coming through a TCP socket.
Constructs a TcpDriver
daemon.
Starts a TCP entry point for MOM clients.
The activity responsible for reading the requests
from the socket and invoke the user's proxy.
This notification must only be used inside
an agent server.
The activity responsible for getting the replies
from the user's proxy and writing them to the
socket.
A TempDestDeleteRequest
instance is sent by a
deleting temporary destination.
Constructs a TempDestDeleteRequest
instance.
Constructs a TempDestDeleteRequest
instance.
Implements the javax.jms.TemporaryQueue
interface.
Constructs an empty temporary queue.
Constructs a temporary queue.
Implements the javax.jms.TemporaryTopic
interface.
Constructs an empty temporary topic.
Constructs a temporary topic.
TEXT - static field in class org.objectweb.joram.shared.messages.
MessageType A text message carries a String body.
Implements the javax.jms.TextMessage
interface.
The active component of this daemon.
separate thread running the driver
This class is a facility for scheduling tasks future execution.
Constructs a Timer
instance.
The TimerTask
class is the base class for implementing
tasks run by a Timer
instance.
TIMES - static field in class org.objectweb.joram.shared.selectors.
sym Gets the boolean value of the given object.
Gets the byte value of the given object.
Provides a Java string literal representing the parameter string.
Gets the bytes value of the given object.
Gets the char value of the given object.
Gets the double value of the given object.
Gets the float value of the given object.
Gives the hexa representation of unsigned value of the byte.
Gives the hexa representation of an array of bytes.
Gets the int value of the given object.
Gets the long value of the given object.
Topic - class org.objectweb.joram.client.jms.
Topic Implements the javax.jms.Topic
interface and provides
JORAM specific administration and monitoring methods.
A Topic
agent is an agent hosting a MOM topic, and which
behaviour is provided by a TopicImpl
instance.
Topic() - constructor for class org.objectweb.joram.client.jms.
Topic Constructs an empty topic.
Topic() - constructor for class org.objectweb.joram.mom.dest.
Topic Empty constructor for newInstance().
Constructor with parameters for fixing the topic.
Constructs a Topic
agent.
Constructor with parameters for fixing the topic and specifying its
identifier.
Implements the javax.jms.TopicConnection
interface.
Creates a TopicConnection
instance.
Implements the javax.jms.TopicConnectionFactory
interface.
Constructs an empty TopicConnectionFactory
.
Constructs a TopicConnectionFactory
dedicated to a given
server.
A TopicConnectionRequest
instance wraps a user connection
request for performing PubSub messaging.
Constructs a TopicConnectionRequest
instance.
The TopicImpl
class implements the MOM topic behaviour,
basically distributing the received messages to subscribers.
Constructs a TopicImpl
instance.
A TopicLocalConnectionFactory
instance is a factory of
local connections for Pub/Sub communication.
Constructs an empty TopicLocalConnectionFactory
instance.
A TopicMsgsReply
instance is used by a topic for sending
messages to an agent client which subscribed to it.
Constructs a TopicMsgsReply
.
Implements the javax.jms.TopicPublisher
interface.
Implements the javax.jms.TopicSession
interface.
Implements the javax.jms.TopicSubscriber
interface.
A TopicTcpConnectionFactory
instance is a factory of
TCP connections for Pub/Sub communication.
Constructs an empty TopicTcpConnectionFactory
instance.
Constructs a TopicTcpConnectionFactory
instance.
Returns true
if the destination is a queue.
Gets the short value of the given object.
Provides a string image for this object.
Returns a string representation of this agent, including the agent's
class, name, global identication, and fixed property.
Provides a string image for this object.
Returns a string representation of this AgentId
object.
Returns a string representation of this agent, including the agent's
class, name, global identication, and fixed property.
Returns a string representation of this object.
Returns a String image of the cluster queue.
String image of the connection.
Returns a string image of the connection consumer.
Returns a string view of the connection factory.
Returns a string representation of this daemon.
Returns a String image of the queue.
Provides a string image for this object.
String view of a Driver
instance.
Provides a string image for this object.
Returns a string representation of this engine.
Returns a string representation of this notification.
Provides a string image for this object.
Provides a string image for this object.
Returns a string representation of this consumer, including the
daemon's name and status.
Returns a string view of this consumer.
Returns a string representation of this consumer.
Returns a string representation of this consumer, including the
daemon's name and status.
Returns a string representation of this consumer, including the
daemon's name and status.
Provides a string image for this object.
Returns a String image of the queue.
Returns a string view of this browser.
Returns a string view of the connection factory.
Returns a string view of this receiver.
Returns a string view of this receiver.
Returns a String image of this session.
Provides a string image for this object.
Provides a string image for this object.
Provides a string image for this object.
Provides a string image for this object.
Returns a String image of this session.
Returns a string representation of this consumer, including the
daemon's name and status.
Constructs a string representation of this InetSocketAddress.
Returns a String image of the queue.
Returns a String image of the topic.
Returns a String image of the topic.
Returns a string view of the connection factory.
Returns a string view of this receiver.
Returns a String image of this session.
Returns a string view of this receiver.
Returns a string representation of this notification.
Returns a string representation of this notification.
toString() - method in class org.objectweb.joram.client.jms.admin.
User Returns a string view of this User
instance.
Returns a string view of the connection factory.
Returns a string view of the connection factory.
Returns a String image of this session.
Returns a String image of this session.
Returns a string view of the connection factory.
Returns a String image of this session.
Provides a string representation of a hash table of objects.
Gets the String value of the given object.
Provides a string representation of an object.
Provides a Java string literal representing the parameter string.
Provides a string representation of an array of booleans.
Provides a string representation of an array of bytes.
Provides a string representation of an array of chars.
Provides a string representation of an array of doubles.
Provides a string representation of an array of floats.
Provides a string representation of a hash table of objects.
Provides a string representation of an array of ints.
Provides a string representation of an array of longs.
Provides a string representation of an object.
Provides a string representation of an array.
Provides a string representation of an array of shorts.
Provides a Java string literal representing the parameter string.
Provides a string representation of a vector of objects.
Provides a string representation of a vector of objects.
Provides a string representation of an array.
Provides a string representation of an array.
Returns a string representation of id: label + x + sep + y + sep + z.
write a configuration in an A3CML file.
Duration in seconds during which a JMS transacted (non XA) session might
be pending; above that duration the session is rolled back and closed;
the 0 value means "no timer".
Duration in seconds during which a JMS transacted (non XA) session might
be pending; above that duration the session is rolled back and closed;
the 0 value means "no timer".
Duration in seconds during which a JMS transacted (non XA) session might
be pending; above that duration the session is rolled back and closed;
the 0 value means "no timer".
Provides a kind of unsigned byte functionality.
UMINUS - static field in class org.objectweb.joram.shared.selectors.
sym Unbinds the specified path.
Unbinds the named object.
Service method: unbinds an object.
Unbinds the named object.
An UnclusterRequest
instance is used by a client agent
for notifying a topic to leave the cluster it is part of.
Constructs an UnclusterRequest
instance.
true
if the message is considered as undeliverable.
Notify by the engine to the sender of a notification when the target agent
does not exist.
Allocates a new UnknownAgent
notification.
Thrown by Engine if a notification is sent to an unknown agent.
Constructs a new UnknownAgentException
with no
detail message.
Constructs a new UnknownAgentException
with the
specified detail message.
Thrown to indicate that the specified domain does not exist.
Constructs a new UnknownDomainException
with no
detail message.
Constructs a new UnknownDomainException
with no
detail message.
Constructs a new UnknownDomainException
with the
specified detail message.
Constructs a new UnknownDomainException
with the
specified detail message.
Notify by agents when there is no reaction allowed.
Allocates a new UnknownNotification
notification.
Thrown by Agent in the react
method to indicate
that the notification is unknown.
Constructs a new UnknownNotificationException
with
no detail message.
Constructs a new UnknownNotificationException
with
the specified detail message.
Thrown to indicate that the specified agent serverdoes not exist.
Thrown to indicate that the specified agent server does not exist.
Constructs a new UnknownServerException
with no
detail message.
Constructs a new UnknownServerException
with no
detail message.
Constructs a new UnknownServerException
with the
specified detail message.
Constructs a new UnknownServerException
with the
specified detail message.
Thrown to indicate that the specified service is not declared on a
particular server.
Thrown to indicate that the specified service does not exist.
Constructs a new UnknownServiceException
with no
detail message.
Constructs a new UnknownServiceException
with no
detail message.
Constructs a new UnknownServiceException
with the
specified detail message.
Constructs a new UnknownServiceException
with the
specified detail message.
An UnsetCluster
instance is used for notifying a topic to
leave the cluster it is part of.
Constructs an UnsetCluster
instance.
Removes a topic from the cluster it is part of.
An UnsetDefaultDMQ
instance requests to unset the default DMQ
of a given server.
Constructs a UnsetDefaultDMQ
instance.
An UnsetDefaultThreshold
instance requests to unset the
default threshold value of a given server.
Constructs a UnsetDefaultThreshold
instance.
An UnsetDestinationDMQ
instance requests to unset the DMQ of
a given destination.
Constructs an UnsetDestinationDMQ
instance.
An UnsetFather
instance is used for notifying a topic to unset
its father.
Constructs an UnsetFather
instance.
An UnsetFatherRequest
instance is used by a client agent
for notifying a topic it does not belong anymore to a hierarchy.
Constructs an UnsetFatherRequest
instance.
Admin method unsetting free reading access to this destination.
Admin method unsetting free writing access to this destination.
Unsets the father of a given topic.
Unsets the set message listener on the foreign JMS destination.
An UnsetQueueThreshold
instance requests to unset the
threshold value of a given queue.
Constructs an UnsetQueueThreshold
instance.
An UnsetReader
instance requests to unset a given user as
a reader on a given destination.
Admin method unsetting a given user as a reader on this destination.
Constructs an UnsetReader
instance.
An UnsetUserDMQ
instance requests to unset the
DMQ of a given user.
Constructs an UnsetUserDMQ
instance.
An UnsetUserThreshold
instance requests to unset
the threshold of a given user.
Constructs an UnsetUserThreshold
instance.
An UnsetWriter
instance requests to unset a given user as
a writer on a destination.
Admin method unsetting a given user as a writer on this destination.
Constructs an UnsetWriter
instance.
Gives the unsigned value of a byte.
Delegates the call to the wrapped JMS session.
An UnsubscribeRequest
instance is used by a client agent
for unsubscribing to a topic.
Constructs an UnsubscribeRequest
instance.
Updates the configuration.
Admin method updating this user identification.
An UpdateUser
instance requests the modification of a
user identification
Constructs an UpdateUser
instance.
true
if the module is fully usable.
User - class org.objectweb.joram.client.jms.admin.
User The User
class is a utility class needed for administering
JORAM users.
Constructs an User
instance.
Class of a user proxy agent.
Creates a new user proxy.
Creates a new user proxy.
User identification for connecting to the foreign JMS server.
Identification of the user requesting a connection to the
underlying JORAM server.