org.objectweb.joram.mom.dest.DestinationImpl

org.objectweb.joram.mom.dest.DestinationImpl Class Reference

Inherits org.objectweb.joram.mom.dest.DestinationImplMBean.

Inherited by org.objectweb.joram.mom.dest.QueueImpl, and org.objectweb.joram.mom.dest.TopicImpl.

Inheritance diagram for org.objectweb.joram.mom.dest.DestinationImpl:

Inheritance graph
[legend]
Collaboration diagram for org.objectweb.joram.mom.dest.DestinationImpl:

Collaboration graph
[legend]
List of all members.

Public Member Functions

final AgentId getId ()
 DestinationImpl (AgentId adminId, Properties prop)
abstract void initialize (boolean firstTime)
void setAgent (Destination agent)
boolean canBeDeleted ()
void setRightRequest (AgentId from, SetRightRequest not) throws AccessException
void setDMQRequest (AgentId from, SetDMQRequest not) throws AccessException
void monitGetReaders (AgentId from, Monit_GetReaders not) throws AccessException
void monitGetWriters (AgentId from, Monit_GetWriters not) throws AccessException
String[] getRights ()
String getRight (String userid)
void monitFreeAccess (AgentId from, Monit_FreeAccess not) throws AccessException
void monitGetDMQSettings (AgentId from, Monit_GetDMQSettings not) throws AccessException
void monitGetStat (AgentId from, Monit_GetStat not) throws AccessException
void unknownAgent (AgentId from, UnknownAgent not)
void deleteNot (AgentId from, DeleteNot not)
void specialAdminRequest (AgentId from, SpecialAdminRequest not)
void requestGroupNot (AgentId from, RequestGroupNot not)
SetRightRequest preProcess (SetRightRequest req)
void postProcess (SetRightRequest req)
ClientMessages preProcess (AgentId from, ClientMessages msgs)
void postProcess (ClientMessages msgs)
final String getDestinationId ()
boolean isFreeReading ()
void setFreeReading (boolean on)
boolean isFreeWriting ()
void setFreeWriting (boolean on)
String getDMQId ()
long getCreationTimeInMillis ()
String getCreationDate ()
abstract long getNbMsgsReceiveSinceCreation ()
long getNbMsgsDeliverSinceCreation ()
long getNbMsgsSentToDMQSinceCreation ()
final void forward (AgentId to, Notification not)

Public Attributes

long creationDate = -1

Static Public Attributes

static Logger logger = Debug.getLogger(DestinationImpl.class.getName())
static int READ = 1
static int WRITE = 2
static int READWRITE = 3
static String[] _rights = {":R;", ";W;", ":RW;"}

Protected Member Functions

boolean isLocal (AgentId id)
void processSetRight (AgentId user, int right) throws RequestException
Hashtable getStatisticHashtable ()
void clientMessages (AgentId from, ClientMessages not) throws AccessException
Object specialAdminProcess (SpecialAdminRequest not) throws RequestException
boolean isReader (AgentId client)
boolean isWriter (AgentId client)
boolean isAdministrator (AgentId client)
void replyToTopic (org.objectweb.joram.shared.admin.AdminReply reply, AgentId replyTo, String requestMsgId, String replyMsgId)

Protected Attributes

transient Destination agent
boolean freeReading = false
boolean freeWriting = false
Hashtable clients
AgentId dmqId = null
long nbMsgsReceiveSinceCreation = 0
long nbMsgsDeliverSinceCreation = 0
long nbMsgsSentToDMQSinceCreation = 0

Package Functions

void setNoSave ()
void setSave ()

Package Attributes

transient StringBuffer strbuf

Detailed Description

The DestinationImpl class implements the common behaviour of MOM destinations.

Definition at line 70 of file DestinationImpl.java.

Constructor & Destructor Documentation

org.objectweb.joram.mom.dest.DestinationImpl.DestinationImpl ( AgentId  adminId,
Properties  prop 
)

Constructs a DestinationImpl.

Parameters:
destId Identifier of the agent hosting the destination.
adminId Identifier of the administrator of the destination.
prop The initial set of properties.

Definition at line 134 of file DestinationImpl.java.

References org.objectweb.joram.mom.dest.DestinationImpl.clients, org.objectweb.joram.mom.dest.DestinationImpl.creationDate, org.objectweb.joram.mom.dest.DestinationImpl.logger, and org.objectweb.joram.mom.dest.DestinationImpl.strbuf.

Member Function Documentation

final AgentId org.objectweb.joram.mom.dest.DestinationImpl.getId (  ) 

Identifier of the agent hosting the destination.

Definition at line 87 of file DestinationImpl.java.

References org.objectweb.joram.mom.dest.DestinationImpl.agent, fr.dyade.aaa.agent.Agent.getId(), and fr.dyade.aaa.agent.AgentId.nullId.

Referenced by org.objectweb.joram.mom.dest.QueueImpl.addMessage(), org.objectweb.joram.mom.dest.ClusterQueueImpl.addQueueCluster(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeQueueImpl.bridgeDelivery(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeTopicImpl.bridgeDeliveryNot(), org.objectweb.joram.mom.dest.QueueImpl.cleanPendingMessage(), org.objectweb.joram.mom.dest.DestinationImpl.clientMessages(), org.objectweb.joram.mom.dest.TopicImpl.clusterAck(), org.objectweb.joram.mom.dest.TopicImpl.clusterNot(), org.objectweb.joram.mom.dest.TopicImpl.clusterRequest(), org.objectweb.joram.mom.dest.TopicImpl.clusterTest(), org.objectweb.joram.mom.dest.AdminTopicImpl.clusterTest(), org.objectweb.joram.mom.dest.AdminTopicImpl.createDestination(), org.objectweb.joram.mom.dest.AdminTopicImpl.createDestinationAndSave(), org.objectweb.joram.mom.dest.AdminTopicImpl.CreateUserAndSave(), org.objectweb.joram.mom.dest.QueueImpl.denyRequest(), org.objectweb.joram.mom.dest.TopicImpl.doDeleteNot(), org.objectweb.joram.mom.dest.QueueImpl.doDeleteNot(), com.scalagent.joram.mom.dest.mail.JavaMailTopicImpl.doPop(), com.scalagent.joram.mom.dest.mail.JavaMailQueueImpl.doPop(), com.scalagent.joram.mom.dest.ftp.FtpQueueImpl.doProcessFtp(), org.objectweb.joram.mom.dest.QueueImpl.doUnknownAgent(), org.objectweb.joram.mom.dest.TopicImpl.fatherAck(), org.objectweb.joram.mom.dest.TopicImpl.fatherTest(), org.objectweb.joram.mom.dest.AdminTopicImpl.fatherTest(), org.objectweb.joram.mom.dest.DestinationImpl.getDestinationId(), org.objectweb.joram.mom.dest.QueueImpl.getMsgTxPrefix(), org.objectweb.joram.mom.dest.QueueImpl.handleExpiredNot(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeTopicImpl.initialize(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeQueueImpl.initialize(), org.objectweb.joram.mom.dest.ClusterQueueImpl.initialize(), com.scalagent.joram.mom.dest.ftp.FtpQueueImpl.initialize(), org.objectweb.joram.mom.dest.DestinationImpl.isLocal(), org.objectweb.joram.mom.dest.TopicImpl.monitGetCluster(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeTopicImpl.preProcess(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeQueueImpl.preProcess(), com.scalagent.joram.mom.dest.mail.JavaMailTopicImpl.preProcess(), com.scalagent.joram.mom.dest.mail.JavaMailQueueImpl.preProcess(), org.objectweb.joram.mom.dest.ClusterQueueImpl.removeQueueCluster(), com.scalagent.joram.mom.dest.scheduler.SchedulerQueueImpl.SchedulerQueueImpl(), org.objectweb.joram.mom.dest.ClusterQueueImpl.sendToCluster(), org.objectweb.joram.mom.dest.DestinationImpl.setDMQRequest(), org.objectweb.joram.mom.dest.TopicImpl.setFatherRequest(), org.objectweb.joram.mom.dest.QueueImpl.setNbMaxMsgRequest(), org.objectweb.joram.mom.dest.QueueImpl.setPeriod(), org.objectweb.joram.mom.dest.MonitoringTopicImpl.setPeriod(), org.objectweb.joram.mom.dest.AdminTopicImpl.setRightAndSave(), org.objectweb.joram.mom.dest.DestinationImpl.setRightRequest(), org.objectweb.joram.mom.dest.QueueImpl.setThreshRequest(), org.objectweb.joram.mom.dest.DestinationImpl.specialAdminRequest(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeTopicImpl.topicForwardNot(), org.objectweb.joram.mom.dest.TopicImpl.toString(), org.objectweb.joram.mom.dest.QueueImpl.toString(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeTopicImpl.toString(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeQueueImpl.toString(), org.objectweb.joram.mom.dest.ClusterQueueImpl.toString(), com.scalagent.joram.mom.dest.mail.JavaMailTopicImpl.toString(), com.scalagent.joram.mom.dest.mail.JavaMailQueueImpl.toString(), com.scalagent.joram.mom.dest.ftp.FtpQueueImpl.toString(), org.objectweb.joram.mom.dest.TopicImpl.unclusterRequest(), org.objectweb.joram.mom.dest.DestinationImpl.unknownAgent(), org.objectweb.joram.mom.dest.TopicImpl.unsetFatherRequest(), org.objectweb.joram.mom.dest.MonitoringTopicImpl.wakeUpNot(), and org.objectweb.joram.mom.dest.ClusterQueueImpl.wakeUpNot().

Here is the call graph for this function:

abstract void org.objectweb.joram.mom.dest.DestinationImpl.initialize ( boolean  firstTime  )  [pure virtual]

Initializes the destination.

Parameters:
firstTime true when first called by the factory

Implemented in com.scalagent.joram.mom.dest.ftp.FtpQueueImpl, com.scalagent.joram.mom.dest.mail.JavaMailQueueImpl, com.scalagent.joram.mom.dest.mail.JavaMailTopicImpl, org.objectweb.joram.mom.dest.ClusterQueueImpl, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeQueueImpl, org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeTopicImpl, org.objectweb.joram.mom.dest.MonitoringTopicImpl, org.objectweb.joram.mom.dest.QueueImpl, and org.objectweb.joram.mom.dest.TopicImpl.

Referenced by org.objectweb.joram.mom.dest.Destination.agentInitialize().

boolean org.objectweb.joram.mom.dest.DestinationImpl.canBeDeleted (  ) 

Returns true if the destination might be deleted.

Definition at line 180 of file DestinationImpl.java.

Referenced by org.objectweb.joram.mom.dest.Destination.react().

void org.objectweb.joram.mom.dest.DestinationImpl.setRightRequest ( AgentId  from,
SetRightRequest  not 
) throws AccessException

Method implementing the reaction to a SetRightRequest notification requesting rights to be set for a user.

Exceptions:
AccessException If the requester is not the administrator.

Reimplemented in org.objectweb.joram.mom.dest.AdminTopicImpl.

Definition at line 190 of file DestinationImpl.java.

References org.objectweb.joram.mom.dest.DestinationImpl.forward(), org.objectweb.joram.mom.dest.DestinationImpl.getId(), org.objectweb.joram.mom.dest.DestinationImpl.isAdministrator(), org.objectweb.joram.mom.dest.DestinationImpl.logger, org.objectweb.joram.mom.dest.DestinationImpl.processSetRight(), org.objectweb.joram.mom.dest.DestinationImpl.strbuf, and org.objectweb.joram.mom.dest.DestinationImplMBean.toString().

Referenced by org.objectweb.joram.mom.dest.Destination.react().

Here is the call graph for this function:

void org.objectweb.joram.mom.dest.DestinationImpl.processSetRight ( AgentId  user,
int  right 
) throws RequestException [protected]

set user right.

Definition at line 226 of file DestinationImpl.java.

References org.objectweb.joram.mom.dest.DestinationImpl.clients, org.objectweb.joram.mom.dest.DestinationImpl.freeReading, org.objectweb.joram.mom.dest.DestinationImpl.freeWriting, org.objectweb.joram.mom.dest.DestinationImpl.READ, org.objectweb.joram.mom.dest.DestinationImpl.READWRITE, org.objectweb.joram.mom.dest.DestinationImpl.setSave(), and org.objectweb.joram.mom.dest.DestinationImpl.WRITE.

Referenced by org.objectweb.joram.mom.dest.DestinationImpl.setRightRequest().

Here is the call graph for this function:

void org.objectweb.joram.mom.dest.DestinationImpl.setDMQRequest ( AgentId  from,
SetDMQRequest  not 
) throws AccessException

Method implementing the reaction to a SetDMQRequest notification setting the dead message queue identifier for this destination.

Exceptions:
AccessException If the requester is not the administrator.

Reimplemented in org.objectweb.joram.mom.dest.AdminTopicImpl.

Definition at line 278 of file DestinationImpl.java.

References org.objectweb.joram.mom.dest.DestinationImpl.dmqId, org.objectweb.joram.mom.dest.DestinationImpl.forward(), org.objectweb.joram.mom.dest.DestinationImpl.getId(), org.objectweb.joram.mom.dest.DestinationImpl.isAdministrator(), org.objectweb.joram.mom.dest.DestinationImpl.logger, org.objectweb.joram.mom.dest.DestinationImpl.setSave(), and org.objectweb.joram.mom.dest.DestinationImpl.strbuf.

Referenced by org.objectweb.joram.mom.dest.Destination.react().

Here is the call graph for this function:

void org.objectweb.joram.mom.dest.DestinationImpl.monitGetReaders ( AgentId  from,
Monit_GetReaders  not 
) throws AccessException

Method implementing the reaction to a Monit_GetReaders notification requesting the identifiers of the destination's readers.

Exceptions:
AccessException If the requester is not the administrator.

Definition at line 307 of file DestinationImpl.java.

References org.objectweb.joram.mom.dest.DestinationImpl.clients, org.objectweb.joram.mom.dest.DestinationImpl.forward(), org.objectweb.joram.mom.dest.DestinationImpl.isAdministrator(), org.objectweb.joram.mom.dest.DestinationImpl.READ, and org.objectweb.joram.mom.dest.DestinationImpl.READWRITE.

Referenced by org.objectweb.joram.mom.dest.Destination.react().

Here is the call graph for this function:

void org.objectweb.joram.mom.dest.DestinationImpl.monitGetWriters ( AgentId  from,
Monit_GetWriters  not 
) throws AccessException

Method implementing the reaction to a Monit_GetWriters notification requesting the identifiers of the destination's writers.

Exceptions:
AccessException If the requester is not the administrator.

Definition at line 330 of file DestinationImpl.java.

References org.objectweb.joram.mom.dest.DestinationImpl.clients, org.objectweb.joram.mom.dest.DestinationImpl.forward(), org.objectweb.joram.mom.dest.DestinationImpl.isAdministrator(), org.objectweb.joram.mom.dest.DestinationImpl.READWRITE, and org.objectweb.joram.mom.dest.DestinationImpl.WRITE.

Referenced by org.objectweb.joram.mom.dest.Destination.react().

Here is the call graph for this function:

String [] org.objectweb.joram.mom.dest.DestinationImpl.getRights (  ) 

Returns a string representation of the rights set on this destination.

Returns:
the rights set on this destination.

Implements org.objectweb.joram.mom.dest.DestinationImplMBean.

Definition at line 354 of file DestinationImpl.java.

References org.objectweb.joram.mom.dest.DestinationImpl._rights, org.objectweb.joram.mom.dest.DestinationImpl.clients, and fr.dyade.aaa.agent.AgentId.toString().

Here is the call graph for this function:

String org.objectweb.joram.mom.dest.DestinationImpl.getRight ( String  userid  ) 

Returns a string representation of rights set on this destination for a particular user. The user is pointed out by its unique identifier.

Parameters:
userid The user's unique identifier.
Returns:
the rights set on this destination.

Implements org.objectweb.joram.mom.dest.DestinationImplMBean.

Definition at line 377 of file DestinationImpl.java.

References org.objectweb.joram.mom.dest.DestinationImpl._rights, and org.objectweb.joram.mom.dest.DestinationImpl.clients.

void org.objectweb.joram.mom.dest.DestinationImpl.monitFreeAccess ( AgentId  from,
Monit_FreeAccess  not 
) throws AccessException

Method implementing the reaction to a Monit_FreeAccess notification requesting the free access status of this destination.

Exceptions:
AccessException If the requester is not the administrator.

Definition at line 398 of file DestinationImpl.java.

References org.objectweb.joram.mom.dest.DestinationImpl.forward(), org.objectweb.joram.mom.dest.DestinationImpl.freeReading, org.objectweb.joram.mom.dest.DestinationImpl.freeWriting, and org.objectweb.joram.mom.dest.DestinationImpl.isAdministrator().

Referenced by org.objectweb.joram.mom.dest.Destination.react().

Here is the call graph for this function:

void org.objectweb.joram.mom.dest.DestinationImpl.monitGetDMQSettings ( AgentId  from,
Monit_GetDMQSettings  not 
) throws AccessException

Method implementing the reaction to a Monit_GetDMQSettings notification requesting the destination's DMQ settings.

Exceptions:
AccessException If the requester is not the administrator.

Reimplemented in org.objectweb.joram.mom.dest.QueueImpl.

Definition at line 411 of file DestinationImpl.java.

References org.objectweb.joram.mom.dest.DestinationImpl.dmqId, org.objectweb.joram.mom.dest.DestinationImpl.forward(), org.objectweb.joram.mom.dest.DestinationImpl.isAdministrator(), and fr.dyade.aaa.agent.AgentId.toString().

Referenced by org.objectweb.joram.mom.dest.Destination.react().

Here is the call graph for this function:

void org.objectweb.joram.mom.dest.DestinationImpl.monitGetStat ( AgentId  from,
Monit_GetStat  not 
) throws AccessException

Method implementing the reaction to a Monit_GetStat notification requesting to get statistic of this destination.

Exceptions:
AccessException If the requester is not the administrator.

Definition at line 428 of file DestinationImpl.java.

References org.objectweb.joram.mom.dest.DestinationImpl.forward(), org.objectweb.joram.mom.dest.DestinationImpl.getStatisticHashtable(), and org.objectweb.joram.mom.dest.DestinationImpl.isAdministrator().

Referenced by org.objectweb.joram.mom.dest.Destination.react().

Here is the call graph for this function:

Hashtable org.objectweb.joram.mom.dest.DestinationImpl.getStatisticHashtable (  )  [protected]

Gets some statistics about the destination

Returns:
a Hashtable with some information statistics about the destination. Keys are String describing the values.

Reimplemented in org.objectweb.joram.mom.dest.QueueImpl.

Definition at line 440 of file DestinationImpl.java.

References org.objectweb.joram.mom.dest.DestinationImpl.creationDate, org.objectweb.joram.mom.dest.DestinationImpl.getNbMsgsDeliverSinceCreation(), org.objectweb.joram.mom.dest.DestinationImpl.getNbMsgsReceiveSinceCreation(), and org.objectweb.joram.mom.dest.DestinationImpl.getNbMsgsSentToDMQSinceCreation().

Referenced by org.objectweb.joram.mom.dest.DestinationImpl.monitGetStat().

Here is the call graph for this function:

void org.objectweb.joram.mom.dest.DestinationImpl.clientMessages ( AgentId  from,
ClientMessages  not 
) throws AccessException [protected]

Method implementing the reaction to a ClientMessages notification holding messages sent by a client.

If the sender is not a writer on the destination the messages are sent to the DMQ and an exception is thrown. Otherwise, the processing of the received messages is performed in subclasses.

Exceptions:
AccessException If the sender is not a WRITER on the destination.

Definition at line 460 of file DestinationImpl.java.

References org.objectweb.joram.mom.util.DMQManager.addDeadMessage(), org.objectweb.joram.mom.dest.DestinationImpl.dmqId, org.objectweb.joram.mom.dest.DestinationImpl.forward(), org.objectweb.joram.mom.dest.DestinationImpl.getId(), org.objectweb.joram.mom.dest.DestinationImpl.isWriter(), org.objectweb.joram.mom.dest.DestinationImpl.logger, org.objectweb.joram.mom.dest.DestinationImpl.nbMsgsSentToDMQSinceCreation, and org.objectweb.joram.mom.util.DMQManager.sendToDMQ().

Referenced by org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeQueueImpl.bridgeDelivery(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeTopicImpl.bridgeDeliveryNot(), org.objectweb.joram.mom.dest.Destination.react(), org.objectweb.joram.mom.dest.DestinationImpl.replyToTopic(), org.objectweb.joram.mom.dest.AdminTopicImpl.requestGroupNot(), and org.objectweb.joram.mom.dest.MonitoringTopicImpl.wakeUpNot().

Here is the call graph for this function:

void org.objectweb.joram.mom.dest.DestinationImpl.unknownAgent ( AgentId  from,
UnknownAgent  not 
)

Method implementing the reaction to an UnknownAgent notification.

If the unknown agent is the DMQ, its identifier is set to null. If it is a client of the destination, it is removed. Specific processing is also done in subclasses.

Definition at line 498 of file DestinationImpl.java.

References fr.dyade.aaa.agent.UnknownAgent.agent, org.objectweb.joram.mom.dest.DestinationImpl.clients, org.objectweb.joram.mom.dest.DestinationImpl.dmqId, fr.dyade.aaa.agent.AgentId.equals(), org.objectweb.joram.mom.dest.DestinationImpl.getId(), org.objectweb.joram.mom.dest.DestinationImpl.isAdministrator(), org.objectweb.joram.mom.dest.DestinationImpl.logger, and org.objectweb.joram.mom.dest.DestinationImpl.setSave().

Referenced by org.objectweb.joram.mom.dest.Destination.react().

Here is the call graph for this function:

void org.objectweb.joram.mom.dest.DestinationImpl.deleteNot ( AgentId  from,
DeleteNot  not 
)

Method implementing the reaction to a DeleteNot notification requesting the deletion of the destination.

The processing is done in subclasses if the sender is an administrator.

Reimplemented in org.objectweb.joram.mom.dest.AdminTopicImpl.

Definition at line 521 of file DestinationImpl.java.

References org.objectweb.joram.mom.dest.DestinationImpl.isAdministrator(), org.objectweb.joram.mom.dest.DestinationImpl.logger, and org.objectweb.joram.mom.dest.DestinationImpl.setSave().

Referenced by org.objectweb.joram.mom.dest.Destination.react().

Here is the call graph for this function:

void org.objectweb.joram.mom.dest.DestinationImpl.specialAdminRequest ( AgentId  from,
SpecialAdminRequest  not 
)

Method implementing the reaction to a SpecialAdminRequest notification requesting the special administration of the destination.

Definition at line 539 of file DestinationImpl.java.

References org.objectweb.joram.mom.dest.DestinationImpl.forward(), org.objectweb.joram.mom.dest.DestinationImpl.getId(), org.objectweb.joram.mom.dest.DestinationImpl.isAdministrator(), org.objectweb.joram.mom.dest.DestinationImpl.logger, org.objectweb.joram.mom.dest.DestinationImpl.setSave(), org.objectweb.joram.mom.dest.DestinationImpl.specialAdminProcess(), org.objectweb.joram.mom.dest.DestinationImpl.strbuf, and org.objectweb.joram.mom.dest.DestinationImplMBean.toString().

Referenced by org.objectweb.joram.mom.dest.Destination.react().

Here is the call graph for this function:

boolean org.objectweb.joram.mom.dest.DestinationImpl.isReader ( AgentId  client  )  [protected]

Checks the reading permission of a given client agent.

Parameters:
client AgentId of the client requesting a reading permission.

Definition at line 615 of file DestinationImpl.java.

References org.objectweb.joram.mom.dest.DestinationImpl.clients, org.objectweb.joram.mom.dest.DestinationImpl.freeReading, org.objectweb.joram.mom.dest.DestinationImpl.isAdministrator(), org.objectweb.joram.mom.dest.DestinationImpl.READ, and org.objectweb.joram.mom.dest.DestinationImpl.READWRITE.

Referenced by org.objectweb.joram.mom.dest.QueueImpl.browseRequest(), org.objectweb.joram.mom.dest.TopicImpl.doRightRequest(), org.objectweb.joram.mom.dest.QueueImpl.doRightRequest(), org.objectweb.joram.mom.dest.QueueImpl.receiveRequest(), org.objectweb.joram.mom.dest.jmsbridge.JMSBridgeQueueImpl.receiveRequest(), and org.objectweb.joram.mom.dest.TopicImpl.subscribeRequest().

Here is the call graph for this function:

boolean org.objectweb.joram.mom.dest.DestinationImpl.isWriter ( AgentId  client  )  [protected]

Checks the writing permission of a given client agent.

Parameters:
client AgentId of the client requesting a writing permission.

Definition at line 632 of file DestinationImpl.java.

References org.objectweb.joram.mom.dest.DestinationImpl.clients, org.objectweb.joram.mom.dest.DestinationImpl.freeWriting, org.objectweb.joram.mom.dest.DestinationImpl.isAdministrator(), org.objectweb.joram.mom.dest.DestinationImpl.READWRITE, and org.objectweb.joram.mom.dest.DestinationImpl.WRITE.

Referenced by org.objectweb.joram.mom.dest.DestinationImpl.clientMessages().

Here is the call graph for this function:

boolean org.objectweb.joram.mom.dest.DestinationImpl.isAdministrator ( AgentId  client  )  [protected]

Checks the administering permission of a given client agent.

Parameters:
client AgentId of the client requesting an admin permission.

Definition at line 649 of file DestinationImpl.java.

References fr.dyade.aaa.agent.AgentId.equals().

Referenced by org.objectweb.joram.mom.dest.TopicImpl.clusterRequest(), org.objectweb.joram.mom.dest.DestinationImpl.deleteNot(), org.objectweb.joram.mom.dest.DestinationImpl.isReader(), org.objectweb.joram.mom.dest.DestinationImpl.isWriter(), org.objectweb.joram.mom.dest.DestinationImpl.monitFreeAccess(), org.objectweb.joram.mom.dest.TopicImpl.monitGetCluster(), org.objectweb.joram.mom.dest.QueueImpl.monitGetDMQSettings(), org.objectweb.joram.mom.dest.DestinationImpl.monitGetDMQSettings(), org.objectweb.joram.mom.dest.TopicImpl.monitGetFather(), org.objectweb.joram.mom.dest.QueueImpl.monitGetNbMaxMsg(), org.objectweb.joram.mom.dest.QueueImpl.monitGetPendingMessages(), org.objectweb.joram.mom.dest.QueueImpl.monitGetPendingRequests(), org.objectweb.joram.mom.dest.DestinationImpl.monitGetReaders(), org.objectweb.joram.mom.dest.DestinationImpl.monitGetStat(), org.objectweb.joram.mom.dest.TopicImpl.monitGetSubscriptions(), org.objectweb.joram.mom.dest.DestinationImpl.monitGetWriters(), org.objectweb.joram.mom.dest.DestinationImpl.setDMQRequest(), org.objectweb.joram.mom.dest.TopicImpl.setFatherRequest(), org.objectweb.joram.mom.dest.QueueImpl.setNbMaxMsgRequest(), org.objectweb.joram.mom.dest.DestinationImpl.setRightRequest(), org.objectweb.joram.mom.dest.QueueImpl.setThreshRequest(), org.objectweb.joram.mom.dest.DestinationImpl.specialAdminRequest(), org.objectweb.joram.mom.dest.TopicImpl.unclusterRequest(), org.objectweb.joram.mom.dest.DestinationImpl.unknownAgent(), and org.objectweb.joram.mom.dest.TopicImpl.unsetFatherRequest().

Here is the call graph for this function:

final String org.objectweb.joram.mom.dest.DestinationImpl.getDestinationId (  ) 

Returns the unique identifier of the destination.

Returns:
the unique identifier of the destination.

Implements org.objectweb.joram.mom.dest.DestinationImplMBean.

Definition at line 713 of file DestinationImpl.java.

References org.objectweb.joram.mom.dest.DestinationImpl.getId(), and fr.dyade.aaa.agent.AgentId.toString().

Here is the call graph for this function:

boolean org.objectweb.joram.mom.dest.DestinationImpl.isFreeReading (  ) 

Tests if this destination is free for reading.

Returns:
true if anyone can receive messages from this destination; false otherwise.

Implements org.objectweb.joram.mom.dest.DestinationImplMBean.

Definition at line 723 of file DestinationImpl.java.

References org.objectweb.joram.mom.dest.DestinationImpl.freeReading.

void org.objectweb.joram.mom.dest.DestinationImpl.setFreeReading ( boolean  on  ) 

Sets the FreeReading attribute for this destination.

Parameters:
on if true anyone can receive message from this destination.

Implements org.objectweb.joram.mom.dest.DestinationImplMBean.

Definition at line 732 of file DestinationImpl.java.

References org.objectweb.joram.mom.dest.DestinationImpl.freeReading, and org.objectweb.joram.mom.dest.DestinationImpl.setSave().

Here is the call graph for this function:

boolean org.objectweb.joram.mom.dest.DestinationImpl.isFreeWriting (  ) 

Tests if this destination is free for writing.

Returns:
true if anyone can send messages to this destination; false otherwise.

Implements org.objectweb.joram.mom.dest.DestinationImplMBean.

Definition at line 744 of file DestinationImpl.java.

References org.objectweb.joram.mom.dest.DestinationImpl.freeWriting.

void org.objectweb.joram.mom.dest.DestinationImpl.setFreeWriting ( boolean  on  ) 

Sets the FreeWriting attribute for this destination.

Parameters:
on if true anyone can send message to this destination.

Implements org.objectweb.joram.mom.dest.DestinationImplMBean.

Definition at line 753 of file DestinationImpl.java.

References org.objectweb.joram.mom.dest.DestinationImpl.freeWriting, and org.objectweb.joram.mom.dest.DestinationImpl.setSave().

Referenced by org.objectweb.joram.mom.dest.DeadMQueue.createsImpl().

Here is the call graph for this function:

String org.objectweb.joram.mom.dest.DestinationImpl.getDMQId (  ) 

Return the unique identifier of DMQ set for this destination if any.

Returns:
the unique identifier of DMQ set for this destination if any; null otherwise.

Implements org.objectweb.joram.mom.dest.DestinationImplMBean.

Definition at line 765 of file DestinationImpl.java.

References org.objectweb.joram.mom.dest.DestinationImpl.dmqId, and fr.dyade.aaa.agent.AgentId.toString().

Here is the call graph for this function:

long org.objectweb.joram.mom.dest.DestinationImpl.getCreationTimeInMillis (  ) 

Returns this destination creation time as a long.

Returns:
the destination creation time as UTC milliseconds from the epoch.

Implements