Serialized Form

Package com.scalagent.joram.mom.dest.ftp

Class com.scalagent.joram.mom.dest.ftp.FtpNot extends ClientMessages implements Serializable

serialVersionUID:

1L

Class com.scalagent.joram.mom.dest.ftp.FtpQueue extends Queue implements Serializable

serialVersionUID:

1L

Serialized Fields

clientContext

int clientContext

dmq

AgentId dmq

ftpImplName

String ftpImplName

pass

String pass

path

String path

requestId

int requestId

transferTable

Hashtable<String,FtpMessage> transferTable

user

String user

Package com.scalagent.joram.mom.dest.rest

Class com.scalagent.joram.mom.dest.rest.MessageFormatException extends Exception implements Serializable

serialVersionUID:

1L

Serialized Fields

linkedException

Exception linkedException

Exception reference.

Package com.scalagent.joram.mom.dest.scheduler

Class com.scalagent.joram.mom.dest.scheduler.SchedulerQueue extends Queue implements Serializable

serialVersionUID:

1L

Serialized Fields

scheduler

Scheduler scheduler

Class com.scalagent.joram.mom.dest.scheduler.SchedulerQueueNot extends Notification implements Serializable

serialVersionUID:

1L

Class com.scalagent.joram.mom.dest.scheduler.SchedulerQueueTask extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

schedulerQueue

AgentId schedulerQueue

Package com.scalagent.scheduler

Class com.scalagent.scheduler.CronEvent extends ScheduleEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

ranges

BitSet[] ranges

cron dates for this event

Class com.scalagent.scheduler.ScheduleEvent extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

date

Date date

event scheduling date

name

String name

event name

outdatedRestart

boolean outdatedRestart

execute outdated event on restart

Class com.scalagent.scheduler.ScheduleItem extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

date

Date date

next schedule date

event

ScheduleEvent event

may be of a derived class

next

ScheduleItem next

next item, null terminated

prev

ScheduleItem prev

previous item, null terminated

task

ScheduleTask task

the schedule task

Class com.scalagent.scheduler.Scheduler extends Object implements Serializable

serialVersionUID:

2L

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Class com.scalagent.scheduler.Scheduler.WakeUp extends TimerTask implements Serializable

serialVersionUID:

1L

Package fr.dyade.aaa.agent

Class fr.dyade.aaa.agent.AdminSyncNotification extends SyncNotification implements Serializable

serialVersionUID:

522L

Serialized Fields

command

int command

parameters

Properties parameters

quiet

boolean quiet

Class fr.dyade.aaa.agent.Agent extends Object implements Serializable

serialVersionUID:

1L

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

agentProfiling

boolean agentProfiling

Boolean value indicating if the agent profiling is on. If true, the cumulative time of reaction and commit is kept for this agent.

Class fr.dyade.aaa.agent.AgentCreateReply extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

agent

AgentId agent

Class fr.dyade.aaa.agent.AgentCreateRequest extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

agentState

byte[] agentState

Serialized state of the agent

deploy

AgentId deploy

Id. of agent to deploy, used since id is not more serialized in agent state.

reply

AgentId reply

Id. of agent to reply to

Class fr.dyade.aaa.agent.AgentDeleteRequest extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

extraInformation

Object extraInformation

The extra information is added to the DeleteAck when notifying the reply agent.

reply

AgentId reply

the agent identified by 'reply' will receive a DeleteAck when destruction complete

Class fr.dyade.aaa.agent.AgentException extends Exception implements Serializable

serialVersionUID:

1L

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

cause

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.

Class fr.dyade.aaa.agent.AgentId extends Object implements Serializable

serialVersionUID:

1L

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

The readObject is responsible for reading from the stream and restoring the classes fields.

Throws:

IOException - an error occurs.

ClassNotFoundException - an error occurs.

writeObject

private void writeObject(ObjectOutputStream out)
                  throws 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.

Throws:

IOException - an error occurs.

Class fr.dyade.aaa.agent.CallbackNotification extends Notification implements Serializable

serialVersionUID:

5725173357445928809L

Class fr.dyade.aaa.agent.DeleteAck extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

agent

AgentId agent

exc

Throwable exc

extraInformation

Object extraInformation

status

int status

Class fr.dyade.aaa.agent.DeleteNot extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

reply

AgentId reply

the agent identified by 'reply' will receive a DeleteAck when destruction complete

Class fr.dyade.aaa.agent.ExceptionNotification extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

agent

AgentId agent

The target agent id.

exc

Exception exc

The exception thrown.

not

Notification not

The failing notification.

Class fr.dyade.aaa.agent.ExpirationExceededException extends Exception implements Serializable

serialVersionUID:

1L

Class fr.dyade.aaa.agent.ExpiredNot extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

expiredNot

Notification expiredNot

The expiration which had expired.

from

AgentId from

The agent which sent the expired notification.

to

AgentId to

The destination agent of the expired notification.

Class fr.dyade.aaa.agent.FlowControlNot extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

driverId

int driverId

Deprecated.

id of DriverIn agent issuing notification, when applicable

driverKey

int driverKey

Deprecated.

Key of the DriverIn issuing the notification, in a multi connections context.

Class fr.dyade.aaa.agent.Message extends Object implements Serializable

serialVersionUID:

1L

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

The readObject method is responsible for reading from the stream and restoring the classes fields. Be careful this method should only be used for restoring messages from persistent storage, receiving messages will be done by another way.

Throws:

IOException - an error occurs.

ClassNotFoundException - an error occurs.

writeObject

private void writeObject(ObjectOutputStream out)
                  throws 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. Be careful this method should only be used for saving messages in persistent storage, sending messages will be done by another way. It is also used for HA synchronization.

Throws:

IOException - an error occurs.

Serialized Fields

serializedNot

SerializableWrapper serializedNot

Class fr.dyade.aaa.agent.Notification extends Object implements Serializable

serialVersionUID:

1L

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

The readObject method is responsible for reading from the stream and restoring the classes fields.

Throws:

IOException - if an errors occurs during read.

ClassNotFoundException - a needed class cannot be found.

writeObject

private void writeObject(ObjectOutputStream out)
                  throws 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.

Throws:

IOException - if an errors occurs.

Serialized Fields

context

Object context

Context of the notification. /!\ Be careful, the related object must be serialized either through Serializable or Encodable interfaces, depending of the notification serialization mode. It seems difficult to use, may be we should use a byte array handled by the application. TODO (AF): It seems never used in Joram/JoramMQ.

deadNotificationAgentId

AgentId deadNotificationAgentId

The agentId identifying the agent to which the notification is sent when it is expired.
Default value is null, which means the expired notification is lost.

expiration

long expiration

The expiration date for this notification. This field is handled by the network protocol in order to fit the time synchronization problem.

priority

int priority

The priority for this notification from 0 to 9, 9 being the highest. By default, the priority is 4

Class fr.dyade.aaa.agent.Role extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

listener

AgentId listener

The wrapped AgentId.

name

String name

The role name.

Class fr.dyade.aaa.agent.RoleMultiple extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

list

Vector<AgentId> list

name

String name

Class fr.dyade.aaa.agent.ServerConfigHelper.NameAlreadyUsedException extends Exception implements Serializable

serialVersionUID:

1L

Class fr.dyade.aaa.agent.ServerConfigHelper.ServerIdAlreadyUsedException extends Exception implements Serializable

serialVersionUID:

1L

Class fr.dyade.aaa.agent.ServerConfigHelper.StartFailureException extends Exception implements Serializable

serialVersionUID:

1L

Class fr.dyade.aaa.agent.ServerDesc extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

gateway

short gateway

Server Identifier of a gateway server for this server if it is not in an adjoining domain.

name

String name

Server name.

sid

short sid

Server unique identifier.

sockAddrs

Vector<SocketAddress> sockAddrs

The IP address of the server. It contains hostname and port (SocketAddress) of remote server. The communication port 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. The descriptor of an HA server contains one SocketAddress for each of its constituent.

Class fr.dyade.aaa.agent.ServerUpdate extends Object implements Serializable

serialVersionUID:

1L

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

update

String update

Date of the update.

Class fr.dyade.aaa.agent.ServiceDesc extends Object implements Serializable

serialVersionUID:

1L

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Class fr.dyade.aaa.agent.ServiceManager extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

registry

Hashtable<String,ServiceDesc> registry

repository holding Services

Class fr.dyade.aaa.agent.SyncNotification extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

caller

Thread caller

Class fr.dyade.aaa.agent.TransactionError extends VirtualMachineError implements Serializable

serialVersionUID:

1L

Class fr.dyade.aaa.agent.UnknownAgent extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

agent

AgentId agent

The non-existent target agent id.

not

Notification not

The failing notification that can not be delivered.

Class fr.dyade.aaa.agent.UnknownAgentException extends Exception implements Serializable

serialVersionUID:

1L

Serialized Fields

unknownAgentId

AgentId unknownAgentId

Class fr.dyade.aaa.agent.UnknownDomainException extends Exception implements Serializable

serialVersionUID:

1L

Class fr.dyade.aaa.agent.UnknownNotification extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

agent

AgentId agent

The target agent id.

not

Notification not

The failing notification.

Class fr.dyade.aaa.agent.UnknownNotificationException extends Exception implements Serializable

serialVersionUID:

1L

Class fr.dyade.aaa.agent.UnknownServerException extends Exception implements Serializable

serialVersionUID:

1L

Class fr.dyade.aaa.agent.UnknownServiceException extends Exception implements Serializable

serialVersionUID:

1L

Package fr.dyade.aaa.agent.conf

Class fr.dyade.aaa.agent.conf.A3CMLConfig extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

domains

Hashtable<String,A3CMLDomain> domains

Hashtable of all domains

properties

Hashtable<String,A3CMLProperty> properties

Hashtable of all global properties

servers

Hashtable<Short,A3CMLServer> servers

Hashtable of all servers (persistent and transient)

Class fr.dyade.aaa.agent.conf.A3CMLDomain extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

gateway

short gateway

Server Id. of router (1st hop) to access this domain from current node, if -1 the domain is not accessible.

hops

int hops

Logical distance between the server of this domain and the root one, i.e. the number of hops to reach a server from the local one.

name

String name

Name of the domain.

network

String network

Full name of Java class

servers

Vector<A3CMLServer> servers

Description of alls servers in domain

Class fr.dyade.aaa.agent.conf.A3CMLNat extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

host

String host

Value of the translation host.

port

int port

Value of the translation port.

sid

short sid

server id.

Class fr.dyade.aaa.agent.conf.A3CMLNetwork extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

domain

String domain

port

int port

Class fr.dyade.aaa.agent.conf.A3CMLProperty extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

name

String name

Name of the property.

value

String value

Value of the property.

Class fr.dyade.aaa.agent.conf.A3CMLServer extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

domain

String domain

Domain (1st hop) used to access this server from current node.

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.

hops

int hops

Logical distance between this server and the root one, i.e. the number of hops to reach it from the local one.

hostname

String hostname

jvmArgs

String jvmArgs

name

String name

nat

Hashtable<Short,A3CMLNat> nat

networks

Vector<A3CMLNetwork> networks

port

int port

Communication port if the server is directly accessible by the root server.

properties

Hashtable<String,A3CMLProperty> properties

services

Vector<A3CMLService> services

sid

short sid

visited

boolean visited

True if the server is already visited during configuration phase.

Class fr.dyade.aaa.agent.conf.A3CMLService extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

args

String args

classname

String classname

Class fr.dyade.aaa.agent.conf.DuplicateClusterException extends Exception implements Serializable

serialVersionUID:

1L

Class fr.dyade.aaa.agent.conf.DuplicateDomainException extends Exception implements Serializable

serialVersionUID:

1L

Class fr.dyade.aaa.agent.conf.DuplicateServerException extends Exception implements Serializable

serialVersionUID:

1L

Class fr.dyade.aaa.agent.conf.ParseException extends Exception implements Serializable

serialVersionUID:

1L

Serialized Fields

fileName

String fileName

Name of the configuration file. May be set after the exception has been created.

Class fr.dyade.aaa.agent.conf.UnknownClusterException extends Exception implements Serializable

serialVersionUID:

1L

Class fr.dyade.aaa.agent.conf.UnknownDomainException extends Exception implements Serializable

serialVersionUID:

1L

Class fr.dyade.aaa.agent.conf.UnknownServerException extends Exception implements Serializable

serialVersionUID:

1L

Class fr.dyade.aaa.agent.conf.UnknownServiceException extends Exception implements Serializable

serialVersionUID:

1L

Package fr.dyade.aaa.common

Class fr.dyade.aaa.common.EmptyQueueException extends RuntimeException implements Serializable

serialVersionUID:

1L

Class fr.dyade.aaa.common.Queue extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

closed

boolean closed

true if the queue has been closed.

elements

List<Object> elements

The list holding queue elements.

stopping

boolean stopping

true if a producer called the stop() method.

Class fr.dyade.aaa.common.StoppedQueueException extends RuntimeException implements Serializable

serialVersionUID:

1L

Package fr.dyade.aaa.common.encoding

Class fr.dyade.aaa.common.encoding.EncodableInteger extends Object implements Serializable

Serialized Fields

value

int value

Class fr.dyade.aaa.common.encoding.EncodedString extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

encodedString

byte[] encodedString

string

String string

Class fr.dyade.aaa.common.encoding.EncodedStringList extends Object implements Serializable

Serialized Fields

list

List<EncodedString> list

Package fr.dyade.aaa.common.stream

Class fr.dyade.aaa.common.stream.Properties extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Package fr.dyade.aaa.jndi2.distributed

Class fr.dyade.aaa.jndi2.distributed.CreateRemoteSubcontextRequest extends CreateSubcontextRequest implements Serializable

serialVersionUID:

1L

Serialized Fields

ownerId

Object ownerId

Class fr.dyade.aaa.jndi2.distributed.InitJndiServerNot extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

contexts

NamingContextInfo[] contexts

isRequest

boolean isRequest

Indicates whether this notification is a request (spontaneously sent) or a reply to a request.

jndiServerIds

AgentId[] jndiServerIds

Class fr.dyade.aaa.jndi2.distributed.JndiUpdateNot extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

updateEvent

UpdateEvent updateEvent

Class fr.dyade.aaa.jndi2.distributed.ReplicationEntryPoint extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

manager

ReplicationManager manager

Class fr.dyade.aaa.jndi2.distributed.ReplicationManager extends RequestManager implements Serializable

serialVersionUID:

1L

Serialized Fields

looseCoupling

boolean looseCoupling

rootOwnerId

AgentId rootOwnerId

Identifier of the server that owns the root naming context.

serverIds

short[] serverIds

List of the initially known servers.

Class fr.dyade.aaa.jndi2.distributed.SyncReplyNot extends Notification implements Serializable

serialVersionUID:

1L

Class fr.dyade.aaa.jndi2.distributed.SyncRequestNot extends Notification implements Serializable

serialVersionUID:

1L

Package fr.dyade.aaa.jndi2.impl

Class fr.dyade.aaa.jndi2.impl.BindEvent extends UpdateEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

object

Object object

Class fr.dyade.aaa.jndi2.impl.ChangeOwnerEvent extends UpdateEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

contexts

NamingContextInfo[] contexts

formerOwnerId

Object formerOwnerId

Class fr.dyade.aaa.jndi2.impl.ContextManager extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

contextIdTable

ContextTable contextIdTable

contextNameTable

ContextTable contextNameTable

rootContextId

NamingContextId rootContextId

storageManager

StorageManager storageManager

Class fr.dyade.aaa.jndi2.impl.ContextRecord extends Record implements Serializable

serialVersionUID:

1L

Serialized Fields

id

NamingContextId id

Class fr.dyade.aaa.jndi2.impl.CreateSubcontextEvent extends UpdateEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

contextId

NamingContextId contextId

ownerId

Object ownerId

path

CompositeName path

Class fr.dyade.aaa.jndi2.impl.DestroySubcontextEvent extends UpdateEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

path

CompositeName path

Class fr.dyade.aaa.jndi2.impl.MissingContextException extends NamingException implements Serializable

serialVersionUID:

1L

Serialized Fields

missingContextId

NamingContextId missingContextId

The identifier of the missing context

name

CompositeName name

Class fr.dyade.aaa.jndi2.impl.MissingRecordException extends NamingException implements Serializable

serialVersionUID:

1L

Serialized Fields

namingContextId

NamingContextId namingContextId

nnfe

NameNotFoundException nnfe

ownerId

Object ownerId

Class fr.dyade.aaa.jndi2.impl.NamingContext extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

contextName

CompositeName contextName

id

NamingContextId id

ownerId

Object ownerId

records

Vector<Record> records

Class fr.dyade.aaa.jndi2.impl.NamingContextId extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

factoryId

Object factoryId

localId

long localId

Class fr.dyade.aaa.jndi2.impl.NamingContextInfo extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

name

CompositeName name

namingContext

NamingContext namingContext

Class fr.dyade.aaa.jndi2.impl.NotOwnerException extends NamingException implements Serializable

serialVersionUID:

1L

Serialized Fields

owner

Object owner

Class fr.dyade.aaa.jndi2.impl.ObjectRecord extends Record implements Serializable

serialVersionUID:

1L

Serialized Fields

obj

Object obj

Class fr.dyade.aaa.jndi2.impl.RebindEvent extends UpdateEvent implements Serializable

serialVersionUID:

1L

Serialized Fields

object

Object object

Class fr.dyade.aaa.jndi2.impl.Record extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

name

String name

Class fr.dyade.aaa.jndi2.impl.SimpleContextTable extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

table

Hashtable table

Class fr.dyade.aaa.jndi2.impl.UnbindEvent extends UpdateEvent implements Serializable

serialVersionUID:

1L

Class fr.dyade.aaa.jndi2.impl.UpdateEvent extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

compositeName

CompositeName compositeName

name

String name

updatedContextId

NamingContextId updatedContextId

Package fr.dyade.aaa.jndi2.msg

Class fr.dyade.aaa.jndi2.msg.BindRequest extends JndiRequest implements Serializable

serialVersionUID:

1L

Serialized Fields

obj

Object obj

rebind

boolean rebind

Class fr.dyade.aaa.jndi2.msg.ChangeOwnerRequest extends JndiRequest implements Serializable

serialVersionUID:

1L

Serialized Fields

ownerId

String ownerId

Class fr.dyade.aaa.jndi2.msg.CreateSubcontextRequest extends JndiRequest implements Serializable

serialVersionUID:

1L

Class fr.dyade.aaa.jndi2.msg.DestroySubcontextRequest extends JndiRequest implements Serializable

serialVersionUID:

1L

Class fr.dyade.aaa.jndi2.msg.JndiError extends JndiReply implements Serializable

serialVersionUID:

1L

Serialized Fields

exc

NamingException exc

Class fr.dyade.aaa.jndi2.msg.JndiReply extends Object implements Serializable

serialVersionUID:

1L

Class fr.dyade.aaa.jndi2.msg.JndiRequest extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

name

CompositeName name

Class fr.dyade.aaa.jndi2.msg.ListBindingsReply extends JndiReply implements Serializable

serialVersionUID:

1L

Serialized Fields

bindings

Binding[] bindings

Class fr.dyade.aaa.jndi2.msg.ListBindingsRequest extends JndiRequest implements Serializable

serialVersionUID:

1L

Class fr.dyade.aaa.jndi2.msg.ListReply extends JndiReply implements Serializable

serialVersionUID:

1L

Serialized Fields

pairs

NameClassPair[] pairs

Class fr.dyade.aaa.jndi2.msg.ListRequest extends JndiRequest implements Serializable

serialVersionUID:

1L

Class fr.dyade.aaa.jndi2.msg.LookupReply extends JndiReply implements Serializable

serialVersionUID:

1L

Serialized Fields

obj

Object obj

Class fr.dyade.aaa.jndi2.msg.LookupRequest extends JndiRequest implements Serializable

serialVersionUID:

1L

Class fr.dyade.aaa.jndi2.msg.UnbindRequest extends JndiRequest implements Serializable

serialVersionUID:

1L

Package fr.dyade.aaa.jndi2.server

Class fr.dyade.aaa.jndi2.server.AgentEntryPoint extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

manager

RequestManager manager

Class fr.dyade.aaa.jndi2.server.AgentRequestContext extends RequestContext implements Serializable

serialVersionUID:

1L

Serialized Fields

doReply

boolean doReply

from

AgentId from

request

JndiRequest request

Class fr.dyade.aaa.jndi2.server.Container extends Agent implements Serializable

serialVersionUID:

1L

Serialized Fields

entryPoints

Vector entryPoints

lifeCycleListener

LifeCycleListener lifeCycleListener

Class fr.dyade.aaa.jndi2.server.JndiReplyNot extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

reply

JndiReply reply

request

JndiRequest request

Class fr.dyade.aaa.jndi2.server.JndiScriptReplyNot extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

replies

JndiReply[] replies

Class fr.dyade.aaa.jndi2.server.JndiScriptRequestNot extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

reply

boolean reply

requests

JndiRequest[] requests

Class fr.dyade.aaa.jndi2.server.RequestContext extends Object implements Serializable

serialVersionUID:

9185021686499463557L

Serialized Fields

resolvedName

CompositeName resolvedName

Class fr.dyade.aaa.jndi2.server.RequestManager extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

container

Container container

Class fr.dyade.aaa.jndi2.server.TcpEntryPoint extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

manager

RequestManager manager

Class fr.dyade.aaa.jndi2.server.TcpRequestContext extends RequestContext implements Serializable

serialVersionUID:

1L

Serialized Fields

request

JndiRequest request

Class fr.dyade.aaa.jndi2.server.TcpRequestNot extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

ctx

RequestContext ctx

Package fr.dyade.aaa.util

Class fr.dyade.aaa.util.Operation extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

dirName

String dirName

Relative path of the object if any, null otherwise.

logidx

int logidx

logptr

int logptr

name

String name

Name of the object

type

int type

Type of the operation.

value

byte[] value

Binary representation of the object (only for create and save operation).

Package org.objectweb.joram.client.connector

Class org.objectweb.joram.client.connector.ActivationSpecImpl extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

acknowledgeMode

String acknowledgeMode

Acknowledgement mode.

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.

collocated

Boolean collocated

true if the underlying JORAM server is collocated.

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.

deleteDurableSubscription

Boolean deleteDurableSubscription

Determine whether durable subscription must be deleted or not at close time of the InboundConsumer.

Default is false.

destination

String destination

The name of the destination to get messages from.

destinationType

String destinationType

The type of the destination to get messages from.

hostName

String hostName

Host name or IP of the underlying JORAM server.

identityClass

String identityClass

identity class name.

maxMessages

String maxMessages

The maximum number of messages that can be assigned to a server session at one time Default is 10.

maxNumberOfWorks

String maxNumberOfWorks

Maximum number of work instances to be submitted (0 for infinite).

messageSelector

String messageSelector

Message selector.

name

String name

password

String password

User password.

queueMessageReadMax

int queueMessageReadMax

The maximum number of messages that can be read at once from a queue. Default value is 2 in order to compensate the former subscription mechanism.

serverPort

int serverPort

Port number of the underlying JORAM server.

subscriptionDurability

String subscriptionDurability

Subscription durability.

subscriptionName

String subscriptionName

Durable subscription name, if any.

topicAckBufferMax

int topicAckBufferMax

The maximum number of acknowledgements that can be buffered in Session.DUPS_OK_ACKNOWLEDGE mode when listening to a topic. Default is 0.

topicActivationThreshold

int topicActivationThreshold

This threshold is the minimum messages number below which the subscription is activated. Default is 0.

topicPassivationThreshold

int topicPassivationThreshold

This threshold is the maximum messages number over which the subscription is passivated. Default is Integer.MAX_VALUE.

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".

userName

String userName

User identification.

Class org.objectweb.joram.client.connector.DefaultConnectionManager extends Object implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.connector.JoramAdapter extends JoramResourceAdapter implements Serializable

serialVersionUID:

1L

Serialized Fields

adminDurationState

long adminDurationState

The duration of admin connection before change state.

adminFileExportXML

String adminFileExportXML

Path to the XML file containing a description of the exported administered objects (destination) from the platform.

adminFileXML

String adminFileXML

Path to the XML file (joramAdmin.xml) containing a description of the administered objects to create and bind.

cnx

Connection cnx

collocated

boolean collocated

true if the underlying JORAM server is collocated.

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.

hostName

String hostName

Host name or IP of the underlying JORAM server. localhost if collocated.

identityClass

String identityClass

Identity class needed for authentication

isActive

boolean isActive

true if admin connection connection is active.

platformConfigDir

String platformConfigDir

Path to the directory containing JORAM's configuration files (a3servers.xml, a3debug.cfg and admin file), needed when StartJoramServer is set to true.

registration

org.osgi.framework.ServiceRegistration<?> registration

rootName

String rootName

login name for administrator.

rootPasswd

String rootPasswd

password for administrator

serverDesc

ServerDesc serverDesc

serverId

short serverId

Identifier of the JORAM server to start.

serverPort

int serverPort

Port number of the underlying JORAM server. -1 if collocated

startJoramServer

boolean startJoramServer

true start the JoramServer

storage

String storage

the persistence directory of the JORAM server to start, needed when StartJoramServer is set to true.

wrapper

JoramAdmin wrapper

Class org.objectweb.joram.client.connector.JoramResourceAdapter extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

boundNames

Vector<String> boundNames

Names of the bound objects.

jndiHelper

JndiHelper jndiHelper

the jndi helper

jndiName

String jndiName

the Joram resource adapter jndi name

name

String name

the Joram resource adapter name

status

JoramResourceAdapter.Status status

The resource adapter status.

Class org.objectweb.joram.client.connector.ManagedConnectionFactoryConfig extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

asyncSend

boolean asyncSend

Determines whether the produced messages are asynchronously sent or not (without or with acknowledgement) Default is false (with ack).

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.

collocated

boolean collocated

true for collocated outbound connectivity.

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.

hostName

String hostName

Underlying JORAM server host name.

identityClass

String identityClass

Default identityClass

inInterceptors

String inInterceptors

Comma separated list of IN interceptors.

mode

String mode

multiThreadSync

boolean multiThreadSync

Determines whether client threads which are using the same connection are synchronized in order to group together the requests they send. Default is false.

multiThreadSyncDelay

int multiThreadSyncDelay

The maximum time the threads hang if 'multiThreadSync' is true. Either they wake up (wait time out) or they are notified (by the first woken up thread).

Default is 1 ms.

name

String name

outInterceptors

String outInterceptors

Comma separated list of OUT interceptors.

outLocalAddress

String outLocalAddress

This is the local IP address on which the TCP connection is activated. The value can either be a machine name, such as "java.sun.com", or a textual representation of its IP address.

outLocalPort

int outLocalPort

This is the local IP address port on which the TCP connection is activated

password

String password

Default user password.

serverPort

int serverPort

Underlying JORAM server port number. -1 if collocated

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".

userName

String userName

Default user identification.

Class org.objectweb.joram.client.connector.ManagedConnectionFactoryImpl extends ManagedConnectionFactoryConfig implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.connector.ManagedQueueConnectionFactoryImpl extends ManagedConnectionFactoryImpl implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.connector.ManagedTopicConnectionFactoryImpl extends ManagedConnectionFactoryImpl implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.connector.OutboundConnectionFactory extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

cxManager

ConnectionManager cxManager

Manager for connection pooling.

mcf

ManagedConnectionFactoryImpl mcf

Central manager for outbound connectivity.

reference

Reference reference

Naming reference of this instance.

Class org.objectweb.joram.client.connector.OutboundQueueConnectionFactory extends OutboundConnectionFactory implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.connector.OutboundTopicConnectionFactory extends OutboundConnectionFactory implements Serializable

serialVersionUID:

1L

Package org.objectweb.joram.client.jms

Class org.objectweb.joram.client.jms.ConnectionFactory extends AbstractConnectionFactory implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.jms.Destination extends AdministeredObject implements Serializable

serialVersionUID:

1L

Serialized Fields

adminName

String adminName

Symbolic name given by the administrator.

agentId

String agentId

Identifier of the agent destination. Be careful when using directly this attribute, it is null in clustered destination even the getDestination method is called.

type

byte type

Type of the destination: Queue or Topic, Temporary or not.

See Also:

Destination.getType()

wrapper

AdminItf wrapper

Administration wrapper used to perform administration stuff.

It is defined through AdminModule element, it is closed at the end of the script. if it is not defined the wrapper set at creation is used, if none the static AdminModule connection is used.

Class org.objectweb.joram.client.jms.FactoryParameters extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

asyncSend

boolean asyncSend

Determines whether the persistent produced messages are asynchronously sent (without acknowledge) or not.

Messages sent asynchronously may be lost if a failure occurs before the message is persisted on the server.

Non persistent messages are always sent without acknowledgment.

Default is false, persistent messages are sent with acknowledge.

clientID

String clientID

The clientID used by connection

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 approximatively more than 3* cnxPendingTimer, the connection is considered as dead and processed as required.

compressedMinSize

int compressedMinSize

This attribute defines the minimum size beyond which the message body is compressed. The default value is 0 (no compression).

compressionLevel

int compressionLevel

This attribute defines the compression level (0-9) used when the message body is compressed. The default value is 1 (Deflater.BEST_SPEED).

connectingTimer

int connectingTimer

Duration in seconds during which connecting is attempted (connecting might take time if the server is temporarily not reachable). A value of zero is interpreted as an infinite timeout. The connection will then block until established or a TCP error occurs.

The default value is 30.

host

String host

Name of host hosting the server to create connections with.

implicitAck

boolean implicitAck

Determines whether the messages consumed are implicitly acknowledged or not. When true messages are immediately removed from queue when delivered.

inInterceptors

List<MessageInterceptor> inInterceptors

List of Message interceptors while receiving a message.
These interceptors are called when Session#receive() is called.
The execution follows the order of the elements within the list.
This property is facultative. If set, then the MessageInterceptor handle callback method of the IN interceptors} are called.

messageIdPrefix

String messageIdPrefix

This attribute allows to customize the JMS MessageID adding the specified string. This value is overloaded by the property org.objectweb.joram.client.jms.messageid.prefix if it defined. By default empty.

multiThreadSync

boolean multiThreadSync

Determines whether client threads which are using the same connection are synchronized in order to group together the requests they send.

multiThreadSyncDelay

int multiThreadSyncDelay

The maximum time the threads hang if 'multiThreadSync' is true.

Either they wake up (wait time out) or they are notified (by the first waken up thread).

Default value is 1ms.

multiThreadSyncThreshold

int multiThreadSyncThreshold

The maximum numbers of threads that hang if 'multiThreadSync' is true.

Default value is 10 waiting threads.

noAckedQueue

boolean noAckedQueue

Set this attribute to true to increase performance. The default value is false (use the AckedQueue)

outInterceptors

List<MessageInterceptor> outInterceptors

List of Message interceptors while sending a message.
These interceptors are called when Session#send() is called.
The execution follows the order of the elements within the list.
This property is facultative. If set, then the MessageInterceptor handle callback method of the OUT interceptors} are called.

outLocalAddress

String outLocalAddress

This is the local IP address on which the TCP connection is activated.

The value can either be a machine name, such as "java.sun.com", or a textual representation of its IP address.

outLocalPort

int outLocalPort

This is the local IP address port on which the TCP connection is activated

port

int port

Port to be used for accessing the server.

queueMessageReadMax

int queueMessageReadMax

The maximum number of messages that can be read at once from a queue.

Default is 1.

socketFactory

String socketFactory

Allows to define a specific factory for socket in order to by-pass compatibility problem between JDK version. Currently there is two factories, The default factory one for JDK since 1.4, and SocketFactory13 for JDK prior to 1.4.

SoLinger

int SoLinger

Enable SO_LINGER with the specified linger time in seconds, if the value is less than 0 then it disables SO_LINGER. Default value is -1.

SoTimeout

int SoTimeout

Enable/disable SO_TIMEOUT with the specified timeout in milliseconds. The timeout must be > 0. A timeout of zero is interpreted as an infinite timeout. Default value is 0.

TcpNoDelay

boolean TcpNoDelay

Enable/disable TCP_NODELAY (disable/enable Nagle's algorithm), default value is true.

topicAckBufferMax

int topicAckBufferMax

The maximum number of acknowledgements that can be buffered in Session.DUPS_OK_ACKNOWLEDGE mode when listening to a topic.

Default value is 10.

topicActivationThreshold

int topicActivationThreshold

This threshold is the minimum messages number below which the subscription is activated.

Default value is 0.

topicPassivationThreshold

int topicPassivationThreshold

This threshold is the maximum messages number over which the subscription is passivated.

Default is Integer.MAX_VALUE.

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".

The default value is 0 (no timer).

url

String url

url needed to connect to joram HA

Class org.objectweb.joram.client.jms.Queue extends Destination implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.jms.QueueConnectionFactory extends AbstractConnectionFactory implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.jms.TemporaryQueue extends Queue implements Serializable

serialVersionUID:

1L

Serialized Fields

cnx

Connection cnx

The connection the queue belongs to, null if not known.

Class org.objectweb.joram.client.jms.TemporaryTopic extends Topic implements Serializable

serialVersionUID:

1L

Serialized Fields

cnx

Connection cnx

The connection the topic belongs to, null if not known.

Class org.objectweb.joram.client.jms.Topic extends Destination implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.jms.TopicConnectionFactory extends AbstractConnectionFactory implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.jms.XAConnectionFactory extends AbstractConnectionFactory implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.jms.XAQueueConnectionFactory extends AbstractConnectionFactory implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.jms.XATopicConnectionFactory extends AbstractConnectionFactory implements Serializable

serialVersionUID:

1L

Package org.objectweb.joram.client.jms.admin

Class org.objectweb.joram.client.jms.admin.AbstractConnectionFactory extends AdministeredObject implements Serializable

serialVersionUID:

-4654044059180563323L

Serialized Fields

cnxJMXBeanBaseName

String cnxJMXBeanBaseName

identity

Identity identity

Authentication identity.

identityClassName

String identityClassName

isSetIdentityClassName

boolean isSetIdentityClassName

params

FactoryParameters params

Object containing the factory's parameters.

reliableClass

String reliableClass

Reliable class name, for example use by ssl.

Class org.objectweb.joram.client.jms.admin.AdminException extends Exception implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.jms.admin.AdministeredObject extends Object implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.jms.admin.ClusterConnectionFactory extends AdministeredObject implements Serializable

serialVersionUID:

1L

Serialized Fields

cluster

Hashtable<String,ConnectionFactory> cluster

Class org.objectweb.joram.client.jms.admin.ClusterDestination extends Destination implements Serializable

serialVersionUID:

1L

Serialized Fields

cluster

Hashtable<String,Destination> cluster

Class org.objectweb.joram.client.jms.admin.ClusterQueue extends ClusterDestination implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.jms.admin.ClusterTopic extends ClusterDestination implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.jms.admin.DeadMQueue extends Queue implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.jms.admin.NameAlreadyUsedException extends AdminException implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.jms.admin.ServerIdAlreadyUsedException extends AdminException implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.jms.admin.StartFailureException extends AdminException implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.jms.admin.UnknownServerException extends AdminException implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.jms.admin.User extends AdministeredObject implements Serializable

serialVersionUID:

1L

Serialized Fields

name

String name

The name of the user.

proxyId

String proxyId

Identifier of the user's proxy agent.

wrapper

AdminWrapper wrapper

Administration wrapper used to perform administration stuff.

It is defined through AdminModule element, it is closed at the end of the script. if it is not defined the wrapper set at creation is used, if none the static AdminModule connection is used.

Package org.objectweb.joram.client.jms.connection

Class org.objectweb.joram.client.jms.connection.AbortedRequestException extends Exception implements Serializable

serialVersionUID:

1L

Package org.objectweb.joram.client.jms.local

Class org.objectweb.joram.client.jms.local.LocalConnectionFactory extends ConnectionFactory implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.jms.local.QueueLocalConnectionFactory extends QueueConnectionFactory implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.jms.local.TopicLocalConnectionFactory extends TopicConnectionFactory implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.jms.local.XALocalConnectionFactory extends XAConnectionFactory implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.jms.local.XAQueueLocalConnectionFactory extends XAQueueConnectionFactory implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.jms.local.XATopicLocalConnectionFactory extends XATopicConnectionFactory implements Serializable

serialVersionUID:

1L

Package org.objectweb.joram.client.jms.tcp

Class org.objectweb.joram.client.jms.tcp.QueueTcpConnectionFactory extends QueueConnectionFactory implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.jms.tcp.TcpConnectionFactory extends ConnectionFactory implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.jms.tcp.TopicTcpConnectionFactory extends TopicConnectionFactory implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.jms.tcp.XAQueueTcpConnectionFactory extends XAQueueConnectionFactory implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.jms.tcp.XATcpConnectionFactory extends XAConnectionFactory implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.client.jms.tcp.XATopicTcpConnectionFactory extends XATopicConnectionFactory implements Serializable

serialVersionUID:

1L

Package org.objectweb.joram.mom.dest

Class org.objectweb.joram.mom.dest.AcquisitionNot extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

acquiredMessages

ClientMessages acquiredMessages

id

String id

Class org.objectweb.joram.mom.dest.AcquisitionQueue extends Queue implements Serializable

serialVersionUID:

1L

Serialized Fields

acquisitionClassName

String acquisitionClassName

The acquisition class name.

diff_max

long diff_max

The threshold of messages send by the handler in the engine

diff_min

long diff_min

lastMessageId

String lastMessageId

Stores the id of the last message received to avoid duplicates.

msgCount

long msgCount

The number of produced messages.

pause

boolean pause

pending_max

long pending_max

The threshold of pending messages in the queue

pending_min

long pending_min

properties

Properties properties

Stores the last set of properties defined.

Class org.objectweb.joram.mom.dest.AcquisitionTopic extends Topic implements Serializable

serialVersionUID:

1L

Serialized Fields

ACQ_TOPIC_MAX_MSG

String ACQ_TOPIC_MAX_MSG

ACQ_TOPIC_MIN_MSG

String ACQ_TOPIC_MIN_MSG

acquisitionClassName

String acquisitionClassName

The acquisition class name.

diff_max

long diff_max

The threshold of messages send by the handler in the engine

diff_min

long diff_min

lastMessageId

String lastMessageId

Stores the id of the last message received to avoid duplicates.

msgCount

long msgCount

The number of produced messages.

pause

boolean pause

properties

Properties properties

Stores the last set of properties defined.

Class org.objectweb.joram.mom.dest.AdminTopic extends Topic implements Serializable

serialVersionUID:

1L

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Deserializes an AdminTopic instance.

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Serializes an AdminTopic instance.

Throws:

IOException

Serialized Fields

destinationsTable

Map<String,AdminTopic.DestinationDesc> destinationsTable

Table holding the local server's destinations names. This table is used by more than one thread so it needs to be synchronized.

Key: destination name
Object: destination agent identifier

msgCounter

long msgCounter

Counter of messages produced by this AdminTopic.

proxiesTable

Map<String,AgentId> proxiesTable

Table holding the TCP users proxies identifiers.

Key: user name
Object: proxy's identifier

requestsTable

Map<String,AgentId> requestsTable

Table keeping the administrator's requests.

Key: request's message identifier
Value: request's message ReplyTo field

serverId

int serverId

Identifier of the server this topic is deployed on.

usersTable

Map<String,Identity> usersTable

Table holding the TCP users identifications.

Key: user name
Object: user password

Class org.objectweb.joram.mom.dest.AdminTopic.DestinationDesc extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

id

AgentId id

name

String name

type

byte type

Class org.objectweb.joram.mom.dest.AliasInQueue extends Queue implements Serializable

serialVersionUID:

1L

Serialized Fields

currentDestination

int currentDestination

destinations

ArrayList<AgentId> destinations

metrics

ArrayList<Long> metrics

minMetrics

long minMetrics

newmetrics

ArrayList<Long> newmetrics

oldmetrics

ArrayList<Long> oldmetrics

receivedMetrics

int receivedMetrics

weightLeft

long weightLeft

weights

ArrayList<Long> weights

Class org.objectweb.joram.mom.dest.AliasQueue extends Queue implements Serializable

serialVersionUID:

1L

Serialized Fields

expiration

long expiration

The maximum time the notification can wait in the network before expiration.

remoteDestinationID

AgentId remoteDestinationID

The queue to send the notification to

Class org.objectweb.joram.mom.dest.ClusterQueue extends Queue implements Serializable

serialVersionUID:

1L

Serialized Fields

clusterDeliveryCount

long clusterDeliveryCount

Number of message send to cluster

clusters

Map<AgentId,Float> clusters

key = agentId of ClusterQueue value = rateOfFlow (Float)

loadingFactor

LoadingFactor loadingFactor

to evaluate the loading factor, overloading, ...

receivedFromCluster

int receivedFromCluster

sentToCluster

int sentToCluster

timeTable

Map<String,Long> timeTable

key = msgId value = date

timeThreshold

long timeThreshold

Maximum period of time before forwarding a waiting message or request to other queues of the cluster. By default it is set to Queue.period.

visitTable

Map<String,List<AgentId>> visitTable

key = msgId value = List (alreadyVisit)

Class org.objectweb.joram.mom.dest.Destination extends Agent implements Serializable

serialVersionUID:

-4457639325610333885L

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

adminId

AgentId adminId

Identifier of the destination's administrator. In any case the administration topics are authorized to handle the destination, this mechanism allows an other agent to get the same rights. In particular it is needed to allow user's proxy to handle temporary destinations.

clients

Hashtable<AgentId,Integer> clients

Table of the destination readers and writers.

creationDate

long creationDate

date of creation.

deletable

boolean deletable

true if the destination successfully processed a deletion request.

dmqId

AgentId dmqId

Identifier of the dead message queue this destination must send its dead messages to, if any.

freeReading

boolean freeReading

true if the READ access is granted to everybody.

freeWriting

boolean freeWriting

true if the WRITE access is granted to everybody.

interceptorsProp

List<Properties> interceptorsProp

the interceptors list.

nbMsgsDeliverSinceCreation

long nbMsgsDeliverSinceCreation

nbMsgsSentToDMQSinceCreation

long nbMsgsSentToDMQSinceCreation

period

long period

period to run task at regular interval: cleaning, load-balancing, etc.

Class org.objectweb.joram.mom.dest.DistributionQueue extends Queue implements Serializable

serialVersionUID:

1L

Serialized Fields

batchDistribution

boolean batchDistribution

Tells if we try to distribute the each message each time (true) or if the distribution is stopped on first error (false). Batch mode can (and will probably) lose message ordering but will not stop deliverable messages in the queue waiting for previous ones to be sent.

distributionClassName

String distributionClassName

The acquisition class name.

isAsyncDistribution

boolean isAsyncDistribution

Tells if daemon distribution is active. On true, the batchDistribution is set.

nbMsgsReceiveSinceCreation

long nbMsgsReceiveSinceCreation

properties

Properties properties

Class org.objectweb.joram.mom.dest.DistributionTopic extends Topic implements Serializable

serialVersionUID:

1L

Serialized Fields

distributionClassName

String distributionClassName

The acquisition class name.

isAsyncDistribution

boolean isAsyncDistribution

Tells if daemon distribution is active. On true, the batchDistribution is set.

properties

Properties properties

Class org.objectweb.joram.mom.dest.ElasticTopic extends Topic implements Serializable

serialVersionUID:

3074584772834111626L

Serialized Fields

isRoot

boolean isRoot

True if topic is head of the elastic topic tree.

pool

List<ElasticTopic.TopicDesc> pool

Pool of topics to forward msgs to.

subId

int subId

Index of topic to forward next subscription to.

Class org.objectweb.joram.mom.dest.LoadingFactor extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

autoEvalThreshold

boolean autoEvalThreshold

automatic eval threshold

clusterQueue

ClusterQueue clusterQueue

reference to clusterQueue

consumerStatus

int consumerStatus

consumer status

consumThreshold

int consumThreshold

consumer threshold

lastROFSent

float lastROFSent

maxFwdPerQueue

int maxFwdPerQueue

maximum number of messages forwarded to each queue of cluster by round

producerStatus

int producerStatus

producer status

producThreshold

int producThreshold

producer threshold

rateOfFlow

float rateOfFlow

status

int status

status

statusTime

long statusTime

status time

validityPeriod

long validityPeriod

validity period

Class org.objectweb.joram.mom.dest.MonitoringElement extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

attributes

String[] attributes

List of attributes

mbean

String mbean

Name of the MBean

Class org.objectweb.joram.mom.dest.Queue extends Destination implements Serializable

serialVersionUID:

1L

Serialized Fields

cload

int cload

deliveryDelay

int deliveryDelay

The delivery delay in milliseconds used to wait before delivering a message. If set the resulting delay is the max between this value and the message property.

deliveryTimeout

long deliveryTimeout

DFLT_DELIVERY_TIMEOUT

long DFLT_DELIVERY_TIMEOUT

hcons

long hcons

hprod

long hprod

lenientRedeliveryDelay

boolean lenientRedeliveryDelay

lenientUndeliverable

boolean lenientUndeliverable

nbExpirations

int nbExpirations

Number of stored messages with an expiration date.

nbMaxMsg

int nbMaxMsg

nb Max of Message store in queue (-1 no limit).

nbMsgsDeniedSinceCreation

long nbMsgsDeniedSinceCreation

pause

boolean pause

pload

int pload

priority

int priority

Common priority value.

redeliveryDelay

int redeliveryDelay

The re-delivery delay in seconds use to wait before re-delivering messages after a deny.

requests

List<ReceiveRequest> requests

List holding the requests before reply or expiry.

samePriorities

boolean samePriorities

true if all the stored messages have the same priority. Note: messages list is ordered by priorities, so we could test if first and last message have the same priority.

syncExceptionOnFullDest

boolean syncExceptionOnFullDest

if true, throws an exception on sending message on full destination.

threshold

int threshold

Threshold above which messages are considered as undeliverable because constantly denied; 0 stands for no threshold, -1 for value not set.

Class org.objectweb.joram.mom.dest.QueueArrivalState extends Object implements Serializable

serialVersionUID:

8781424702189250843L

Serialized Fields

arrivalCount

long arrivalCount

id

String id

modified

boolean modified

Class org.objectweb.joram.mom.dest.QueueDelivery extends Object implements Serializable

serialVersionUID:

8114112983207655810L

Serialized Fields

consumerId

AgentId consumerId

contextId

int contextId

Class org.objectweb.joram.mom.dest.QueueDeliveryTable extends Object implements Serializable

serialVersionUID:

-4062834409427547337L

Serialized Fields

deliveries

HashMap<String,QueueDelivery> deliveries

modified

boolean modified

Class org.objectweb.joram.mom.dest.Topic extends Destination implements Serializable

serialVersionUID:

1L

Serialized Fields

fatherId

AgentId fatherId

Identifier of this topic's father, if any.

friends

Set<AgentId> friends

Set of cluster elements (including itself), if any.

nbMsgsReceiveSinceCreation

long nbMsgsReceiveSinceCreation

selectors

Map<AgentId,String> selectors

Table of subscribers' selectors.

subscribers

List<AgentId> subscribers

Vector of subscribers' identifiers.

Package org.objectweb.joram.mom.dest.amqp

Class org.objectweb.joram.mom.dest.amqp.LiveServerConnection extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

host

String host

name

String name

password

String password

port

int port

user

String user

Package org.objectweb.joram.mom.dest.jms

Class org.objectweb.joram.mom.dest.jms.JMSModule extends Object implements Serializable

serialVersionUID:

-4654256406604729021L

Serialized Fields

clientID

String clientID

JMS clientID field.

cnxFactName

String cnxFactName

ConnectionFactory JNDI name.

jndiFactory

String jndiFactory

Name of the JNDI factory class to use.

jndiUrl

String jndiUrl

JNDI URL.

name

String name

the name identifying the remote JMS provider

password

String password

User password for connecting to the foreign JMS server. This field may be encrypted if JMSConnections.ENCRYPT_CONFIGURATION_PROPERTY is defined to true.

status

int status

userName

String userName

User identification for connecting to the foreign JMS server.

Package org.objectweb.joram.mom.messages

Class org.objectweb.joram.mom.messages.InvalidMessageException extends RuntimeException implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.mom.messages.Message extends Object implements Serializable

serialVersionUID:

2L

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:

ClassNotFoundException

IOException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Package org.objectweb.joram.mom.notifications

Class org.objectweb.joram.mom.notifications.AbortReceiveRequest extends AbstractRequestNot implements Serializable

serialVersionUID:

1L

Serialized Fields

abortedRequestId

int abortedRequestId

Class org.objectweb.joram.mom.notifications.AbstractNotification extends CallbackNotification implements Serializable

serialVersionUID:

-1933719957724933079L

Serialized Fields

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.

Class org.objectweb.joram.mom.notifications.AbstractReplyNot extends AbstractNotification implements Serializable

serialVersionUID:

-5283973981895033090L

Serialized Fields

correlationId

int correlationId

The correlationId field is equal to the request's identifier.

Class org.objectweb.joram.mom.notifications.AbstractRequestNot extends AbstractNotification implements Serializable

serialVersionUID:

-7029517541826292641L

Serialized Fields

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.

Class org.objectweb.joram.mom.notifications.AcknowledgeRequest extends AbstractRequestNot implements Serializable

serialVersionUID:

1L

Serialized Fields

msgId

String msgId

Message identifier.

msgIds

Vector<String> msgIds

Vector of message identifiers.

Class org.objectweb.joram.mom.notifications.AdminReplyNot extends AbstractNotification implements Serializable

serialVersionUID:

1L

Serialized Fields

info

String info

Info related to the processing of the request.

requestId

String requestId

Field identifying the original request.

success

boolean success

true if the request succeeded.

Class org.objectweb.joram.mom.notifications.AdminRequestNot extends AbstractNotification implements Serializable

serialVersionUID:

1L

Serialized Fields

id

String id

Field used for identifying the request.

Class org.objectweb.joram.mom.notifications.BrowseReply extends AbstractReplyNot implements Serializable

serialVersionUID:

1L

Serialized Fields

message

Message message

The message contained in the queue.

messages

Vector<Message> messages

The messages contained in the queue.

Class org.objectweb.joram.mom.notifications.BrowseRequest extends AbstractRequestNot implements Serializable

serialVersionUID:

1L

Serialized Fields

selector

String selector

String selector for filtering messages, null or empty for no selection.

Class org.objectweb.joram.mom.notifications.ClientMessages extends AbstractRequestNot implements Serializable

serialVersionUID:

1L

Serialized Fields

asyncSend

boolean asyncSend

message

Message message

Message sent by the client.

messages

List<Message> messages

Messages sent by the client.

proxyId

AgentId proxyId

Class org.objectweb.joram.mom.notifications.ClientSubscriptionNot extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

subName

String subName

Class org.objectweb.joram.mom.notifications.ClusterJoinAck extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

cluster

Set<AgentId> cluster

Class org.objectweb.joram.mom.notifications.ClusterJoinNot extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

cluster

Set<AgentId> cluster

replyMsgId

String replyMsgId

The generated JMS message id. for the reply

replyTo

AgentId replyTo

The JMS destination to send the reply

requestMsgId

String requestMsgId

The JMS message id. of the request needed for the reply

Class org.objectweb.joram.mom.notifications.ClusterLBNot extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

rateOfFlow

float rateOfFlow

Class org.objectweb.joram.mom.notifications.ClusterRemoveNot extends Notification implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.mom.notifications.DenyRequest extends AbstractRequestNot implements Serializable

serialVersionUID:

1L

Serialized Fields

msgId

String msgId

Message identifier.

msgIds

Vector<String> msgIds

Vector of message identifiers.

redelivered

boolean redelivered

true if the message has already been delivered.

Class org.objectweb.joram.mom.notifications.ExceptionReply extends AbstractReplyNot implements Serializable

serialVersionUID:

1L

Serialized Fields

except

MomException except

The MomException which occured when processing the request.

Class org.objectweb.joram.mom.notifications.FwdAdminRequestNot extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

replyMsgId

String replyMsgId

The generated JMS message id. for the reply

replyTo

AgentId replyTo

The JMS destination to send the reply

request

AdminRequest request

The request

requestMsgId

String requestMsgId

The JMS message id. of the request needed for the reply

Class org.objectweb.joram.mom.notifications.GetClientSubscriptions extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

not

FwdAdminRequestNot not

Class org.objectweb.joram.mom.notifications.GetProxyIdListNot extends SyncNotification implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.mom.notifications.GetProxyIdNot extends SyncNotification implements Serializable

serialVersionUID:

1L

Serialized Fields

identity

Identity identity

inaddr

String inaddr

Class org.objectweb.joram.mom.notifications.GetRightsReplyNot extends AdminReplyNot implements Serializable

serialVersionUID:

1L

Serialized Fields

isFreeReading

boolean isFreeReading

True if all users can read this destination.

isFreeWriting

boolean isFreeWriting

True if all users can write this destination.

readers

Vector<AgentId> readers

Vector of readers' identifiers.

writers

Vector<AgentId> writers

Vector of writers' identifiers.

Class org.objectweb.joram.mom.notifications.GetRightsRequestNot extends AdminRequestNot implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.mom.notifications.LBCycleLife extends ClusterLBNot implements Serializable

serialVersionUID:

1L

Serialized Fields

clientMessages

ClientMessages clientMessages

visitTable

Map<String,List<AgentId>> visitTable

Class org.objectweb.joram.mom.notifications.LBLoadingFactor extends ClusterLBNot implements Serializable

serialVersionUID:

1L

Serialized Fields

validityPeriode

long validityPeriode

Class org.objectweb.joram.mom.notifications.LBMessageGive extends LBLoadingFactor implements Serializable

serialVersionUID:

1L

Serialized Fields

clientMessages

ClientMessages clientMessages

Class org.objectweb.joram.mom.notifications.LBMessageHope extends LBLoadingFactor implements Serializable

serialVersionUID:

1L

Serialized Fields

nbMsg

int nbMsg

Class org.objectweb.joram.mom.notifications.PingNot extends Notification implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.mom.notifications.PongNot extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

stats

Properties stats

Class org.objectweb.joram.mom.notifications.QueueDeliveryTimeNot extends Notification implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.mom.notifications.QueueMsgReply extends AbstractReplyNot implements Serializable

serialVersionUID:

1L

Serialized Fields

messages

Vector<Message> messages

The message sent by the queue.

Class org.objectweb.joram.mom.notifications.ReceiveRequest extends AbstractRequestNot implements Serializable

serialVersionUID:

1L

Serialized Fields

autoAck

boolean autoAck

If true, the consumed message will be immediately deleted on the queue.

expirationTime

long expirationTime

The expiration time of the request.

msgCount

int msgCount

msgIds

String[] msgIds

requester

AgentId requester

Identifier of the client requesting a message, set by the queue if storing the request.

selector

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.

Class org.objectweb.joram.mom.notifications.ReconnectSubscribersNot extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

msgs

ArrayList<Message> msgs

not

FwdAdminRequestNot not

subName

String subName

subs

ArrayList<Integer> subs

Class org.objectweb.joram.mom.notifications.RequestGroupNot extends AbstractRequestNot implements Serializable

serialVersionUID:

1L

Serialized Fields

clientMessages

Vector<ClientMessages> clientMessages

Class org.objectweb.joram.mom.notifications.SubscribeReply extends AbstractReplyNot implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.mom.notifications.SubscribeRequest extends AbstractRequestNot implements Serializable

serialVersionUID:

1L

Serialized Fields

asyncSub

boolean asyncSub

asynchronous subscription request.

selector

String selector

Selector for filtering messages, null or empty string for no selection.

Class org.objectweb.joram.mom.notifications.TopicDeliveryTimeNot extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

msg

Message msg

subName

String subName

topic

AgentId topic

Class org.objectweb.joram.mom.notifications.TopicForwardNot extends CallbackNotification implements Serializable

serialVersionUID:

1L

Serialized Fields

fromCluster

boolean fromCluster

true if the notification is destinated to a hierarchical father.

messages

ClientMessages messages

The forwarded messages.

Class org.objectweb.joram.mom.notifications.TopicMsgsReply extends AbstractReplyNot implements Serializable

serialVersionUID:

1L

Serialized Fields

messages

List<Message> messages

Vector of messages.

Class org.objectweb.joram.mom.notifications.UnsubscribeRequest extends AbstractRequestNot implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.mom.notifications.WakeUpNot extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

update

boolean update

This field is always visibly initialized to true. However, this class is also used in a hidden way (see default constructor), and update is then initialized to false.

Package org.objectweb.joram.mom.proxies

Class org.objectweb.joram.mom.proxies.AckedQueue extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

current

int current

list

Vector<ProxyMessage> list

Class org.objectweb.joram.mom.proxies.AdminNotification extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

identity

Identity identity

The administrator's Identity.

proxyId

AgentId proxyId

The proxy's AgentId identifier.

Class org.objectweb.joram.mom.proxies.ClientContext extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

deliveringQueues

Hashtable<AgentId,AgentId> deliveringQueues

Identifiers of queues delivering messages.

id

int id

Context identifier.

proxyId

AgentId proxyId

The proxy's agent identifier

tempDestinations

Vector<AgentId> tempDestinations

Vector of temporary destinations.

transactionsTable

Hashtable<Xid,XACnxPrepare> transactionsTable

Prepared transactions objects waiting for commit.

Class org.objectweb.joram.mom.proxies.ClientSubscription extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

clientID

String clientID

deliveredIds

Map<String,String> deliveredIds

Table of delivered messages identifiers.

deniedMsgs

Map<String,Integer> deniedMsgs

Table keeping the denied messages identifiers.

dmqId

AgentId dmqId

Identifier of the subscriber's dead message queue, null for DMQ not set.

durable

boolean durable

true if the subscription is durable.

name

String name

The subscription name.

nbMaxMsg

int nbMaxMsg

Max number of Message stored in the queue (-1 no limit).

nbMsgsDeliveredSinceCreation

long nbMsgsDeliveredSinceCreation

the number of delivered messages

nbMsgsSentToDMQSinceCreation

long nbMsgsSentToDMQSinceCreation

the number of erroneous messages forwarded to the DMQ

proxyId

AgentId proxyId

The proxy's agent identifier.

selector

String selector

The selector for filtering messages.

threshold

int threshold

Threshold above which messages are considered as undeliverable because constantly denied. 0 stands for no threshold, -1 for value not set (use servers' default value).

topicId

AgentId topicId

The topic identifier.

Class org.objectweb.joram.mom.proxies.CloseConnectionNot extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

key

int key

Class org.objectweb.joram.mom.proxies.CloseConnectionNot2 extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

key

int key

Class org.objectweb.joram.mom.proxies.GetConnectionNot extends SyncNotification implements Serializable

serialVersionUID:

1L

Serialized Fields

key

int key

Class org.objectweb.joram.mom.proxies.OpenConnectionNot extends SyncNotification implements Serializable

serialVersionUID:

1L

Serialized Fields

heartBeat

int heartBeat

noAckedQueue

boolean noAckedQueue

type

ConnectionContext.Type type

Class org.objectweb.joram.mom.proxies.ProxyMessage extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

ackId

long ackId

id

long id

obj

AbstractJmsMessage obj

Class org.objectweb.joram.mom.proxies.ProxyRequestGroupNot extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

requests

RequestNot[] requests

Class org.objectweb.joram.mom.proxies.ReliableConnectionContext extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

active

boolean active

closed

boolean closed

heartBeat

int heartBeat

inputCounter

long inputCounter

key

int key

noAckedQueue

boolean noAckedQueue

outputCounter

long outputCounter

queue

AckedQueue queue

queueWorker

QueueWorker queueWorker

Class org.objectweb.joram.mom.proxies.RequestNot extends CallbackNotification implements Serializable

serialVersionUID:

1L

Serialized Fields

cKey

int cKey

msg

Object msg

Class org.objectweb.joram.mom.proxies.ResetCollocatedConnectionsNot extends Notification implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.mom.proxies.ReturnConnectionNot extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

ctx

ConnectionContext ctx

not

OpenConnectionNot not

Class org.objectweb.joram.mom.proxies.SendRepliesNot extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

replies

Vector<SendReplyNot> replies

Class org.objectweb.joram.mom.proxies.SendReplyNot extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

key

int key

requestId

int requestId

Class org.objectweb.joram.mom.proxies.StandardConnectionContext extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

closed

boolean closed

key

int key

queue

Queue queue

Class org.objectweb.joram.mom.proxies.UserAgent extends Agent implements Serializable

serialVersionUID:

1L

Serialized Fields

arrivalState

UserAgentArrivalState arrivalState

Counter of message arrivals from topics.

contexts

Map<Integer,ClientContext> contexts

Table of the proxy's ClientContext instances.

Key: context identifier
Value: context

dmqId

AgentId dmqId

Identifier of this proxy dead message queue, null for DMQ not set.

interceptorsPropIN

List<Properties> interceptorsPropIN

interceptorsPropOUT

List<Properties> interceptorsPropOUT

keyCounter

int keyCounter

Counter of the connection keys

nbMaxMsg

int nbMaxMsg

Maximum number of Message store in subscriptions (-1 set no limit). This value is used as default value at subscription creation.

nbMsgsSentToDMQSinceCreation

long nbMsgsSentToDMQSinceCreation

the number of erroneous messages forwarded to the DMQ

period

long period

period to run the cleaning task, by default 60s.

recoveredTransactions

Map<Xid,XACnxPrepare> recoveredTransactions

Table holding the recovered transactions branches.

Key: transaction identifier
Value: XACnxPrepare instance

redeliveryDelay

int redeliveryDelay

The redelivery delay use to wait before re-delivering messages after a deny.

subsClientIDs

Properties subsClientIDs

Key: subscription name
Value: clientID

subsTable

Map<String,ClientSubscription> subsTable

Table holding the ClientSubscription instances.

Key: subscription name
Value: client subscription

threshold

int threshold

Threshold above which messages are considered as undeliverable because constantly denied. This value is used as default value at subscription creation. 0 stands for no threshold, -1 for value not set (use default value).

Class org.objectweb.joram.mom.proxies.UserAgentArrivalState extends Object implements Serializable

serialVersionUID:

5250075640984219772L

Serialized Fields

arrivalCount

long arrivalCount

id

String id

modified

boolean modified

Package org.objectweb.joram.mom.util

Class org.objectweb.joram.mom.util.MessageIdListImpl extends Object implements Serializable

serialVersionUID:

-3470039435921556495L

Serialized Fields

list

ArrayList<String> list

listId

String listId

Class org.objectweb.joram.mom.util.SynchronousAgent extends Agent implements Serializable

serialVersionUID:

3842240802167239809L

Serialized Fields

nextReqMsgId

int nextReqMsgId

Deprecated.

requests

Map<String,Message> requests

Deprecated.

Package org.objectweb.joram.shared.admin

Class org.objectweb.joram.shared.admin.AbstractAdminMessage extends Object implements Serializable

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.AddDomainRequest extends AdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.AddRemoteDestination extends DestinationAdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.AddServerRequest extends AdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.AddServiceRequest extends AdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.AdminCommandReply extends AdminReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.AdminCommandRequest extends AdminRequest implements Serializable

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.AdminReply extends AbstractAdminMessage implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.AdminRequest extends AbstractAdminMessage implements Serializable

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.ClearQueue extends DestinationAdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.ClearSubscription extends SubscriptionAdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.ClusterAdd extends DestinationAdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.ClusterLeave extends DestinationAdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.ClusterList extends DestinationAdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.ClusterListReply extends AdminReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.CreateDestinationReply extends AdminReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.CreateDestinationRequest extends AdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.CreateUserReply extends AdminReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.CreateUserRequest extends AdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.DeleteDestination extends AdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.DeleteQueueMessage extends DestinationAdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.DeleteSubscriptionMessage extends SubscriptionAdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.DeleteUser extends AdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.DelRemoteDestination extends DestinationAdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.DestinationAdminRequest extends AdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetConfigRequest extends AdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetDeliveredMessages extends DestinationAdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetDestinationsReply extends AdminReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetDestinationsRequest extends AdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetDMQSettingsReply extends AdminReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetDMQSettingsRequest extends DestinationAdminRequest implements Serializable

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetDomainNames extends AdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetDomainNamesRep extends AdminReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetFatherReply extends AdminReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetFatherRequest extends DestinationAdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetJMXAttsReply extends AdminReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetJMXAttsRequest extends AdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetLocalServer extends AdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetLocalServerRep extends AdminReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetNbMaxMsgRequest extends DestinationAdminRequest implements Serializable

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetNumberReply extends AdminReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetPendingMessages extends DestinationAdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetPendingRequests extends DestinationAdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetQueueMessage extends DestinationAdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetQueueMessageIds extends DestinationAdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetQueueMessageIdsRep extends AdminReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetQueueMessageRep extends AdminReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetRightsReply extends AdminReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetRightsRequest extends AdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetServersIdsReply extends AdminReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetServersIdsRequest extends AdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetStatsReply extends AdminReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetStatsRequest extends AdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetSubscriberIds extends DestinationAdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetSubscriberIdsRep extends AdminReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetSubscription extends SubscriptionAdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetSubscriptionMessage extends SubscriptionAdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetSubscriptionMessageIds extends SubscriptionAdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetSubscriptionMessageIdsRep extends AdminReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetSubscriptionMessageRep extends AdminReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetSubscriptionRep extends AdminReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetSubscriptions extends SubscriptionAdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetSubscriptionsRep extends AdminReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetSubscriptionsRequest extends DestinationAdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetUsersReply extends AdminReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.GetUsersRequest extends AdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.RemoveDomainRequest extends AdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.RemoveServerRequest extends AdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.RemoveServiceRequest extends AdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.ScaleRequest extends DestinationAdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.SendDestinationsWeights extends DestinationAdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.SetDMQRequest extends AdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.SetFather extends DestinationAdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.SetNbMaxMsgRequest extends DestinationAdminRequest implements Serializable

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.SetReader extends SetRight implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.SetRight extends DestinationAdminRequest implements Serializable

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.SetSyncExceptionOnFullDestRequest extends DestinationAdminRequest implements Serializable

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.SetThresholdRequest extends DestinationAdminRequest implements Serializable

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.SetWriter extends SetRight implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.StopServerRequest extends AdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.SubscriptionAdminRequest extends UserAdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.UnsetReader extends SetRight implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.UnsetWriter extends SetRight implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.UpdateUser extends AdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.admin.UserAdminRequest extends AdminRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Package org.objectweb.joram.shared.client

Class org.objectweb.joram.shared.client.AbstractJmsMessage extends Object implements Serializable

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.AbstractJmsReply extends AbstractJmsMessage implements Serializable

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.AbstractJmsRequest extends AbstractJmsMessage implements Serializable

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.ActivateConsumerRequest extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.AddClientIDReply extends AbstractJmsReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.AddClientIDRequest extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.CnxCloseReply extends AbstractJmsReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.CnxCloseRequest extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.CnxConnectReply extends AbstractJmsReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.CnxConnectRequest extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.CnxStartRequest extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.CnxStopRequest extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.CommitRequest extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.ConsumerAckRequest extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.ConsumerCloseSubRequest extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.ConsumerDenyRequest extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.ConsumerMessages extends AbstractJmsReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.ConsumerReceiveRequest extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.ConsumerSetListRequest extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.ConsumerSubRequest extends AbstractJmsRequest implements Serializable

serialVersionUID:

2L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.ConsumerUnsetListRequest extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.ConsumerUnsubRequest extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.GetAdminTopicReply extends AbstractJmsReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.GetAdminTopicRequest extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.JmsRequestGroup extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.MomExceptionReply extends AbstractJmsReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.PingRequest extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.ProducerMessages extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.QBrowseReply extends AbstractJmsReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.QBrowseRequest extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.ServerReply extends AbstractJmsReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.SessAckRequest extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.SessCreateDestReply extends AbstractJmsReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.SessCreateDestRequest extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.SessDenyRequest extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.TempDestDeleteRequest extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.XACnxCommit extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.XACnxPrepare extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.XACnxRecoverReply extends AbstractJmsReply implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.XACnxRecoverRequest extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Class org.objectweb.joram.shared.client.XACnxRollback extends AbstractJmsRequest implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

Throws:

IOException

Package org.objectweb.joram.shared.excepts

Class org.objectweb.joram.shared.excepts.AccessException extends MomException implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.shared.excepts.DestinationException extends MomException implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.shared.excepts.MessageValueException extends MomException implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.shared.excepts.MomException extends Exception implements Serializable

serialVersionUID:

1L

Serialized Fields

type

int type

Class org.objectweb.joram.shared.excepts.RequestException extends MomException implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.shared.excepts.SelectorException extends MomException implements Serializable

serialVersionUID:

1L

Class org.objectweb.joram.shared.excepts.StateException extends MomException implements Serializable

serialVersionUID:

1L

Package org.objectweb.joram.shared.messages

Class org.objectweb.joram.shared.messages.Message extends Object implements Serializable

serialVersionUID:

3L

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:

ClassNotFoundException

IOException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

***** ***** ***** ***** ***** ***** ***** Serializable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Package org.objectweb.joram.shared.security

Class org.objectweb.joram.shared.security.Identity extends Object implements Serializable

serialVersionUID:

4314723884869555244L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Class org.objectweb.joram.shared.security.SimpleIdentity extends Identity implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Package org.objectweb.joram.shared.security.jaas

Class org.objectweb.joram.shared.security.jaas.JonasIdentity extends Identity implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public final void readExternal(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public final void writeExternal(ObjectOutput out)
                         throws IOException

***** ***** ***** ***** ***** ***** ***** Externalizable interface ***** ***** ***** ***** ***** ***** ***** *****

Throws:

IOException

Package org.ow2.joram.jakarta.connector

Class org.ow2.joram.jakarta.connector.ActivationSpecImpl extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

acknowledgeMode

String acknowledgeMode

Acknowledgement mode.

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.

collocated

Boolean collocated

true if the underlying JORAM server is collocated.

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.

deleteDurableSubscription

Boolean deleteDurableSubscription

Determine whether durable subscription must be deleted or not at close time of the InboundConsumer.

Default is false.

destination

String destination

The name of the destination to get messages from.

destinationType

String destinationType

The type of the destination to get messages from.

hostName

String hostName

Host name or IP of the underlying JORAM server.

identityClass

String identityClass

identity class name.

maxMessages

String maxMessages

The maximum number of messages that can be assigned to a server session at one time Default is 10.

maxNumberOfWorks

String maxNumberOfWorks

Maximum number of work instances to be submitted (0 for infinite).

messageSelector

String messageSelector

Message selector.

name

String name

password

String password

User password.

queueMessageReadMax

int queueMessageReadMax

The maximum number of messages that can be read at once from a queue. Default value is 2 in order to compensate the former subscription mechanism.

serverPort

int serverPort

Port number of the underlying JORAM server.

subscriptionDurability

String subscriptionDurability

Subscription durability.

subscriptionName

String subscriptionName

Durable subscription name, if any.

topicAckBufferMax

int topicAckBufferMax

The maximum number of acknowledgements that can be buffered in Session.DUPS_OK_ACKNOWLEDGE mode when listening to a topic. Default is 0.

topicActivationThreshold

int topicActivationThreshold

This threshold is the minimum messages number below which the subscription is activated. Default is 0.

topicPassivationThreshold

int topicPassivationThreshold

This threshold is the maximum messages number over which the subscription is passivated. Default is Integer.MAX_VALUE.

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".

userName

String userName

User identification.

Class org.ow2.joram.jakarta.connector.DefaultConnectionManager extends Object implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.jakarta.connector.JoramAdapter extends JoramResourceAdapter implements Serializable

serialVersionUID:

1L

Serialized Fields

adminDurationState

long adminDurationState

The duration of admin connection before change state.

adminFileExportXML

String adminFileExportXML

Path to the XML file containing a description of the exported administered objects (destination) from the platform.

adminFileXML

String adminFileXML

Path to the XML file (joramAdmin.xml) containing a description of the administered objects to create and bind.

cnx

jakarta.jms.Connection cnx

collocated

boolean collocated

true if the underlying JORAM server is collocated.

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.

hostName

String hostName

Host name or IP of the underlying JORAM server. localhost if collocated.

identityClass

String identityClass

Identity class needed for authentication

isActive

boolean isActive

true if admin connection connection is active.

platformConfigDir

String platformConfigDir

Path to the directory containing JORAM's configuration files (a3servers.xml, a3debug.cfg and admin file), needed when StartJoramServer is set to true.

registration

org.osgi.framework.ServiceRegistration<?> registration

rootName

String rootName

login name for administrator.

rootPasswd

String rootPasswd

password for administrator

serverDesc

ServerDesc serverDesc

serverId

short serverId

Identifier of the JORAM server to start.

serverPort

int serverPort

Port number of the underlying JORAM server. -1 if collocated

startJoramServer

boolean startJoramServer

true start the JoramServer

storage

String storage

the persistence directory of the JORAM server to start, needed when StartJoramServer is set to true.

wrapper

JoramAdmin wrapper

Class org.ow2.joram.jakarta.connector.JoramResourceAdapter extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

boundNames

Vector<String> boundNames

Names of the bound objects.

jndiHelper

JndiHelper jndiHelper

the jndi helper

jndiName

String jndiName

the Joram resource adapter jndi name

name

String name

the Joram resource adapter name

status

JoramResourceAdapter.Status status

The resource adapter status.

Class org.ow2.joram.jakarta.connector.ManagedConnectionFactoryConfig extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

asyncSend

boolean asyncSend

Determines whether the produced messages are asynchronously sent or not (without or with acknowledgement) Default is false (with ack).

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.

collocated

boolean collocated

true for collocated outbound connectivity.

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.

hostName

String hostName

Underlying JORAM server host name.

identityClass

String identityClass

Default identityClass

inInterceptors

String inInterceptors

Comma separated list of IN interceptors.

mode

String mode

multiThreadSync

boolean multiThreadSync

Determines whether client threads which are using the same connection are synchronized in order to group together the requests they send. Default is false.

multiThreadSyncDelay

int multiThreadSyncDelay

The maximum time the threads hang if 'multiThreadSync' is true. Either they wake up (wait time out) or they are notified (by the first woken up thread).

Default is 1 ms.

name

String name

outInterceptors

String outInterceptors

Comma separated list of OUT interceptors.

outLocalAddress

String outLocalAddress

This is the local IP address on which the TCP connection is activated. The value can either be a machine name, such as "java.sun.com", or a textual representation of its IP address.

outLocalPort

int outLocalPort

This is the local IP address port on which the TCP connection is activated

password

String password

Default user password.

serverPort

int serverPort

Underlying JORAM server port number. -1 if collocated

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".

userName

String userName

Default user identification.

Class org.ow2.joram.jakarta.connector.ManagedConnectionFactoryImpl extends ManagedConnectionFactoryConfig implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.jakarta.connector.ManagedQueueConnectionFactoryImpl extends ManagedConnectionFactoryImpl implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.jakarta.connector.ManagedTopicConnectionFactoryImpl extends ManagedConnectionFactoryImpl implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.jakarta.connector.OutboundConnectionFactory extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

cxManager

jakarta.resource.spi.ConnectionManager cxManager

Manager for connection pooling.

mcf

ManagedConnectionFactoryImpl mcf

Central manager for outbound connectivity.

reference

Reference reference

Naming reference of this instance.

Class org.ow2.joram.jakarta.connector.OutboundQueueConnectionFactory extends OutboundConnectionFactory implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.jakarta.connector.OutboundTopicConnectionFactory extends OutboundConnectionFactory implements Serializable

serialVersionUID:

1L

Package org.ow2.joram.jakarta.jms

Class org.ow2.joram.jakarta.jms.ConnectionFactory extends AbstractConnectionFactory implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.jakarta.jms.Destination extends AdministeredObject implements Serializable

serialVersionUID:

1L

Serialized Fields

adminName

String adminName

Symbolic name given by the administrator.

agentId

String agentId

Identifier of the agent destination. Be careful when using directly this attribute, it is null in clustered destination even the getDestination method is called.

type

byte type

Type of the destination: Queue or Topic, Temporary or not.

See Also:

Destination.getType()

wrapper

AdminItf wrapper

Administration wrapper used to perform administration stuff.

It is defined through AdminModule element, it is closed at the end of the script. if it is not defined the wrapper set at creation is used, if none the static AdminModule connection is used.

Class org.ow2.joram.jakarta.jms.FactoryParameters extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

asyncSend

boolean asyncSend

Determines whether the persistent produced messages are asynchronously sent (without acknowledge) or not.

Messages sent asynchronously may be lost if a failure occurs before the message is persisted on the server.

Non persistent messages are always sent without acknowledgment.

Default is false, persistent messages are sent with acknowledge.

clientID

String clientID

The clientID used by connection

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 approximatively more than 3* cnxPendingTimer, the connection is considered as dead and processed as required.

compressedMinSize

int compressedMinSize

This attribute defines the minimum size beyond which the message body is compressed. The default value is 0 (no compression).

compressionLevel

int compressionLevel

This attribute defines the compression level (0-9) used when the message body is compressed. The default value is 1 (Deflater.BEST_SPEED).

connectingTimer

int connectingTimer

Duration in seconds during which connecting is attempted (connecting might take time if the server is temporarily not reachable). A value of zero is interpreted as an infinite timeout. The connection will then block until established or a TCP error occurs.

The default value is 30.

host

String host

Name of host hosting the server to create connections with.

implicitAck

boolean implicitAck

Determines whether the messages consumed are implicitly acknowledged or not. When true messages are immediately removed from queue when delivered.

inInterceptors

List<MessageInterceptor> inInterceptors

List of Message interceptors while receiving a message.
These interceptors are called when Session#receive() is called.
The execution follows the order of the elements within the list.
This property is facultative. If set, then the MessageInterceptor handle callback method of the IN interceptors} are called.

messageIdPrefix

String messageIdPrefix

This attribute allows to customize the JMS MessageID adding the specified string. This value is overloaded by the property org.ow2.joram.jakarta.jms.messageid.prefix if it defined. By default empty.

multiThreadSync

boolean multiThreadSync

Determines whether client threads which are using the same connection are synchronized in order to group together the requests they send.

multiThreadSyncDelay

int multiThreadSyncDelay

The maximum time the threads hang if 'multiThreadSync' is true.

Either they wake up (wait time out) or they are notified (by the first waken up thread).

Default value is 1ms.

multiThreadSyncThreshold

int multiThreadSyncThreshold

The maximum numbers of threads that hang if 'multiThreadSync' is true.

Default value is 10 waiting threads.

noAckedQueue

boolean noAckedQueue

Set this attribute to true to increase performance. The default value is false (use the AckedQueue)

outInterceptors

List<MessageInterceptor> outInterceptors

List of Message interceptors while sending a message.
These interceptors are called when Session#send() is called.
The execution follows the order of the elements within the list.
This property is facultative. If set, then the MessageInterceptor handle callback method of the OUT interceptors} are called.

outLocalAddress

String outLocalAddress

This is the local IP address on which the TCP connection is activated.

The value can either be a machine name, such as "java.sun.com", or a textual representation of its IP address.

outLocalPort

int outLocalPort

This is the local IP address port on which the TCP connection is activated

port

int port

Port to be used for accessing the server.

queueMessageReadMax

int queueMessageReadMax

The maximum number of messages that can be read at once from a queue.

Default is 1.

socketFactory

String socketFactory

Allows to define a specific factory for socket in order to by-pass compatibility problem between JDK version. Currently there is two factories, The default factory one for JDK since 1.4, and SocketFactory13 for JDK prior to 1.4.

SoLinger

int SoLinger

Enable SO_LINGER with the specified linger time in seconds, if the value is less than 0 then it disables SO_LINGER. Default value is -1.

SoTimeout

int SoTimeout

Enable/disable SO_TIMEOUT with the specified timeout in milliseconds. The timeout must be > 0. A timeout of zero is interpreted as an infinite timeout. Default value is 0.

TcpNoDelay

boolean TcpNoDelay

Enable/disable TCP_NODELAY (disable/enable Nagle's algorithm), default value is true.

topicAckBufferMax

int topicAckBufferMax

The maximum number of acknowledgements that can be buffered in Session.DUPS_OK_ACKNOWLEDGE mode when listening to a topic.

Default value is 10.

topicActivationThreshold

int topicActivationThreshold

This threshold is the minimum messages number below which the subscription is activated.

Default value is 0.

topicPassivationThreshold

int topicPassivationThreshold

This threshold is the maximum messages number over which the subscription is passivated.

Default is Integer.MAX_VALUE.

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".

The default value is 0 (no timer).

url

String url

url needed to connect to joram HA

Class org.ow2.joram.jakarta.jms.Queue extends Destination implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.jakarta.jms.TemporaryQueue extends Queue implements Serializable

serialVersionUID:

1L

Serialized Fields

cnx

Connection cnx

The connection the queue belongs to, null if not known.

Class org.ow2.joram.jakarta.jms.TemporaryTopic extends Topic implements Serializable

serialVersionUID:

1L

Serialized Fields

cnx

Connection cnx

The connection the topic belongs to, null if not known.

Class org.ow2.joram.jakarta.jms.Topic extends Destination implements Serializable

serialVersionUID:

1L

Package org.ow2.joram.jakarta.jms.admin

Class org.ow2.joram.jakarta.jms.admin.AbstractConnectionFactory extends AdministeredObject implements Serializable

serialVersionUID:

-4654044059180563323L

Serialized Fields

cnxJMXBeanBaseName

String cnxJMXBeanBaseName

identity

Identity identity

Authentication identity.

identityClassName

String identityClassName

isSetIdentityClassName

boolean isSetIdentityClassName

params

FactoryParameters params

Object containing the factory's parameters.

reliableClass

String reliableClass

Reliable class name, for example use by ssl.

Class org.ow2.joram.jakarta.jms.admin.AdminException extends Exception implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.jakarta.jms.admin.AdministeredObject extends Object implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.jakarta.jms.admin.ClusterConnectionFactory extends AdministeredObject implements Serializable

serialVersionUID:

1L

Serialized Fields

cluster

Hashtable<String,ConnectionFactory> cluster

Class org.ow2.joram.jakarta.jms.admin.ClusterDestination extends Destination implements Serializable

serialVersionUID:

1L

Serialized Fields

cluster

Hashtable<String,Destination> cluster

Class org.ow2.joram.jakarta.jms.admin.ClusterQueue extends ClusterDestination implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.jakarta.jms.admin.ClusterTopic extends ClusterDestination implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.jakarta.jms.admin.NameAlreadyUsedException extends AdminException implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.jakarta.jms.admin.ServerIdAlreadyUsedException extends AdminException implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.jakarta.jms.admin.StartFailureException extends AdminException implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.jakarta.jms.admin.UnknownServerException extends AdminException implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.jakarta.jms.admin.User extends AdministeredObject implements Serializable

serialVersionUID:

1L

Serialized Fields

name

String name

The name of the user.

proxyId

String proxyId

Identifier of the user's proxy agent.

wrapper

AdminWrapper wrapper

Administration wrapper used to perform administration stuff.

It is defined through AdminModule element, it is closed at the end of the script. if it is not defined the wrapper set at creation is used, if none the static AdminModule connection is used.

Package org.ow2.joram.jakarta.jms.connection

Class org.ow2.joram.jakarta.jms.connection.AbortedRequestException extends Exception implements Serializable

serialVersionUID:

1L

Package org.ow2.joram.jakarta.jms.local

Class org.ow2.joram.jakarta.jms.local.LocalConnectionFactory extends ConnectionFactory implements Serializable

serialVersionUID:

1L

Package org.ow2.joram.jakarta.jms.tcp

Class org.ow2.joram.jakarta.jms.tcp.TcpConnectionFactory extends ConnectionFactory implements Serializable

serialVersionUID:

1L

Package org.ow2.joram.mom.amqp

Class org.ow2.joram.mom.amqp.AMQPAgent extends Agent implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.AMQPRequestNot extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

keyLock

long keyLock

obj

Object obj

proxyId

long proxyId

Class org.ow2.joram.mom.amqp.AMQPResponseNot extends Notification implements Serializable

serialVersionUID:

1L

Serialized Fields

keyLock

long keyLock

obj

Object obj

Class org.ow2.joram.mom.amqp.DirectExchange extends IExchange implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Throws:

IOException

Class org.ow2.joram.mom.amqp.FanoutExchange extends IExchange implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Throws:

IOException

Class org.ow2.joram.mom.amqp.HeadersExchange extends IExchange implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Throws:

IOException

Class org.ow2.joram.mom.amqp.IExchange extends Object implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Throws:

IOException

Class org.ow2.joram.mom.amqp.Message extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

body

byte[] body

exchange

String exchange

properties

AMQP.Basic.BasicProperties properties

queueMsgId

long queueMsgId

queueName

String queueName

queueSize

int queueSize

redelivered

boolean redelivered

routingKey

String routingKey

Class org.ow2.joram.mom.amqp.PublishRequest extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

body

byte[] body

bodyRead

int bodyRead

channel

int channel

header

AMQP.Basic.BasicProperties header

publish

AMQP.Basic.Publish publish

Class org.ow2.joram.mom.amqp.Queue extends Object implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Throws:

IOException

Class org.ow2.joram.mom.amqp.RestartNot extends Notification implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.TopicExchange extends IExchange implements Serializable

serialVersionUID:

1L

Serialization Methods

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Throws:

IOException

Package org.ow2.joram.mom.amqp.exceptions

Class org.ow2.joram.mom.amqp.exceptions.AccessRefusedException extends ChannelException implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.exceptions.AMQPException extends Exception implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.exceptions.ChannelErrorException extends ConnectionException implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.exceptions.ChannelException extends AMQPException implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.exceptions.CommandInvalidException extends ConnectionException implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.exceptions.ConnectionException extends AMQPException implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.exceptions.FrameErrorException extends ConnectionException implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.exceptions.InternalErrorException extends ConnectionException implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.exceptions.InterruptedException extends InternalErrorException implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.exceptions.NoConsumersException extends ChannelException implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.exceptions.NotAllowedException extends ConnectionException implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.exceptions.NotFoundException extends ChannelException implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.exceptions.NotImplementedException extends ConnectionException implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.exceptions.PreconditionFailedException extends ChannelException implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.exceptions.ResourceLockedException extends ChannelException implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.exceptions.SyntaxErrorException extends ConnectionException implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.exceptions.TransactionException extends InternalErrorException implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.exceptions.UnexpectedFrameException extends ConnectionException implements Serializable

serialVersionUID:

1L

Package org.ow2.joram.mom.amqp.marshalling

Class org.ow2.joram.mom.amqp.marshalling.AbstractMarshallingMethod extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

channelNumber

int channelNumber

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Basic.Ack extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

deliveryTag

long deliveryTag

multiple

boolean multiple

If set to 1, the delivery tag is treated as "up to and including", so that the client can acknowledge multiple messages with a single method. If set to zero, the delivery tag refers to a single message. If the multiple field is 1, and the delivery tag is zero, tells the server to acknowledge all outstanding messages.

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Basic.BasicProperties extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

appId

String appId

bitCount

int bitCount

clusterId

String clusterId

contentEncoding

String contentEncoding

contentType

String contentType

correlationId

String correlationId

deliveryMode

int deliveryMode

expiration

String expiration

flag

int flag

headers

Map headers

messageId

String messageId

priority

int priority

replyTo

String replyTo

timestamp

Date timestamp

type

String type

userId

String userId

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Basic.Cancel extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

consumerTag

String consumerTag

noWait

boolean noWait

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Basic.CancelOk extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

consumerTag

String consumerTag

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Basic.Consume extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

arguments

Map arguments

A set of arguments for the consume. The syntax and semantics of these arguments depends on the server implementation.

consumerTag

String consumerTag

Specifies the identifier for the consumer. The consumer tag is local to a channel, so two clients can use the same consumer tags. If this field is empty the server will generate a unique tag.

exclusive

boolean exclusive

Request exclusive consumer access, meaning only this consumer can access the queue.

noAck

boolean noAck

noLocal

boolean noLocal

noWait

boolean noWait

queue

String queue

Specifies the name of the queue to consume from.

reserved1

int reserved1

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Basic.ConsumeOk extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

consumerTag

String consumerTag

Holds the consumer tag specified by the client or provided by the server.

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Basic.Deliver extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

consumerTag

String consumerTag

deliveryTag

long deliveryTag

exchange

String exchange

Specifies the name of the exchange that the message was originally published to. May be empty, indicating the default exchange.

redelivered

boolean redelivered

routingKey

String routingKey

Specifies the routing key name specified when the message was published.

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Basic.Get extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

noAck

boolean noAck

queue

String queue

Specifies the name of the queue to get a message from.

reserved1

int reserved1

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Basic.GetEmpty extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

reserved1

String reserved1

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Basic.GetOk extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

deliveryTag

long deliveryTag

exchange

String exchange

Specifies the name of the exchange that the message was originally published to. If empty, the message was published to the default exchange.

messageCount

int messageCount

redelivered

boolean redelivered

routingKey

String routingKey

Specifies the routing key name specified when the message was published.

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Basic.Publish extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

exchange

String exchange

Specifies the name of the exchange to publish to. The exchange name can be empty, meaning the default exchange. If the exchange name is specified, and that exchange does not exist, the server will raise a channel exception.

immediate

boolean immediate

This flag tells the server how to react if the message cannot be routed to a queue consumer immediately. If this flag is set, the server will return an undeliverable message with a Return method. If this flag is zero, the server will queue the message, but with no guarantee that it will ever be consumed.

mandatory

boolean mandatory

This flag tells the server how to react if the message cannot be routed to a queue. If this flag is set, the server will return an unroutable message with a Return method. If this flag is zero, the server silently drops the message.

reserved1

int reserved1

routingKey

String routingKey

Specifies the routing key for the message. The routing key is used for routing messages depending on the exchange configuration.

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Basic.Qos extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

global

boolean global

By default the QoS settings apply to the current channel only. If this field is set, they are applied to the entire connection.

prefetchCount

int prefetchCount

Specifies a prefetch window in terms of whole messages. This field may be used in combination with the prefetch-size field; a message will only be sent in advance if both prefetch windows (and those at the channel and connection level) allow it. The prefetch-count is ignored if the no-ack option is set.

prefetchSize

int prefetchSize

The client can request that messages be sent in advance so that when the client finishes processing a message, the following message is already held locally, rather than needing to be sent down the channel. Prefetching gives a performance improvement. This field specifies the prefetch window size in octets. The server will send a message in advance if it is equal to or smaller in size than the available prefetch size (and also falls into other prefetch limits). May be set to zero, meaning "no specific limit", although other prefetch limits may still apply. The prefetch-size is ignored if the no-ack option is set.

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Basic.QosOk extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Basic.Recover extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

requeue

boolean requeue

If this field is zero, the message will be redelivered to the original recipient. If this bit is 1, the server will attempt to requeue the message, potentially then delivering it to an alternative subscriber.

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Basic.RecoverAsync extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

requeue

boolean requeue

If this field is zero, the message will be redelivered to the original recipient. If this bit is 1, the server will attempt to requeue the message, potentially then delivering it to an alternative subscriber.

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Basic.RecoverOk extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Basic.Reject extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

deliveryTag

long deliveryTag

requeue

boolean requeue

If requeue is true, the server will attempt to requeue the message. If requeue is false or the requeue attempt fails the messages are discarded or dead-lettered.

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Basic.Return extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

exchange

String exchange

Specifies the name of the exchange that the message was originally published to. May be empty, meaning the default exchange.

replyCode

int replyCode

replyText

String replyText

routingKey

String routingKey

Specifies the routing key name specified when the message was published.

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Channel.Close extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

classId

int classId

When the close is provoked by a method exception, this is the class of the method.

methodId

int methodId

When the close is provoked by a method exception, this is the ID of the method.

replyCode

int replyCode

replyText

String replyText

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Channel.CloseOk extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Channel.Flow extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

active

boolean active

If 1, the peer starts sending content frames. If 0, the peer stops sending content frames.

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Channel.FlowOk extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

active

boolean active

Confirms the setting of the processed flow method: 1 means the peer will start sending or continue to send content frames; 0 means it will not.

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Channel.Open extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

reserved1

String reserved1

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Channel.OpenOk extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

reserved1

LongString reserved1

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Connection.Close extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

classId

int classId

When the close is provoked by a method exception, this is the class of the method.

methodId

int methodId

When the close is provoked by a method exception, this is the ID of the method.

replyCode

int replyCode

replyText

String replyText

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Connection.CloseOk extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Connection.Open extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

reserved1

String reserved1

reserved2

boolean reserved2

virtualHost

String virtualHost

The name of the virtual host to work with.

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Connection.OpenOk extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

reserved1

String reserved1

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Connection.Secure extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

challenge

LongString challenge

Challenge information, a block of opaque binary data passed to the security mechanism.

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Connection.SecureOk extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

response

LongString response

A block of opaque data passed to the security mechanism. The contents of this data are defined by the SASL security mechanism.

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Connection.Start extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

locales

LongString locales

A list of the message locales that the server supports, delimited by spaces. The locale defines the language in which the server will send reply texts.

mechanisms

LongString mechanisms

A list of the security mechanisms that the server supports, delimited by spaces.

serverProperties

Map serverProperties

versionMajor

int versionMajor

The major version number can take any value from 0 to 99 as defined in the AMQP specification.

versionMinor

int versionMinor

The minor version number can take any value from 0 to 99 as defined in the AMQP specification.

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Connection.StartOk extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

clientProperties

Map clientProperties

locale

String locale

A single message locale selected by the client, which must be one of those specified by the server.

mechanism

String mechanism

A single security mechanisms selected by the client, which must be one of those specified by the server.

response

LongString response

A block of opaque data passed to the security mechanism. The contents of this data are defined by the SASL security mechanism.

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Connection.Tune extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

channelMax

int channelMax

Specifies highest channel number that the server permits. Usable channel numbers are in the range 1..channel-max. Zero indicates no specified limit.

frameMax

int frameMax

The largest frame size that the server proposes for the connection, including frame header and end-byte. The client can negotiate a lower value. Zero means that the server does not impose any specific limit but may reject very large frames if it cannot allocate resources for them.

heartbeat

int heartbeat

The delay, in seconds, of the connection heartbeat that the server wants. Zero means the server does not want a heartbeat.

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Connection.TuneOk extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

channelMax

int channelMax

The maximum total number of channels that the client will use per connection.

frameMax

int frameMax

The largest frame size that the client and server will use for the connection. Zero means that the client does not impose any specific limit but may reject very large frames if it cannot allocate resources for them. Note that the frame-max limit applies principally to content frames, where large contents can be broken into frames of arbitrary size.

heartbeat

int heartbeat

The delay, in seconds, of the connection heartbeat that the client wants. Zero means the client does not want a heartbeat.

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Exchange.Declare extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

arguments

Map arguments

A set of arguments for the declaration. The syntax and semantics of these arguments depends on the server implementation.

durable

boolean durable

If set when creating a new exchange, the exchange will be marked as durable. Durable exchanges remain active when a server restarts. Non-durable exchanges (transient exchanges) are purged if/when a server restarts.

exchange

String exchange

noWait

boolean noWait

passive

boolean passive

If set, the server will reply with Declare-Ok if the exchange already exists with the same name, and raise an error if not. The client can use this to check whether an exchange exists without modifying the server state. When set, all other method fields except name and no-wait are ignored. A declare with both passive and no-wait has no effect. Arguments are compared for semantic equivalence.

reserved1

int reserved1

reserved2

boolean reserved2

reserved3

boolean reserved3

type

String type

Each exchange belongs to one of a set of exchange types implemented by the server. The exchange types define the functionality of the exchange - i.e. how messages are routed through it. It is not valid or meaningful to attempt to change the type of an existing exchange.

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Exchange.DeclareOk extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Exchange.Delete extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

exchange

String exchange

ifUnused

boolean ifUnused

If set, the server will only delete the exchange if it has no queue bindings. If the exchange has queue bindings the server does not delete it but raises a channel exception instead.

noWait

boolean noWait

reserved1

int reserved1

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Exchange.DeleteOk extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Queue.Bind extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

arguments

Map arguments

A set of arguments for the binding. The syntax and semantics of these arguments depends on the exchange class.

exchange

String exchange

noWait

boolean noWait

queue

String queue

Specifies the name of the queue to bind.

reserved1

int reserved1

routingKey

String routingKey

Specifies the routing key for the binding. The routing key is used for routing messages depending on the exchange configuration. Not all exchanges use a routing key - refer to the specific exchange documentation. If the queue name is empty, the server uses the last queue declared on the channel. If the routing key is also empty, the server uses this queue name for the routing key as well. If the queue name is provided but the routing key is empty, the server does the binding with that empty routing key. The meaning of empty routing keys depends on the exchange implementation.

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Queue.BindOk extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Queue.Declare extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

arguments

Map arguments

A set of arguments for the declaration. The syntax and semantics of these arguments depends on the server implementation.

autoDelete

boolean autoDelete

If set, the queue is deleted when all consumers have finished using it. The last consumer can be cancelled either explicitly or because its channel is closed. If there was no consumer ever on the queue, it won't be deleted. Applications can explicitly delete auto-delete queues using the Delete method as normal.

durable

boolean durable

If set when creating a new queue, the queue will be marked as durable. Durable queues remain active when a server restarts. Non-durable queues (transient queues) are purged if/when a server restarts. Note that durable queues do not necessarily hold persistent messages, although it does not make sense to send persistent messages to a transient queue.

exclusive

boolean exclusive

Exclusive queues may only be accessed by the current connection, and are deleted when that connection closes. Passive declaration of an exclusive queue by other connections are not allowed.

noWait

boolean noWait

passive

boolean passive

If set, the server will reply with Declare-Ok if the queue already exists with the same name, and raise an error if not. The client can use this to check whether a queue exists without modifying the server state. When set, all other method fields except name and no-wait are ignored. A declare with both passive and no-wait has no effect. Arguments are compared for semantic equivalence.

queue

String queue

reserved1

int reserved1

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Queue.DeclareOk extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

consumerCount

int consumerCount

Reports the number of active consumers for the queue. Note that consumers can suspend activity (Channel.Flow) in which case they do not appear in this count.

messageCount

int messageCount

queue

String queue

Reports the name of the queue. If the server generated a queue name, this field contains that name.

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Queue.Delete extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

ifEmpty

boolean ifEmpty

If set, the server will only delete the queue if it has no messages.

ifUnused

boolean ifUnused

If set, the server will only delete the queue if it has no consumers. If the queue has consumers the server does does not delete it but raises a channel exception instead.

noWait

boolean noWait

queue

String queue

Specifies the name of the queue to delete.

reserved1

int reserved1

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Queue.DeleteOk extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

messageCount

int messageCount

Reports the number of messages deleted.

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Queue.Purge extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

noWait

boolean noWait

queue

String queue

Specifies the name of the queue to purge.

reserved1

int reserved1

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Queue.PurgeOk extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

messageCount

int messageCount

Reports the number of messages purged.

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Queue.Unbind extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Serialized Fields

arguments

Map arguments

Specifies the arguments of the binding to unbind.

exchange

String exchange

The name of the exchange to unbind from.

queue

String queue

Specifies the name of the queue to unbind.

reserved1

int reserved1

routingKey

String routingKey

Specifies the routing key of the binding to unbind.

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Queue.UnbindOk extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Tx.Commit extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Tx.CommitOk extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Tx.Rollback extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Tx.RollbackOk extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Tx.Select extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.marshalling.AMQP.Tx.SelectOk extends AbstractMarshallingMethod implements Serializable

serialVersionUID:

1L

Class org.ow2.joram.mom.amqp.marshalling.LongStringHelper.ByteArrayLongString extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

bytes

byte[] bytes

Package org.ow2.joram.mom.amqp.structures

Class org.ow2.joram.mom.amqp.structures.Ack extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

idsToAck

List<Long> idsToAck

queueName

String queueName

Class org.ow2.joram.mom.amqp.structures.AddBoundExchange extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

exchangeName

String exchangeName

queueName

String queueName

Class org.ow2.joram.mom.amqp.structures.Cancel extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

channelNumber

int channelNumber

consumerTag

String consumerTag

queueName

String queueName

Class org.ow2.joram.mom.amqp.structures.Deliver extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

body

byte[] body

deliver

AMQP.Basic.Deliver deliver

msgId

long msgId

noAck

boolean noAck

properties

AMQP.Basic.BasicProperties properties

proxyId

long proxyId

queueName

String queueName

serverId

short serverId

Class org.ow2.joram.mom.amqp.structures.PublishToQueue extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

body

byte[] body

channelNumber

int channelNumber

exchangeName

String exchangeName

immediate

boolean immediate

properties

AMQP.Basic.BasicProperties properties

proxyId

long proxyId

queueName

String queueName

routingKey

String routingKey

serverId

short serverId

Class org.ow2.joram.mom.amqp.structures.Recover extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

idsToRecover

List<Long> idsToRecover

queueName

String queueName

Class org.ow2.joram.mom.amqp.structures.RemoveBoundExchange extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

exchangeName

String exchangeName

queueName

String queueName

Class org.ow2.joram.mom.amqp.structures.RemoveQueueBindings extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

exchangeName

String exchangeName

queueName

String queueName

Class org.ow2.joram.mom.amqp.structures.Returned extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

body

byte[] body

properties

AMQP.Basic.BasicProperties properties

proxyId

long proxyId

returned

AMQP.Basic.Return returned

serverId

short serverId