Serialized Form
Package fr.dyade.aaa.admin.cmd |
name
java.lang.String name
networkClass
java.lang.String networkClass
throwable
java.lang.Throwable throwable
serverName
java.lang.String serverName
domain
java.lang.String domain
port
int port
name
java.lang.String name
hostname
java.lang.String hostname
sid
java.lang.Short sid
serverName
java.lang.String serverName
className
java.lang.String className
args
java.lang.String args
serverName
java.lang.String serverName
args
java.lang.String args
port
int port
name
java.lang.String name
value
java.lang.String value
serverName
java.lang.String serverName
translationServerName
java.lang.String translationServerName
translationHostName
java.lang.String translationHostName
translationHostPort
int translationHostPort
serverName
java.lang.String serverName
sid
short sid
domainName
java.lang.String domainName
sid
short sid
serverName
java.lang.String serverName
className
java.lang.String className
args
java.lang.String args
sid
short sid
domainName
java.lang.String domainName
className
java.lang.String className
args
java.lang.String args
serverName
java.lang.String serverName
args
java.lang.String args
name
java.lang.String name
value
java.lang.String value
serverName
java.lang.String serverName
translationServerName
java.lang.String translationServerName
translationHostName
java.lang.String translationHostName
translationHostPort
int translationHostPort
serverName
java.lang.String serverName
Package fr.dyade.aaa.admin.script |
commands
java.util.Vector commands
- AdminCmd Vector
newConfig
boolean newConfig
- create new configuration
commands
java.util.Vector commands
- vector of StartAdminCmd
serverDesc
java.util.Hashtable serverDesc
- hashtable of server description
commands
java.util.Vector commands
- vector of StopAdminCmd
Package fr.dyade.aaa.agent |
exc
ExceptionCmd exc
- exception catch in start/stop
startScript
StartScript startScript
- start script
stopScript
StopScript stopScript
- stop script
status
int status
- operation status
exc
ExceptionCmd exc
- exception catch in configuration
startScript
StartScript startScript
- start script
stopScript
StopScript stopScript
- stop script
status
int status
- operation status
script
Script script
- configuration script.
autoStart
boolean autoStart
- used to start script in a same reaction.
(set configuration and start this configuration)
silence
boolean silence
- silence use for idempotence.
startScript
StartScript startScript
- start script vector
stopScript
StopScript stopScript
- stop script vector
serialVersionUID: 2955513886633164244l
readObject
private void readObject(java.io.ObjectInputStream in)
throws java.io.IOException,
java.lang.ClassNotFoundException
writeObject
private void writeObject(java.io.ObjectOutputStream out)
throws java.io.IOException
silence
boolean silence
- silence use for idempotence
startScript
StartScript startScript
- start script
stopScript
StopScript stopScript
- stop script
rollback
Script rollback
- script use to rollback a configuration
maxId
short maxId
- server id counter
serialVersionUID: 8123502821909657657l
agent
AgentId agent
serialVersionUID: -873215263839213534l
reply
AgentId reply
- Id. of agent to reply to
deploy
AgentId deploy
- Id. of agent to deploy, used since id is not more serialized in
agent state.
agentState
byte[] agentState
- Serialized state of the agent
reply
AgentId reply
- the agent identified by 'reply' will receive a DeleteAck
when destruction complete
readObject
private void readObject(java.io.ObjectInputStream in)
throws java.io.IOException,
java.lang.ClassNotFoundException
writeObject
private void writeObject(java.io.ObjectOutputStream out)
throws java.io.IOException
cause
java.lang.Throwable cause
- This class does not use the
initCause
because this class handles the deserialization
of the cause that may fail if its class is
unknown.
readObject
private void readObject(java.io.ObjectInputStream in)
throws java.io.IOException,
java.lang.ClassNotFoundException
- The
readObject
is responsible for reading from the stream
and restoring the classes fields.
writeObject
private void writeObject(java.io.ObjectOutputStream out)
throws java.io.IOException
- The
writeObject
method is responsible for writing the
state of the object for its particular class so that the corresponding
readObject
method can restore it.
readObject
private void readObject(java.io.ObjectInputStream in)
throws java.io.IOException,
java.lang.ClassNotFoundException
- The
readObject
is responsible for reading from the stream
and restoring the classes fields.
writeObject
private void writeObject(java.io.ObjectOutputStream out)
throws java.io.IOException
- The
writeObject
method is responsible for writing the
state of the object for its particular class so that the corresponding
readObject
method can restore it.
agent
AgentId agent
status
int status
exc
java.lang.Throwable exc
reply
AgentId reply
- the agent identified by 'reply' will receive a DeleteAck
when destruction complete
driver
int driver
driverKey
int driverKey
- Identifies the driver in the context of multi-connections.
serialVersionUID: -78084906213588139l
agent
AgentId agent
- The target agent id.
not
Notification not
- The failing notification.
exc
java.lang.Exception exc
- The exception thrown.
driverId
int driverId
- id of
DriverIn
agent issuing notification, when applicable
driverKey
int driverKey
- Key of the
DriverIn
issuing the notification, in a multi
connections context.
serialVersionUID: 3007264908616389613l
persistent
boolean persistent
- Context of the notification.
context
java.lang.Object context
- Context of the notification.
blockingCnx
boolean blockingCnx
- true if connect may block
multipleCnx
boolean multipleCnx
- true if proxy may handle multiple connection
inFlowControl
int inFlowControl
- flow control in driver in
multiConn
boolean multiConn
true
if the proxy manages multiple connections.
driversKey
int driversKey
- Used in multi-connections context for identifying each
connection.
finalizing
boolean finalizing
true
if the proxy is being finalized.
listener
AgentId listener
- The wrapped
AgentId
.
name
java.lang.String name
- The role name.
name
java.lang.String name
list
java.util.Vector list
sid
short sid
- Server unique identifier.
name
java.lang.String name
- Server name.
hostname
java.lang.String hostname
- Host name.
port
int port
- The communication port. This variable is set only if the server is
directly accessible from this node, in this case it corresponds to the
communication port of the server in the adjoining domain.
gateway
short gateway
- Server Id. of a gateway server for this server if it is not in a
adjoining domain.
readObject
private void readObject(java.io.ObjectInputStream in)
throws java.io.IOException,
java.lang.ClassNotFoundException
writeObject
private void writeObject(java.io.ObjectOutputStream out)
throws java.io.IOException
registry
java.util.Hashtable registry
- repository holding
Service
s
serialVersionUID: 3125179672784868254l
agent
AgentId agent
- The non-existent target agent id.
not
Notification not
- The failing notification that can not be delivered.
agent
AgentId agent
- The target agent id.
not
Notification not
- The failing notification.
Package fr.dyade.aaa.agent.conf |
serialVersionUID: -2497621374376654935l
domains
java.util.Hashtable domains
- Hashtable of all domains
servers
java.util.Hashtable servers
- Hashtable of all servers (persitent and transient)
properties
java.util.Hashtable properties
- Hashtable of all global properties
name
java.lang.String name
- Name of the domain.
network
java.lang.String network
- Full name of Java class
servers
java.util.Vector servers
- Description of alls servers in domain
gateway
short gateway
- Server Id. of router (1st hop) to access this domain from current node,
if -1 the domain is not accessible.
sid
short sid
- server id.
host
java.lang.String host
- Value of the translation host.
port
int port
- Value of the translation port.
domain
java.lang.String domain
port
int port
name
java.lang.String name
- Name of the property.
value
java.lang.String value
- Value of the property.
domain
java.lang.String domain
- Domain (1st hop) used to access this server from current node.
port
int port
- Communication port if the server is directly accessible by the root
server.
sid
short sid
name
java.lang.String name
hostname
java.lang.String hostname
services
java.util.Vector services
jvmArgs
java.lang.String jvmArgs
properties
java.util.Hashtable properties
nat
java.util.Hashtable nat
networks
java.util.Vector networks
visited
boolean visited
- True if the server is already visited during configuration phase.
gateway
short gateway
- For persistent server, Id. of router (1st hop) used to access the
server from current node. if -1 the server is not accessible. This
value is fixed during configuration phase.
For transient server, Id. of proxy used to access this server. This
value is statically fixed.
classname
java.lang.String classname
args
java.lang.String args
Package fr.dyade.aaa.jndi2.distributed |
ownerId
java.lang.Object ownerId
jndiServerIds
AgentId[] jndiServerIds
contexts
NamingContextInfo[] contexts
updateEvent
UpdateEvent updateEvent
manager
ReplicationManager manager
rootOwnerId
AgentId rootOwnerId
- Identifier of the server that owns
the root naming context.
serverIds
short[] serverIds
- List of the initially known
servers.
Package fr.dyade.aaa.jndi2.impl |
object
java.lang.Object object
formerOwnerId
java.lang.Object formerOwnerId
contexts
NamingContextInfo[] contexts
contextIdTable
ContextTable contextIdTable
contextNameTable
ContextTable contextNameTable
rootContextId
NamingContextId rootContextId
storageManager
StorageManager storageManager
id
NamingContextId id
path
javax.naming.CompositeName path
contextId
NamingContextId contextId
ownerId
java.lang.Object ownerId
path
javax.naming.CompositeName path
missingContextId
NamingContextId missingContextId
- The identifier of the missing context
name
javax.naming.CompositeName name
namingContextId
NamingContextId namingContextId
ownerId
java.lang.Object ownerId
nnfe
javax.naming.NameNotFoundException nnfe
id
NamingContextId id
ownerId
java.lang.Object ownerId
records
java.util.Vector records
factoryId
java.lang.Object factoryId
localId
long localId
namingContext
NamingContext namingContext
name
javax.naming.CompositeName name
owner
java.lang.Object owner
obj
java.lang.Object obj
object
java.lang.Object object
name
java.lang.String name
table
java.util.Hashtable table
updatedContextId
NamingContextId updatedContextId
name
java.lang.String name
Package fr.dyade.aaa.jndi2.msg |
obj
java.lang.Object obj
rebind
boolean rebind
ownerId
java.lang.String ownerId
exc
javax.naming.NamingException exc
name
javax.naming.CompositeName name
bindings
javax.naming.Binding[] bindings
pairs
javax.naming.NameClassPair[] pairs
obj
java.lang.Object obj
Package fr.dyade.aaa.jndi2.server |
manager
RequestManager manager
request
JndiRequest request
from
AgentId from
doReply
boolean doReply
entryPoints
java.util.Vector entryPoints
lifeCycleListener
LifeCycleListener lifeCycleListener
bagSerializer
BagSerializer bagSerializer
request
JndiRequest request
reply
JndiReply reply
replies
JndiReply[] replies
requests
JndiRequest[] requests
reply
boolean reply
resolvedName
javax.naming.CompositeName resolvedName
container
Container container
manager
RequestManager manager
request
JndiRequest request
ctx
RequestContext ctx
Package fr.dyade.aaa.util |
value
java.lang.String value
condition
boolean condition
stopping
boolean stopping
true
if a producer called the stop()
method.
serverName
java.lang.String serverName
hostName
java.lang.String hostName
port
int port
Package org.objectweb.joram.client.connector |
destinationType
java.lang.String destinationType
- The type of the destination to get messages from.
destination
java.lang.String destination
- The name of the destination to get messages from.
userName
java.lang.String userName
- User identification.
password
java.lang.String password
- User password.
messageSelector
java.lang.String messageSelector
- Message selector.
subscriptionDurability
java.lang.String subscriptionDurability
- Subscription durability.
subscriptionName
java.lang.String subscriptionName
- Durable subscription name, if any.
acknowledgeMode
java.lang.String acknowledgeMode
- Acknowledgement mode.
maxNumberOfWorks
java.lang.String maxNumberOfWorks
- Maximum number of work instances to be submitted (0 for infinite).
readObject
private void readObject(java.io.ObjectInputStream in)
throws java.io.IOException,
java.lang.ClassNotFoundException
- Deserializing method.
started
boolean started
true
if the adapter has been started.
stopped
boolean stopped
true
if the adapter has been stopped.
collocated
boolean collocated
true
if the underlying JORAM server is collocated.
hostName
java.lang.String hostName
- Host name or IP of the underlying JORAM server.
serverPort
int serverPort
- Port number of the underlying JORAM server.
serverId
short serverId
- Identifier of the JORAM server to start.
platformServersIds
java.util.List platformServersIds
- Platform servers identifiers.
platformConfigDir
java.lang.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.
persistentPlatform
boolean persistentPlatform
true
if the JORAM server to start is persistent.
adminFile
java.lang.String adminFile
- Path to the file containing a description of the administered objects to
create and bind.
serverName
java.lang.String serverName
- Name of the JORAM server to start.
connectingTimer
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.
txPendingTimer
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".
cnxPendingTimer
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.
readObject
private void readObject(java.io.ObjectInputStream in)
throws java.io.IOException,
java.lang.ClassNotFoundException
- Deserializing method.
collocated
boolean collocated
true
for collocated outbound connectivity.
hostName
java.lang.String hostName
- Underlying JORAM server host name.
serverPort
int serverPort
- Underlying JORAM server port number.
userName
java.lang.String userName
- Default user identification.
password
java.lang.String password
- Default user password.
connectingTimer
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.
txPendingTimer
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".
cnxPendingTimer
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.
mcf
ManagedConnectionFactoryImpl mcf
- Central manager for outbound connectivity.
cxManager
javax.resource.spi.ConnectionManager cxManager
- Manager for connection pooling.
reference
javax.naming.Reference reference
- Naming reference of this instance.
Package org.objectweb.joram.client.jms |
params
FactoryParameters params
- Object containing the factory's parameters.
agentId
java.lang.String agentId
- Identifier of the agent destination.
adminName
java.lang.String adminName
- Name given by the administrator.
host
java.lang.String host
- Name of host hosting the server to create connections with.
port
int port
- Port to be used for accessing the server.
connectingTimer
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.
txPendingTimer
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".
cnxPendingTimer
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.
cnx
Connection cnx
- The connection the queue belongs to,
null
if not known.
cnx
Connection cnx
- The connection the topic belongs to,
null
if not known.
params
FactoryParameters params
- Factory's parameters object.
Package org.objectweb.joram.client.jms.admin |
id
java.lang.String id
- Identifier of the object.
cluster
java.util.Hashtable cluster
name
java.lang.String name
- The name of the user.
proxyId
java.lang.String proxyId
- Identifier of the user's proxy agent.
Package org.objectweb.joram.client.jms.local |
Package org.objectweb.joram.client.jms.soap |
Package org.objectweb.joram.client.jms.tcp |
Package org.objectweb.joram.client.tools.admin |
userList
javax.swing.JList userList
userListModel
javax.swing.DefaultListModel userListModel
accessList
javax.swing.JList accessList
accessListModel
javax.swing.DefaultListModel accessListModel
addButton
javax.swing.JButton addButton
removeButton
javax.swing.JButton removeButton
authorized
java.util.List authorized
unauthorized
java.util.List unauthorized
c
AdminController c
configTree
javax.swing.JTree configTree
jndiTree
javax.swing.JTree jndiTree
tabbedPane
javax.swing.JTabbedPane tabbedPane
msgPane
javax.swing.JEditorPane msgPane
serverPanel
ServerPanel serverPanel
userPanel
UserPanel userPanel
destPanel
DestinationPanel destPanel
editPanel
javax.swing.JPanel editPanel
splitter
javax.swing.JSplitPane splitter
connStatus
javax.swing.JLabel connStatus
exitAction
javax.swing.Action exitAction
adminConnectAction
javax.swing.Action adminConnectAction
adminDisconnectAction
javax.swing.Action adminDisconnectAction
adminRefreshAction
javax.swing.Action adminRefreshAction
jndiConnectAction
javax.swing.Action jndiConnectAction
jndiDisconnectAction
javax.swing.Action jndiDisconnectAction
jndiRefreshAction
javax.swing.Action jndiRefreshAction
jndiCreateFactoryAction
javax.swing.Action jndiCreateFactoryAction
parent
java.awt.Frame parent
adminHost
java.lang.String adminHost
adminPort
int adminPort
adminUser
java.lang.String adminUser
adminPasswd
java.lang.String adminPasswd
hostField
javax.swing.JTextField hostField
portField
javax.swing.JFormattedTextField portField
userField
javax.swing.JTextField userField
passwdField
javax.swing.JPasswordField passwdField
actionCancelled
boolean actionCancelled
parent
java.awt.Frame parent
jndiHost
java.lang.String jndiHost
jndiPort
int jndiPort
namedCtx
java.lang.String namedCtx
hostField
javax.swing.JTextField hostField
portField
javax.swing.JFormattedTextField portField
ctxField
javax.swing.JTextField ctxField
actionCancelled
boolean actionCancelled
parent
java.awt.Frame parent
actionCancelled
boolean actionCancelled
destName
java.lang.String destName
destType
java.lang.String destType
destNameField
javax.swing.JTextField destNameField
typeGroup
javax.swing.ButtonGroup typeGroup
defaultType
javax.swing.JRadioButton defaultType
parent
java.awt.Frame parent
actionCancelled
boolean actionCancelled
host
java.lang.String host
port
int port
factoryName
java.lang.String factoryName
factoryType
java.lang.String factoryType
hostField
javax.swing.JTextField hostField
portField
javax.swing.JFormattedTextField portField
factoryNameField
javax.swing.JTextField factoryNameField
typeGroup
javax.swing.ButtonGroup typeGroup
defaultType
javax.swing.JRadioButton defaultType
parent
java.awt.Frame parent
name
java.lang.String name
passwd
java.lang.String passwd
passwd2
java.lang.String passwd2
nameField
javax.swing.JTextField nameField
passwdField
javax.swing.JPasswordField passwdField
passwd2Field
javax.swing.JPasswordField passwd2Field
submitButton
javax.swing.JButton submitButton
actionCancelled
boolean actionCancelled
c
AdminController c
dest
javax.jms.Destination dest
idLabel
javax.swing.JLabel idLabel
nameLabel
javax.swing.JLabel nameLabel
typeLabel
javax.swing.JLabel typeLabel
pendingMsgsLabel
javax.swing.JLabel pendingMsgsLabel
pendingReqsLabel
javax.swing.JLabel pendingReqsLabel
thresholdField
javax.swing.JTextField thresholdField
dmqCombo
javax.swing.JComboBox dmqCombo
freeRead
javax.swing.JCheckBox freeRead
freeWrite
javax.swing.JCheckBox freeWrite
readingACL
ACLPanel readingACL
writingACL
ACLPanel writingACL
nonZeroThreshold
boolean nonZeroThreshold
dmqSelected
boolean dmqSelected
c
AdminController c
id
int id
idLabel
javax.swing.JLabel idLabel
thresholdField
javax.swing.JTextField thresholdField
dmqCombo
javax.swing.JComboBox dmqCombo
c
AdminController c
user
User user
idLabel
javax.swing.JLabel idLabel
thresholdField
javax.swing.JTextField thresholdField
dmqCombo
javax.swing.JComboBox dmqCombo
Package org.objectweb.joram.mom.dest |
readObject
private void readObject(java.io.ObjectInputStream in)
throws java.io.IOException,
java.lang.ClassNotFoundException
- Deserializes an
AdminTopicImpl
instance.
writeObject
private void writeObject(java.io.ObjectOutputStream out)
throws java.io.IOException
- Serializes an
AdminTopicImpl
instance.
serverId
int serverId
- Identifier of the server this topic is deployed on.
queues
java.util.Vector queues
- Vector holding the local server's queues' identifiers.
deadMQueues
java.util.Vector deadMQueues
- Vector holding the local server's dead message queues' identifiers.
topics
java.util.Vector topics
- Vector holding the local server's topics' identifiers.
destinationsTable
java.util.Hashtable destinationsTable
- Table holding the local server's destinations names.
Key: destination name
Object: destination agent identifier
usersTable
java.util.Hashtable usersTable
- Table holding the TCP users identifications.
Key: user name
Object: user password
proxiesTable
java.util.Hashtable proxiesTable
- Table holding the TCP users proxies identifiers.
Key: user name
Object: proxy's identifier
requestsTable
java.util.Hashtable requestsTable
- Table keeping the administrator's requests.
Key: request's message identifier
Value: request's message ReplyTo field
msgCounter
long msgCounter
- Counter of messages produced by this AdminTopic.
defaultDMQId
AgentId defaultDMQId
- Identifier of the server's default dead message queue, kept here for
persisting it.
defaultThreshold
java.lang.Integer defaultThreshold
- Server's default threshold value, kept here for persisting it.
readObject
private void readObject(java.io.ObjectInputStream in)
throws java.io.IOException,
java.lang.ClassNotFoundException
- Deserializes a
BridgeQueueImpl
instance.
jmsModule
BridgeUnifiedModule jmsModule
- The JMS module for accessing the foreign JMS destination.
outTable
java.util.Hashtable outTable
- Table persisting the outgoing messages until acknowledgement by the
bridge module.
Key: message identifier
Value: message
readObject
private void readObject(java.io.ObjectInputStream in)
throws java.io.IOException,
java.lang.ClassNotFoundException
- Deserializes a
BridgeTopicImpl
instance.
jmsModule
BridgeUnifiedModule jmsModule
- The JMS module for accessing the foreign JMS destination.
arrivalsCounter
long arrivalsCounter
- Counter for keeping the original delivery order.
outTable
java.util.Hashtable outTable
- Table persisting the outgoing messages until acknowledgement by the
bridge module.
Key: message identifier
Value: message
period
long period
- period to eval the loading factor
producThreshold
int producThreshold
- producer threshold
consumThreshold
int consumThreshold
- consumer threshold
autoEvalThreshold
boolean autoEvalThreshold
- automatic eval threshold
waitAfterClusterReq
long waitAfterClusterReq
- waiting after a cluster request
readObject
private void readObject(java.io.ObjectInputStream in)
throws java.io.IOException,
java.lang.ClassNotFoundException
clusters
java.util.Hashtable clusters
- key = agentId of ClusterQueue
value = rateOfFlow (Float)
period
long period
- period to eval the loading factor
waitAfterClusterReq
long waitAfterClusterReq
- waiting after a cluster request
loadingFactor
LoadingFactor loadingFactor
- to calcul the loading factor, overloaded, ...
timeTable
java.util.Hashtable timeTable
- key = msgId
value = date
visitTable
java.util.Hashtable visitTable
- key = msgId
value = Vector (alreadyVisit)
clusterDeliveryCount
long clusterDeliveryCount
- number of message send to cluster
destImpl
DestinationImpl destImpl
- The reference of the
DestinationImpl
instance providing this
this agent with its Destination behaviour.
deletable
boolean deletable
true
if the destination successfully processed a deletion
request.
adminId
AgentId adminId
- Identifier of the destination's administrator.
destId
AgentId destId
- Identifier of the agent hosting the destination.
freeReading
boolean freeReading
true
if the READ access is granted to everybody.
freeWriting
boolean freeWriting
true
if the WRITE access is granted to everybody.
clients
java.util.Hashtable clients
- Table of the destination readers and writers.
dmqId
AgentId dmqId
- Identifier of the dead message queue this destination must send its
dead messages to, if any.
status
int status
- status
statusTime
long statusTime
- status time
consumerStatus
int consumerStatus
- consumer status
producerStatus
int producerStatus
- producer status
clusterQueueImpl
ClusterQueueImpl clusterQueueImpl
- reference to clusterQueueImpl
producThreshold
int producThreshold
- producer threshold
consumThreshold
int consumThreshold
- consumer threshold
autoEvalThreshold
boolean autoEvalThreshold
- automatic eval threshold
validityPeriod
long validityPeriod
- validity period
rateOfFlow
float rateOfFlow
overLoaded
boolean overLoaded
nbOfPendingMessages
int nbOfPendingMessages
nbOfPendingRequests
int nbOfPendingRequests
readObject
private void readObject(java.io.ObjectInputStream in)
throws java.io.IOException,
java.lang.ClassNotFoundException
- Deserializes a
QueueImpl
instance.
threshold
java.lang.Integer threshold
- Threshold above which messages are considered as undeliverable because
constantly denied; 0 stands for no threshold,
null
for value
not set.
samePriorities
boolean samePriorities
true
if all the stored messages have the same priority.
priority
int priority
- Common priority value.
consumers
java.util.Hashtable consumers
- Table keeping the messages' consumers identifiers.
contexts
java.util.Hashtable contexts
- Table keeping the messages' consumers contexts.
arrivalsCounter
long arrivalsCounter
- Counter of messages arrivals.
requests
java.util.Vector requests
- Vector holding the requests before reply or expiry.
persistenceModule
MessagePersistenceModule persistenceModule
- The persistence module used for managing the messages' persistence.
fatherId
AgentId fatherId
- Identifier of this topic's father, if any.
friends
java.util.Vector friends
- Vector of cluster fellows, if any.
subscribers
java.util.Vector subscribers
- Vector of subscribers' identifiers.
selectors
java.util.Hashtable selectors
- Table of subscribers' selectors.
Package org.objectweb.joram.mom.notifications |
clientContext
int clientContext
- The
clientContext
field allows a client to identify a context
within which a notification is exchanged with a destination.
This field is for the client use only and might not be set.
correlationId
int correlationId
- The
correlationId
field is equal to the request's
identifier.
requestId
int requestId
- The
requestId
field allows a client to identify the request
sent to a destination.
This field is for the client use only and might not be set.
msgId
java.lang.String msgId
- Message identifier.
msgIds
java.util.Vector msgIds
- Vector of message identifiers.
requestId
java.lang.String requestId
- Field identifying the original request.
success
boolean success
true
if the request succeeded.
info
java.lang.String info
- Info related to the processing of the request.
replyObj
java.lang.Object replyObj
- possible return object
id
java.lang.String id
- Field used for identifying the request.
message
Message message
- The message contained in the queue.
messages
java.util.Vector messages
- The messages contained in the queue.
selector
java.lang.String selector
- String selector for filtering messages, null or empty for no selection.
message
Message message
- Message sent by the client.
messages
java.util.Vector messages
- Messages sent by the client.
producerDMQId
AgentId producerDMQId
- Identifier of the producer's dead message queue, if any.
topicId
AgentId topicId
- The identifier of the topic the target topic must set a cluster with.
msgId
java.lang.String msgId
- Message identifier.
msgIds
java.util.Vector msgIds
- Vector of message identifiers.
except
MomException except
- The
MomException
which occured when processing the request.
userName
java.lang.String userName
password
java.lang.String password
clusters
java.util.Hashtable clusters
clients
java.util.Hashtable clients
freeReading
boolean freeReading
freeWriting
boolean freeWriting
clientMessages
ClientMessages clientMessages
visitTable
java.util.Hashtable visitTable
validityPeriode
long validityPeriode
clientMessages
ClientMessages clientMessages
nbMsg
int nbMsg
removeQueue
java.lang.String removeQueue
freeReading
boolean freeReading
true
if READ access is free.
freeWriting
boolean freeWriting
true
if WRITE access is free.
topics
java.util.Vector topics
- Topics identifiers.
dmqId
java.lang.String dmqId
- DMQ identifier.
threshold
java.lang.Integer threshold
- Threshold.
fatherId
java.lang.String fatherId
- Identifier of the hierarchical father.
number
int number
- The wrapped value.
users
java.util.Vector users
- Vector of readers' or writers' identifiers.
rateOfFlow
float rateOfFlow
message
Message message
- The message sent by the queue.
selector
java.lang.String selector
- String selector for filtering messages, null or empty for no selection.
timeOut
long timeOut
- The time-to-live value in milliseconds, during which a receive request
is valid.
expirationTime
long expirationTime
- The expiration time of the request.
autoAck
boolean autoAck
- If
true
, the consumed message will be immediately
deleted on the queue.
requester
AgentId requester
- Identifier of the client requesting a message, set by the queue if
storing the request.
dmqId
AgentId dmqId
- The dead message queue identifier,
null
for no DMQ.
fatherId
AgentId fatherId
- The hierarchical father identifier.
setRightRequest
SetRightRequest setRightRequest
clients
java.util.Hashtable clients
client
AgentId client
- Identifier of the user,
null
stands for all users.
right
int right
- 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.
threshold
java.lang.Integer threshold
- The threshold value, negative or zero for no threshold,
null
for unsetting the previous value.
request
SpecialAdmin request
selector
java.lang.String selector
- Selector for filtering messages, null or empty string for no selection.
messages
java.util.Vector messages
- Vector of messages.
Package org.objectweb.joram.mom.proxies |
list
java.util.Vector list
current
int current
proxyId
AgentId proxyId
- The proxy's
AgentId
identifier.
name
java.lang.String name
- The administrator's name.
pass
java.lang.String pass
- The administrator's password.
key
int key
key
int key
reliable
boolean reliable
heartBeat
int heartBeat
dmqId
AgentId dmqId
- Identifier of this proxy dead message queue,
null
for DMQ
not set.
threshold
java.lang.Integer threshold
- Threshold value, 0 or negative for no threshold,
null
for
value not set.
contexts
java.util.Hashtable contexts
- Table of the proxy's
ClientContext
instances.
Key: context identifier
Value: context
subsTable
java.util.Hashtable subsTable
- Table holding the
ClientSubscription
instances.
Key: subsription name
Value: client subscription
recoveredTransactions
java.util.Hashtable recoveredTransactions
- Table holding the recovered transactions branches.
Key: transaction identifier
Value: XACnxPrepare
instance
msgsPersistenceModule
MessagePersistenceModule msgsPersistenceModule
- The module used by the proxy's subscriptions for persisting messages.
arrivalsCounter
long arrivalsCounter
- Counter of message arrivals from topics.
proxyAgent
ProxyAgentItf proxyAgent
- The reference of the agent hosting the proxy.
id
long id
ackId
long ackId
obj
java.lang.Object obj
cKey
int cKey
msg
ProxyMessage msg
cKey
int cKey
msg
java.lang.Object msg
not
OpenConnectionNot not
key
int key
queue
java.lang.Object queue
key
int key
req
AbstractJmsRequest req
proxyImpl
ProxyImpl proxyImpl
- All the user requests are delegated
to the proxy
keyCounter
int keyCounter
- Counter of the connection keys
Package org.objectweb.joram.mom.util |
id
java.lang.String id
- Identifier of the message successfuly delivered to the foreign
JMS server.
message
Message message
- Message obtained from the foreign JMS server.
readObject
private void readObject(java.io.ObjectInputStream in)
throws java.io.IOException,
java.lang.ClassNotFoundException
- Deserializes a
BridgeUnifiedModule
instance.
agentId
AgentId agentId
- Identifier of the agent using this module.
jndiFactory
java.lang.String jndiFactory
- Name of the JNDI factory class to use.
jndiUrl
java.lang.String jndiUrl
- JNDI URL.
cnxFactName
java.lang.String cnxFactName
- ConnectionFactory JNDI name.
destName
java.lang.String destName
- Destination JNDI name.
cnxFact
javax.jms.ConnectionFactory cnxFact
- Connection factory object for connecting to the foreign JMS server.
dest
javax.jms.Destination dest
- Foreign JMS destination object.
userName
java.lang.String userName
- User identification for connecting to the foreign JMS server.
password
java.lang.String password
- User password for connecting to the foreign JMS server.
clientID
java.lang.String clientID
- JMS clientID field.
selector
java.lang.String selector
- Selector for filtering messages.
usable
boolean usable
true
if the module is fully usable.
notUsableMessage
java.lang.String notUsableMessage
- Message explaining why the module is not usable.
readObject
private void readObject(java.io.ObjectInputStream in)
throws java.io.IOException,
java.lang.ClassNotFoundException
- Deserializes a
PersistenceModule
.
agentId
AgentId agentId
- Identifier of the agent using the module.
vectorsTable
java.util.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
counter
long counter
- Counter of persistence objects.
Package org.objectweb.joram.shared.admin |
joiningQueue
java.lang.String joiningQueue
success
boolean success
true
if this reply replies to a successful request.
info
java.lang.String info
- Information.
replyObj
java.lang.Object replyObj
- Object.
id
java.lang.String id
- Identifier of the created destination.
serverId
int serverId
- Id of the server where deploying the destination.
name
java.lang.String name
- Name attributed to the destination.
className
java.lang.String className
- Name of the class to be instanciated.
prop
java.util.Properties prop
- Properties needed to create destination object.
id
java.lang.String id
- Identifier of the user's proxy.
userName
java.lang.String userName
- Name of the user.
userPass
java.lang.String userPass
- Password of the user.
serverId
int serverId
- Id of the server where deploying the proxy.
id
java.lang.String id
- Identifier of the destination to delete.
userName
java.lang.String userName
- Name of the user to delete.
proxId
java.lang.String proxId
- Identifier of the user's proxy.
topic
java.lang.String topic
- Identifier of a topic part of the target cluster.
topics
java.util.Vector topics
- Identifiers of the cluster's topics.
serverId
int serverId
- Identifier of the target server.
queues
java.util.Vector queues
- Queues identifiers.
dmqs
java.util.Vector dmqs
- Dead message queues identifiers.
topics
java.util.Vector topics
- Topics identifiers.
names
java.util.Hashtable names
- Destinations' names, if any.
serverId
int serverId
- Identifier of the target server.
target
java.lang.String target
- Identifier of the target queue or user.
dmqId
java.lang.String dmqId
- DMQ identifier.
threshold
java.lang.Integer threshold
- Threshold.
topic
java.lang.String topic
- Identifier of the target topic.
fatherId
java.lang.String fatherId
- Identifier of the hierarchical father.
dest
java.lang.String dest
- Identifier of the target destination.
freeReading
boolean freeReading
true
if READ access is free.
freeWriting
boolean freeWriting
true
if WRITE access is free.
number
int number
- The integer value.
dest
java.lang.String dest
- Identifier of the target destination.
dest
java.lang.String dest
- Identifier of the target destination.
dest
java.lang.String dest
- Identifier of the target destination.
serverId
int serverId
- Identifier of the target server.
ids
java.util.Vector ids
- Servers identifiers.
dest
java.lang.String dest
- Identifier of the target topic.
serverId
int serverId
- Identifier of the target server.
users
java.util.Hashtable users
- Table holding the users identifications.
dest
java.lang.String dest
- Identifier of the target destination.
removeQueue
java.lang.String removeQueue
initId
java.lang.String initId
- Identifier of the topic already part of a cluster, or chosen as the
initiator.
topId
java.lang.String topId
- Identifier of the topic joining the cluster, or the initiator.
serverId
int serverId
- Identifier of the server the DMQ is set for.
dmqId
java.lang.String dmqId
- Identifier of the DMQ.
serverId
int serverId
- Identifier of the server the threshold is set for.
threshold
int threshold
- Threshold value.
destId
java.lang.String destId
- Identifier of the destination the DMQ is set for.
dmqId
java.lang.String dmqId
- Identifier of the DMQ.
father
java.lang.String father
- Identifier of the father.
son
java.lang.String son
- Identifier of the son.
queueId
java.lang.String queueId
- Identifier of the queue the threshold is set for.
threshold
int threshold
- Threshold value.
userProxId
java.lang.String userProxId
- Identifier of the user's proxy,
null
for all users.
destId
java.lang.String destId
- Identifier of the destination.
userProxId
java.lang.String userProxId
- Identifier of the user's proxy the DMQ is set for.
dmqId
java.lang.String dmqId
- Identifier of the DMQ.
userProxId
java.lang.String userProxId
- Identifier of the user's proxy the threshold is set for.
threshold
int threshold
- Threshold value.
destId
java.lang.String destId
- Identifier of the destination.
serverId
int serverId
- Id of the server to stop.
id
java.lang.String id
- Identifier of the topic leaving its cluster.
serverId
int serverId
- Identifier of the server which default DMQ is unset.
serverId
int serverId
- Identifier of the server which threshold is unset.
destId
java.lang.String destId
- Identifier of the destination which DMQ is unset.
id
java.lang.String id
- Identifier of the topic.
queueId
java.lang.String queueId
- Identifier of the queue which threshold is unset.
userProxId
java.lang.String userProxId
- Identifier of the user's proxy which DMQ is unset.
userProxId
java.lang.String userProxId
- Identifier of the user's proxy which threshold is unset.
userName
java.lang.String userName
- Name of the user.
proxId
java.lang.String proxId
- Identifier of the user's proxy.
newName
java.lang.String newName
- New name of the user.
newPass
java.lang.String newPass
- New password of the user.
Package org.objectweb.joram.shared.client |
correlationId
int correlationId
- Identifier of the replied request.
requestId
int requestId
- Identifier of the request.
target
java.lang.String target
- The request target is either a destination agent name, or a subscription
name.
cnxKey
int cnxKey
- The connection's key.
proxyId
java.lang.String proxyId
- The proxy's identifier.
id
java.lang.String id
- Message identifier.
queueMode
boolean queueMode
true
if the request is destinated to a queue.
id
java.lang.String id
- Message identifier.
queueMode
boolean queueMode
true
if the request is destinated to a queue.
doNotAck
boolean doNotAck
true
if the request must not be acked by the server.
message
Message message
- Wrapped message.
messages
java.util.Vector messages
- Wrapped messages.
comingFrom
java.lang.String comingFrom
- Name of the subscription or the queue the messages come from.
queueMode
boolean queueMode
true
if the messages come from a queue.
selector
java.lang.String selector
- The selector for filtering messages on a queue.
timeToLive
long timeToLive
- The time to live value of the request (negative for infinite).
queueMode
boolean queueMode
true
if the request is destinated to a queue.
selector
java.lang.String selector
- Selector for filtering messages on a queue.
queueMode
boolean queueMode
true
if the request is destinated to a queue.
subName
java.lang.String subName
- The subscription's name.
selector
java.lang.String selector
- The selector for filtering messages.
noLocal
boolean noLocal
true
if the subscriber does not wish to consume messages
produced by its connection.
durable
boolean durable
true
if the subscription is durable.
queueMode
boolean queueMode
true
if the listener is listening to a queue.
cancelledRequestId
int cancelledRequestId
- Identifier of the last listener request, cancelled by this
request, queue mode only.
id
java.lang.String id
- Identifier of the admin topic.
momExcept
MomException momExcept
- The wrapped exception.
message
Message message
- The wrapped message.
messages
java.util.Vector messages
- The wrapped messages.
message
Message message
- The message carried by this reply.
messages
java.util.Vector messages
- The vector of messages carried by this reply.
selector
java.lang.String selector
- The selector for filtering messages.
ids
java.util.Vector ids
- Vector of message identifiers.
queueMode
boolean queueMode
true
if the request is destinated to a queue.
agentId
java.lang.String agentId
- The string identifier of the temporary destination agent.
ids
java.util.Vector ids
- Vector of message identifiers.
queueMode
boolean queueMode
true
if the request is destinated to a queue.
doNotAck
boolean doNotAck
true
if the request must not be acked by the server.
bq
byte[] bq
- Transaction branch qualifier.
fi
int fi
- Transaction identifier format.
gti
byte[] gti
- Global transaction identifier.
bq
byte[] bq
- Transaction branch qualifier.
fi
int fi
- Transaction identifier format.
gti
byte[] gti
- Global transaction identifier.
sendings
java.util.Vector sendings
- Vector of
ProducerMessages
instances.
acks
java.util.Vector acks
- Vector of
SessAckRequest
instances.
bqs
java.util.Vector bqs
- Branch qualifiers.
fis
java.util.Vector fis
- Format identifiers.
gtis
java.util.Vector gtis
- Global transaction identifiers.
bq
byte[] bq
- Transaction branch qualifier.
fi
int fi
- Transaction identifier format.
gti
byte[] gti
- Global transaction identifier.
qDenyings
java.util.Hashtable qDenyings
- Table holding the identifiers of the messages to deny on queues.
subDenyings
java.util.Hashtable subDenyings
- Table holding the identifiers of the messages to deny on subs.
Package org.objectweb.joram.shared.excepts |
Package org.objectweb.joram.shared.messages |
readObject
private void readObject(java.io.ObjectInputStream s)
throws java.io.IOException,
java.lang.ClassNotFoundException
- Specializes the deserialization method for initializing the message's
transient fields.
writeObject
private void writeObject(java.io.ObjectOutputStream s)
throws java.io.IOException
- Specializes the serialization method for protecting the message's
properties and body as soon as it is sent.
type
int type
- The message type (SIMPLE, TEXT, OBJECT, MAP, STREAM, BYTES).
persistent
boolean persistent
true
if the message must be persisted.
id
java.lang.String id
- The message identifier.
priority
int priority
- The message priority (from 0 to 9, 9 being the highest).
expiration
long expiration
- The message expiration time (0 for infinite time-to-live).
timestamp
long timestamp
- The message time stamp.
toId
java.lang.String toId
- The message destination identifier.
toQueue
boolean toQueue
true
if the message destination is a queue.
correlationId
java.lang.String correlationId
- The correlation identifier field.
replyToId
java.lang.String replyToId
- The reply to destination identifier.
replyToQueue
boolean replyToQueue
true
if the "reply to" destination is a queue.
optionalHeader
java.util.Hashtable optionalHeader
- Table holding header fields that may be required by particular
clients (such as JMS clients).
body_bytes
byte[] body_bytes
- The bytes body.
body_map
java.util.HashMap body_map
- The map body.
body_text
java.lang.String body_text
- The text body.
bodyRO
boolean bodyRO
true
if the body is read-only.
properties
java.util.Hashtable properties
- The message properties table.
propertiesRO
boolean propertiesRO
true
if the properties are read-only.
order
long order
- Arrival position of this message on its queue or proxy.
deliveryCount
int deliveryCount
- The number of delivery attempts for this message.
denied
boolean denied
true
if the message has been denied at least once by a
consumer.
deletedDest
boolean deletedDest
true
if the message target destination is deleted.
expired
boolean expired
true
if the message expired.
notWriteable
boolean notWriteable
true
if the message could not be written on the dest.
undeliverable
boolean undeliverable
true
if the message is considered as undeliverable.
Copyright ? 2004 Scalagent - All rights reserved