Frames | No Frames |
String destinationType
The type of the destination to get messages from.
String destination
The name of the destination to get messages from.
String userName
User identification.
String password
User password.
String messageSelector
Message selector.
String subscriptionDurability
Subscription durability.
String subscriptionName
Durable subscription name, if any.
String acknowledgeMode
Acknowledgement mode.
String maxNumberOfWorks
Maximum number of work instances to be submitted (0 for infinite).
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException
Deserializing method.
boolean started
true
if the adapter has been started.
boolean stopped
true
if the adapter has been stopped.
boolean collocated
true
if the underlying JORAM server is collocated.
String hostName
Host name or IP of the underlying JORAM server.
int serverPort
Port number of the underlying JORAM server.
short serverId
Identifier of the JORAM server to start.
List platformServersIds
Platform servers identifiers.
String platformConfigDir
Path to the directory containing JORAM's configuration files (a3servers.xml
,a3debug.cfg
and admin file), needed when starting the collocated JORAM server.
boolean persistentPlatform
true
if the JORAM server to start is persistent.
String adminFile
Path to the file containing a description of the administered objects to create and bind.
String serverName
Name of the JORAM server to start.
int connectingTimer
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.
int txPendingTimer
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".
int cnxPendingTimer
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.
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException
Deserializing method.
boolean collocated
true
for collocated outbound connectivity.
String hostName
Underlying JORAM server host name.
int serverPort
Underlying JORAM server port number.
String userName
Default user identification.
String password
Default user password.
int connectingTimer
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.
int txPendingTimer
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".
int cnxPendingTimer
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.
ConnectionManager cxManager
Manager for connection pooling.
Reference reference
Naming reference of this instance.
String agentId
Identifier of the agent destination.
String adminName
Name given by the administrator.
String host
Name of host hosting the server to create connections with.
int port
Port to be used for accessing the server.
int connectingTimer
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.
int txPendingTimer
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".
int cnxPendingTimer
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.
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException
Serializes anAdminTopicImpl
instance.
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException
Deserializes anAdminTopicImpl
instance.
int serverId
Identifier of the server this topic is deployed on.
Vector queues
Vector holding the local server's queues' identifiers.
Vector deadMQueues
Vector holding the local server's dead message queues' identifiers.
Vector topics
Vector holding the local server's topics' identifiers.
Hashtable destinationsTable
Table holding the local server's destinations names. Key: destination name
Object: destination agent identifier
Hashtable usersTable
Table holding the TCP users identifications. Key: user name
Object: user password
Hashtable proxiesTable
Table holding the TCP users proxies identifiers. Key: user name
Object: proxy's identifier
Hashtable requestsTable
Table keeping the administrator's requests. Key: request's message identifier
Value: request's message ReplyTo field
long msgCounter
Counter of messages produced by this AdminTopic.
AgentId defaultDMQId
Identifier of the server's default dead message queue, kept here for persisting it.
Integer defaultThreshold
Server's default threshold value, kept here for persisting it.
private void readObject(java.io.ObjectInputStream in) throws IOException, ClassNotFoundException
Deserializes aBridgeQueueImpl
instance.
Hashtable outTable
Table persisting the outgoing messages until acknowledgement by the bridge module. Key: message identifier
Value: message
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException
Deserializes aBridgeTopicImpl
instance.
long arrivalsCounter
Counter for keeping the original delivery order.
Hashtable outTable
Table persisting the outgoing messages until acknowledgement by the bridge module. Key: message identifier
Value: message
private void readObject(java.io.ObjectInputStream in) throws IOException, ClassNotFoundException
Deserializes aQueueImpl
instance.
Hashtable clusters
key = agentId of ClusterQueue value = rateOfFlow (Float)
long period
period to eval the loading factor
long waitAfterClusterReq
waiting after a cluster request
Hashtable timeTable
key = msgId value = date
Hashtable visitTable
key = msgId value = Vector (alreadyVisit)
long clusterDeliveryCount
number of message send to cluster
boolean deletable
true
if the destination successfully processed a deletion request.
boolean freeReading
true
if the READ access is granted to everybody.
boolean freeWriting
true
if the WRITE access is granted to everybody.
Hashtable clients
Table of the destination readers and writers.
AgentId dmqId
Identifier of the dead message queue this destination must send its dead messages to, if any.
private void readObject(java.io.ObjectInputStream in) throws IOException, ClassNotFoundException
Deserializes aQueueImpl
instance.
Integer threshold
Threshold above which messages are considered as undeliverable because constantly denied; 0 stands for no threshold,null
for value not set.
boolean samePriorities
true
if all the stored messages have the same priority.
int priority
Common priority value.
Hashtable consumers
Table keeping the messages' consumers identifiers.
Hashtable contexts
Table keeping the messages' consumers contexts.
long arrivalsCounter
Counter of messages arrivals.
Vector requests
Vector holding the requests before reply or expiry.
MessagePersistenceModule persistenceModule
The persistence module used for managing the messages' persistence.
Vector friends
Vector of cluster fellows, if any.
Vector subscribers
Vector of subscribers' identifiers.
Hashtable selectors
Table of subscribers' selectors.
Integer threshold
Threshold value, 0 or negative for no threshold,null
for value not set.
Hashtable contexts
Table of the proxy'sClientContext
instances. Key: context identifier
Value: context
Hashtable subsTable
Table holding theClientSubscription
instances. Key: subsription name
Value: client subscription
Hashtable recoveredTransactions
Table holding the recovered transactions branches. Key: transaction identifier
Value:XACnxPrepare
instance
MessagePersistenceModule msgsPersistenceModule
The module used by the proxy's subscriptions for persisting messages.
long arrivalsCounter
Counter of message arrivals from topics.
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException
Deserializes aBridgeUnifiedModule
instance.
String jndiFactory
Name of the JNDI factory class to use.
String jndiUrl
JNDI URL.
String cnxFactName
ConnectionFactory JNDI name.
String destName
Destination JNDI name.
ConnectionFactory cnxFact
Connection factory object for connecting to the foreign JMS server.
Destination dest
Foreign JMS destination object.
String userName
User identification for connecting to the foreign JMS server.
String password
User password for connecting to the foreign JMS server.
String clientID
JMS clientID field.
String selector
Selector for filtering messages.
boolean usable
true
if the module is fully usable.
String notUsableMessage
Message explaining why the module is not usable.
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException
Deserializes aPersistenceModule
.
Hashtable vectorsTable
Table of the identifiers of the messages persisted in vectors. Key: name of the persistence vector
Value: table of identifiers of the persisted messages
long counter
Counter of persistence objects.
boolean success
true
if this reply replies to a successful request.
String info
Information.
Object replyObj
Object.
int serverId
Id of the server where deploying the destination.
String name
Name attributed to the destination.
String className
Name of the class to be instanciated.
Properties prop
Properties needed to create destination object.
String userName
Name of the user.
String userPass
Password of the user.
int serverId
Id of the server where deploying the proxy.
String userName
Name of the user to delete.
String proxId
Identifier of the user's proxy.
Vector queues
Queues identifiers.
Vector dmqs
Dead message queues identifiers.
Vector topics
Topics identifiers.
Hashtable names
Destinations' names, if any.
int serverId
Identifier of the target server.
String target
Identifier of the target queue or user.
boolean freeReading
true
if READ access is free.
boolean freeWriting
true
if WRITE access is free.
String initId
Identifier of the topic already part of a cluster, or chosen as the initiator.
String topId
Identifier of the topic joining the cluster, or the initiator.
int serverId
Identifier of the server the DMQ is set for.
String dmqId
Identifier of the DMQ.
int serverId
Identifier of the server the threshold is set for.
int threshold
Threshold value.
String destId
Identifier of the destination the DMQ is set for.
String dmqId
Identifier of the DMQ.
String queueId
Identifier of the queue the threshold is set for.
int threshold
Threshold value.
String userProxId
Identifier of the user's proxy,null
for all users.
String destId
Identifier of the destination.
String userProxId
Identifier of the user's proxy the DMQ is set for.
String dmqId
Identifier of the DMQ.
String userProxId
Identifier of the user's proxy the threshold is set for.
int threshold
Threshold value.
String userName
Name of the user.
String proxId
Identifier of the user's proxy.
String newName
New name of the user.
String newPass
New password of the user.
int requestId
Identifier of the request.
String target
The request target is either a destination agent name, or a subscription name.
String id
Message identifier.
boolean queueMode
true
if the request is destinated to a queue.
String id
Message identifier.
boolean queueMode
true
if the request is destinated to a queue.
boolean doNotAck
true
if the request must not be acked by the server.
Vector messages
Wrapped messages.
String comingFrom
Name of the subscription or the queue the messages come from.
boolean queueMode
true
if the messages come from a queue.
String selector
The selector for filtering messages on a queue.
long timeToLive
The time to live value of the request (negative for infinite).
boolean queueMode
true
if the request is destinated to a queue.
String selector
Selector for filtering messages on a queue.
boolean queueMode
true
if the request is destinated to a queue.
String subName
The subscription's name.
String selector
The selector for filtering messages.
boolean noLocal
true
if the subscriber does not wish to consume messages produced by its connection.
boolean durable
true
if the subscription is durable.
boolean queueMode
true
if the listener is listening to a queue.
int cancelledRequestId
Identifier of the last listener request, cancelled by this request, queue mode only.
Vector ids
Vector of message identifiers.
boolean queueMode
true
if the request is destinated to a queue.
Vector ids
Vector of message identifiers.
boolean queueMode
true
if the request is destinated to a queue.
boolean doNotAck
true
if the request must not be acked by the server.
byte[] bq
Transaction branch qualifier.
int fi
Transaction identifier format.
byte[] gti
Global transaction identifier.
byte[] bq
Transaction branch qualifier.
int fi
Transaction identifier format.
byte[] gti
Global transaction identifier.
Vector sendings
Vector ofProducerMessages
instances.
Vector acks
Vector ofSessAckRequest
instances.
Vector bqs
Branch qualifiers.
Vector fis
Format identifiers.
Vector gtis
Global transaction identifiers.
byte[] bq
Transaction branch qualifier.
int fi
Transaction identifier format.
byte[] gti
Global transaction identifier.
Hashtable qDenyings
Table holding the identifiers of the messages to deny on queues.
Hashtable subDenyings
Table holding the identifiers of the messages to deny on subs.