org.objectweb.joram.mom.dest.AdminTopicImpl

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

Inherits org.objectweb.joram.mom.dest.TopicImpl, and org.objectweb.joram.mom.dest.AdminTopicImplMBean.

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

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

Collaboration graph
[legend]
List of all members.

Public Member Functions

 AdminTopicImpl (AgentId topicId)
String toString ()
AgentId getProxyId (String name, String pass, String inaddr) throws Exception
String getName (AgentId proxyId)
String getPassword (AgentId proxyId)
boolean isTaken (String name)
void AdminNotification (AgentId from, AdminNotification adminNot)
void AdminRequestNot (AgentId from, AdminRequestNot adminNot)
void AdminReply (AgentId from, org.objectweb.joram.mom.notifications.AdminReply not)
void GetProxyIdNot (GetProxyIdNot not)
void GetProxyIdListNot (GetProxyIdListNot not)
void RegisterTmpDestNot (RegisterTmpDestNot not)
void RegisterDestNot (RegisterDestNot not)
void RegisteredDestNot (AgentId from, RegisteredDestNot not)
void setRightRequest (AgentId from, SetRightRequest request) throws AccessException
void setDMQRequest (AgentId from, SetDMQRequest request) throws AccessException
void requestGroupNot (AgentId from, RequestGroupNot not)
SetRightRequest preProcess (SetRightRequest req)
void postProcess (SetRightRequest req)
ClientMessages preProcess (AgentId from, ClientMessages msgs)
void deleteNot (AgentId from, DeleteNot not)
void clusterRequest (AgentId from, ClusterRequest request) throws AccessException
void clusterTest (AgentId from, ClusterTest request)
void clusterAck (AgentId from, ClusterAck ack)
void clusterNot (AgentId from, ClusterNot not)
void unclusterRequest (AgentId from, UnclusterRequest request) throws MomException
void setFatherRequest (AgentId from, SetFatherRequest request) throws MomException
void fatherTest (AgentId from, FatherTest not)
void fatherAck (AgentId from, FatherAck ack)
void unsetFatherRequest (AgentId from, UnsetFatherRequest request) throws MomException
void topicForwardNot (AgentId from, TopicForwardNot not)
DestinationDesc createDestination (String destName, AgentId adminId, Properties properties, String type, String className, String requestClassName, StringBuffer strbuf) throws UnknownServerException, RequestException
void doProcess (CreateUserRequest request, AgentId replyTo, String msgId) throws UnknownServerException, RequestException
void doProcess (SetRight request, AgentId replyTo, String msgId) throws UnknownServerException

Static Public Member Functions

static DestinationDesc createDestinationAndSave (String destName, AgentId adminId, Properties properties, String type, String className, String requestClassName, StringBuffer strbuf) throws UnknownServerException, RequestException, IOException
static boolean isDestinationTableContain (String destName)
static void CreateUserAndSave (CreateUserRequest request, AgentId replyTo, String msgId) throws UnknownServerException, RequestException, IOException
static void setRightAndSave (SetRight request, AgentId replyTo, String msgId) throws UnknownServerException, IOException

Protected Member Functions

void doUnknownAgent (UnknownAgent uA)

Detailed Description

The AdminTopicImpl class implements the admin topic behaviour, basically processing administration requests.

Definition at line 169 of file AdminTopicImpl.java.

Constructor & Destructor Documentation

org.objectweb.joram.mom.dest.AdminTopicImpl.AdminTopicImpl ( AgentId  topicId  ) 

Constructs an AdminTopicImpl instance.

Parameters:
topicId Identifier of the agent hosting the AdminTopicImpl.

Definition at line 218 of file AdminTopicImpl.java.

Member Function Documentation

String org.objectweb.joram.mom.dest.AdminTopicImpl.toString (  ) 

Returns a string representation of this destination.

Reimplemented from org.objectweb.joram.mom.dest.TopicImpl.

Definition at line 227 of file AdminTopicImpl.java.

AgentId org.objectweb.joram.mom.dest.AdminTopicImpl.getProxyId ( String  name,
String  pass,
String  inaddr 
) throws Exception

Method used by ConnectionManager proxies to check their clients identification.

Parameters:
name 
pass 
inaddr 
Exceptions:
Exception If the user does not exist, is wrongly identified, or does not have any proxy deployed.
See also:
org.objectweb.joram.mom.proxies.ConnectionManager

Definition at line 243 of file AdminTopicImpl.java.

Referenced by org.objectweb.joram.mom.dest.AdminTopicImpl.GetProxyIdNot().

String org.objectweb.joram.mom.dest.AdminTopicImpl.getName ( AgentId  proxyId  ) 

Method used by proxies for retrieving their name.

Definition at line 264 of file AdminTopicImpl.java.

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

Here is the call graph for this function:

String org.objectweb.joram.mom.dest.AdminTopicImpl.getPassword ( AgentId  proxyId  ) 

Method used by proxies for retrieving their password.

Definition at line 275 of file AdminTopicImpl.java.

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

Here is the call graph for this function:

boolean org.objectweb.joram.mom.dest.AdminTopicImpl.isTaken ( String  name  ) 

Method used by proxies for checking if a given name is already used.

Definition at line 286 of file AdminTopicImpl.java.

void org.objectweb.joram.mom.dest.AdminTopicImpl.AdminNotification ( AgentId  from,
AdminNotification  adminNot 
)

Method implementing the reaction to a org.objectweb.joram.mom.proxies.AdminNotification notification notifying of the creation of an admin proxy.

Definition at line 295 of file AdminTopicImpl.java.

References org.objectweb.joram.mom.dest.DestinationImpl.clients, org.objectweb.joram.mom.proxies.AdminNotification.getName(), org.objectweb.joram.mom.proxies.AdminNotification.getPass(), org.objectweb.joram.mom.proxies.AdminNotification.getProxyId(), and org.objectweb.joram.mom.dest.DestinationImpl.READWRITE.

Here is the call graph for this function:

void org.objectweb.joram.mom.dest.AdminTopicImpl.AdminRequestNot ( AgentId  from,
AdminRequestNot  adminNot 
)

Method implementing the reaction to a AdminRequest notification notifying of the creation of an admin proxy.

Definition at line 313 of file AdminTopicImpl.java.

Referenced by org.objectweb.joram.mom.dest.AdminTopicImpl.doProcess().

void org.objectweb.joram.mom.dest.AdminTopicImpl.AdminReply ( AgentId  from,
org.objectweb.joram.mom.notifications.AdminReply  not 
)

Method implementing the reaction to a org.objectweb.joram.mom.notifications.AdminReply notification replying to an administration request.

A reply is sent back to the connected administrator if needed.

Definition at line 325 of file AdminTopicImpl.java.

References org.objectweb.joram.mom.notifications.AdminReply.getInfo(), org.objectweb.joram.mom.notifications.AdminReply.getReplyObject(), and org.objectweb.joram.mom.notifications.AdminReply.getSuccess().

Referenced by org.objectweb.joram.mom.dest.AdminTopicImpl.doUnknownAgent().

Here is the call graph for this function:

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

Overrides this DestinationImpl method; AdminTopics do not accept SetRightRequest notifications.

Exceptions:
AccessException Not thrown.

Reimplemented from org.objectweb.joram.mom.dest.DestinationImpl.

Definition at line 512 of file AdminTopicImpl.java.

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

Overrides this DestinationImpl method; AdminTopics do not accept SetDMQRequest notifications.

Exceptions:
AccessException Not thrown.

Reimplemented from org.objectweb.joram.mom.dest.DestinationImpl.

Definition at line 524 of file AdminTopicImpl.java.

ClientMessages org.objectweb.joram.mom.dest.AdminTopicImpl.preProcess ( AgentId  from,
ClientMessages  msgs 
)

Overrides this DestinationImpl method; ClientMessages notifications hold requests sent by an administrator.

Reimplemented from org.objectweb.joram.mom.dest.DestinationImpl.

Definition at line 557 of file AdminTopicImpl.java.

References org.objectweb.joram.mom.dest.DestinationImpl.forward(), org.objectweb.joram.mom.notifications.ClientMessages.getAsyncSend(), org.objectweb.joram.mom.notifications.AbstractNotification.getClientContext(), org.objectweb.joram.mom.notifications.AbstractNotification.getPersistent(), and org.objectweb.joram.mom.notifications.AbstractRequest.getRequestId().

Here is the call graph for this function:

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

Overrides this DestinationImpl method; deletion requests are not accepted by AdminTopics.

Reimplemented from org.objectweb.joram.mom.dest.DestinationImpl.

Definition at line 580 of file AdminTopicImpl.java.

void org.objectweb.joram.mom.dest.AdminTopicImpl.clusterRequest ( AgentId  from,
ClusterRequest  request 
) throws AccessException

Overrides this TopicImpl method; AdminTopics do not accept ClusterRequest notifications.

Exceptions:
AccessException Not thrown.

Reimplemented from org.objectweb.joram.mom.dest.TopicImpl.

Definition at line 592 of file AdminTopicImpl.java.

void org.objectweb.joram.mom.dest.AdminTopicImpl.clusterTest ( AgentId  from,
ClusterTest  request 
)

Overrides this TopicImpl method; AdminTopics do not accept to join clusters other than their admin topics cluster.

Reimplemented from org.objectweb.joram.mom.dest.TopicImpl.

Definition at line 602 of file AdminTopicImpl.java.

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

Here is the call graph for this function:

void org.objectweb.joram.mom.dest.AdminTopicImpl.clusterAck ( AgentId  from,
ClusterAck  ack 
)

Overrides this TopicImpl method; a ClusterAck is not expected by an AdminTopic.

Reimplemented from org.objectweb.joram.mom.dest.TopicImpl.

Definition at line 611 of file AdminTopicImpl.java.

void org.objectweb.joram.mom.dest.AdminTopicImpl.clusterNot ( AgentId  from,
ClusterNot  not 
)

Overrides this TopicImpl method; if this AdminTopic is on server0, new cluster fellow is notified to other fellows and other fellows are notified to it.

Reimplemented from org.objectweb.joram.mom.dest.TopicImpl.

Definition at line 622 of file AdminTopicImpl.java.

void org.objectweb.joram.mom.dest.AdminTopicImpl.unclusterRequest ( AgentId  from,
UnclusterRequest  request 
) throws MomException

Overrides this TopicImpl method; AdminTopics do not accept UnclusterRequest notifications.

Exceptions:
AccessException Not thrown.

Reimplemented from org.objectweb.joram.mom.dest.TopicImpl.

Definition at line 634 of file AdminTopicImpl.java.

void org.objectweb.joram.mom.dest.AdminTopicImpl.setFatherRequest ( AgentId  from,
SetFatherRequest  request 
) throws MomException

Overrides this TopicImpl method; AdminTopics do not accept SetFatherRequest notifications.

Exceptions:
AccessException Not thrown.

Reimplemented from org.objectweb.joram.mom.dest.TopicImpl.

Definition at line 646 of file AdminTopicImpl.java.

void org.objectweb.joram.mom.dest.AdminTopicImpl.fatherTest ( AgentId  from,
FatherTest  not 
)

Overrides this TopicImpl method; AdminTopics do not accept to join a hierarchy.

Reimplemented from org.objectweb.joram.mom.dest.TopicImpl.

Definition at line 657 of file AdminTopicImpl.java.

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

Here is the call graph for this function:

void org.objectweb.joram.mom.dest.AdminTopicImpl.fatherAck ( AgentId  from,
FatherAck  ack 
)

Overrides this TopicImpl method; a FatherAck acknowledges the process of creating a hierarchy of topics.

Reimplemented from org.objectweb.joram.mom.dest.TopicImpl.

Definition at line 668 of file AdminTopicImpl.java.

void org.objectweb.joram.mom.dest.AdminTopicImpl.unsetFatherRequest ( AgentId  from,
UnsetFatherRequest  request 
) throws MomException

Overrides this TopicImpl method; AdminTopics do not accept UnsetFatherRequest notifications.

Exceptions:
AccessException Not thrown.

Reimplemented from org.objectweb.joram.mom.dest.TopicImpl.

Definition at line 680 of file AdminTopicImpl.java.

void org.objectweb.joram.mom.dest.AdminTopicImpl.topicForwardNot ( AgentId  from,
TopicForwardNot  not 
)

Overrides this TopicImpl method; the forwarded messages contain admin requests and will be processed.

Reimplemented from org.objectweb.joram.mom.dest.TopicImpl.

Definition at line 691 of file AdminTopicImpl.java.

References org.objectweb.joram.mom.dest.TopicForwardNot.messages.

void org.objectweb.joram.mom.dest.AdminTopicImpl.doUnknownAgent ( UnknownAgent  uA  )  [protected, virtual]

Specializes this TopicImpl reaction.

Reimplemented from org.objectweb.joram.mom.dest.TopicImpl.

Definition at line 698 of file AdminTopicImpl.java.

References org.objectweb.joram.mom.dest.AdminTopicImpl.AdminReply(), fr.dyade.aaa.agent.UnknownAgent.agent, fr.dyade.aaa.agent.UnknownAgent.not, and org.objectweb.joram.mom.dest.DestinationImpl.strbuf.

Here is the call graph for this function:

DestinationDesc org.objectweb.joram.mom.dest.AdminTopicImpl.createDestination ( String  destName,
AgentId  adminId,
Properties  properties,
String  type,
String  className,
String  requestClassName,
StringBuffer  strbuf 
) throws UnknownServerException, RequestException

Instanciating the destination class or retrieving the destination.

Parameters:
destName destination Name
adminId other admin (null for TopicAdmin)
properties destination properties
type destination type ("queue" or "topic")
className creates an instance of the class
requestClassName 
strbuf information
Returns:
DestinationDesc contain destination description
Exceptions:
UnknownServerException 
RequestException 

Definition at line 991 of file AdminTopicImpl.java.

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

Referenced by org.objectweb.joram.mom.dest.AdminTopicImpl.createDestinationAndSave().

Here is the call graph for this function:

static DestinationDesc org.objectweb.joram.mom.dest.AdminTopicImpl.createDestinationAndSave ( String  destName,
AgentId  adminId,
Properties  properties,
String  type,
String  className,
String  requestClassName,
StringBuffer  strbuf 
) throws UnknownServerException, RequestException, IOException [static]

Instanciating the destination class or retrieving the destination and save Agent AdminTopic. (used by ScalAgent mediation)

Parameters:
destName destination Name
adminId other admin (null for TopicAdmin)
properties destination properties
type destination type ("queue" or "topic")
className creates an instance of the class
requestClassName 
strbuf information
Returns:
DestinationDesc contain destination description
Exceptions:
UnknownServerException 
RequestException 
IOException transaction exception.

Definition at line 1088 of file AdminTopicImpl.java.

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

Here is the call graph for this function:

static boolean org.objectweb.joram.mom.dest.AdminTopicImpl.isDestinationTableContain ( String  destName  )  [static]

is destinationTable contain destName ? (used by ScalAgent mediation)

Parameters:
destName destination name.
Returns:
true if contain.

Definition at line 1118 of file AdminTopicImpl.java.

References org.objectweb.joram.mom.dest.AdminTopicImpl.destinationsTable.

void org.objectweb.joram.mom.dest.AdminTopicImpl.doProcess ( CreateUserRequest  request,
AgentId  replyTo,
String  msgId 
) throws UnknownServerException, RequestException

Processes a CreateUserRequest instance requesting the creation of a UserAgent for a given user.

Exceptions:
UnknownServerException If the target server does not exist.
RequestException If the user already exists but with a different password, or if the proxy deployment failed.

Definition at line 1260 of file AdminTopicImpl.java.

References org.objectweb.joram.mom.dest.AdminTopicImpl.AdminRequestNot(), fr.dyade.aaa.agent.Agent.deploy(), org.objectweb.joram.mom.dest.DestinationImpl.forward(), fr.dyade.aaa.agent.Agent.getId(), fr.dyade.aaa.agent.Agent.name, org.objectweb.joram.mom.dest.DestinationImpl.strbuf, and fr.dyade.aaa.agent.AgentId.toString().

Here is the call graph for this function:

static void org.objectweb.joram.mom.dest.AdminTopicImpl.CreateUserAndSave ( CreateUserRequest  request,
AgentId  replyTo,
String  msgId 
) throws UnknownServerException, RequestException, IOException [static]

Processes a CreateUserRequest instance requesting the creation of a UserAgent for a given user and save Agent AdminTopic. (used by ScalAgent mediation)

Exceptions:
UnknownServerException If the target server does not exist.
RequestException If the user already exists but with a different password, or if the proxy deployment failed.
IOException transaction exception

Definition at line 1333 of file AdminTopicImpl.java.

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

Here is the call graph for this function:

void org.objectweb.joram.mom.dest.AdminTopicImpl.doProcess ( SetRight  request,
AgentId  replyTo,
String  msgId 
) throws UnknownServerException

Processes a SetRight instance requesting to grant a user a given right on a given destination.

Definition at line 1446 of file AdminTopicImpl.java.

References org.objectweb.joram.mom.dest.AdminTopicImpl.AdminRequestNot(), org.objectweb.joram.mom.dest.DestinationImpl.forward(), fr.dyade.aaa.agent.AgentId.fromString(), fr.dyade.aaa.agent.AgentId.getTo(), org.objectweb.joram.mom.dest.DestinationImpl.READ, and org.objectweb.joram.mom.dest.DestinationImpl.WRITE.

Here is the call graph for this function:

static void org.objectweb.joram.mom.dest.AdminTopicImpl.setRightAndSave ( SetRight  request,
AgentId  replyTo,
String  msgId 
) throws UnknownServerException, IOException [static]

Processes a SetRight instance requesting to grant a user a given right on a given destination. And save Agent TopicAdmin. (used by ScalAgent mediation)

Parameters:
request 
replyTo 
msgId 
Exceptions:
UnknownServerException 
IOException 

Definition at line 1488 of file AdminTopicImpl.java.

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

Here is the call graph for this function:

The documentation for this class was generated from the following file:
Generated on Tue Sep 16 16:19:27 2008 for joram by  doxygen 1.5.0