|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.joram.mom.dest.DestinationImpl
org.objectweb.joram.mom.dest.TopicImpl
org.objectweb.joram.mom.dest.AdminTopicImpl
public final class AdminTopicImpl
The AdminTopicImpl
class implements the administration topic behavior,
basically processing administration requests.
It receives administration requests from the client encapsulated in JMS messages:
Nested Class Summary | |
---|---|
static class |
AdminTopicImpl.DestinationDesc
|
Field Summary | |
---|---|
private java.util.Map |
destinationsTable
Table holding the local server's destinations names. |
private long |
msgCounter
Counter of messages produced by this AdminTopic. |
private java.util.Map |
proxiesTable
Table holding the TCP users proxies identifiers. |
private static AdminTopicImpl |
ref
Reference of the server's local AdminTopicImpl instance. |
private java.util.Map |
requestsTable
Table keeping the administrator's requests. |
private static long |
serialVersionUID
define serialVersionUID for interoperability |
private int |
serverId
Identifier of the server this topic is deployed on. |
private java.util.Map |
usersTable
Table holding the TCP users identifications. |
Fields inherited from class org.objectweb.joram.mom.dest.TopicImpl |
---|
alreadySentLocally, fatherId, friends, selectors, subscribers |
Fields inherited from class org.objectweb.joram.mom.dest.DestinationImpl |
---|
_rights, agent, clients, creationDate, dmqId, freeReading, freeWriting, logger, nbMsgsDeliverSinceCreation, nbMsgsReceiveSinceCreation, nbMsgsSentToDMQSinceCreation, READ, READWRITE, strbuf, WAKEUP_PERIOD, WRITE |
Constructor Summary | |
---|---|
AdminTopicImpl(AgentId topicId)
Constructs an AdminTopicImpl instance. |
Method Summary | |
---|---|
void |
AdminNotification(AdminNotification adminNot)
Method implementing the reaction to a AdminNotification
notification notifying of the creation of an administrator proxy. |
void |
AdminReply(AdminReplyNot not)
Method implementing the reaction to a org.objectweb.joram.mom.notifications.AdminReply
notification replying to an administration request. |
private void |
broadcastRequest(AdminRequest request,
int avoidServerId,
AgentId replyTo,
java.lang.String msgId)
Sends the administration request to AdminTopic of all servers except the given one. |
private boolean |
checkServerId(int serverId)
Returns true if a given server identification corresponds
to the local server's. |
void |
clusterAck(AgentId from,
ClusterAck ack)
Overrides this TopicImpl method; a ClusterAck
is not expected by an AdminTopic. |
void |
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. |
void |
clusterTest(AgentId from,
ClusterTest request)
Overrides this TopicImpl method; AdminTopics do not
accept to join clusters other than their admin topics cluster. |
AdminTopicImpl.DestinationDesc |
createDestination(java.lang.String destName,
AgentId adminId,
java.util.Properties properties,
byte type,
java.lang.String className,
java.lang.String requestClassName,
java.lang.StringBuffer strbuf)
Instantiating the destination class or retrieving the destination. |
private java.lang.String |
createMessageId()
|
void |
createQueue(java.lang.String name)
Creates a new queue on the local server. |
void |
createQueue(java.lang.String name,
int serverId)
Creates a new queue on the selected server. |
void |
createQueue(java.lang.String name,
java.lang.String queueClassName,
int serverId)
Creates a new queue on the selected server. |
void |
createTopic(java.lang.String name)
Creates a new topic on the local server. |
void |
createTopic(java.lang.String name,
int serverId)
Creates a new topic on the selected server. |
void |
createTopic(java.lang.String name,
java.lang.String topicClassName,
int serverId)
Creates a new topic on the selected server. |
void |
createUser(java.lang.String user,
java.lang.String passwd)
Creates a new user on the local server. |
void |
createUser(java.lang.String user,
java.lang.String passwd,
int serverId)
Creates a new user on the selected server. |
void |
createUser(java.lang.String user,
java.lang.String passwd,
int serverId,
java.lang.String identityClassName)
Creates a new user on the selected server. |
void |
deleteNot(AgentId from,
DeleteNot not)
Overrides this DestinationImpl method. |
static void |
deleteUser(java.lang.String userName)
|
private void |
distributeReply(AgentId to,
java.lang.String msgId,
AdminReply reply)
Actually sends an AdminReply object to an identified
destination. |
private void |
doProcess(AddDomainRequest request,
AgentId replyTo,
java.lang.String msgId,
AgentId from)
Adds a new domain to the configuration. |
private void |
doProcess(AddServerRequest request,
AgentId replyTo,
java.lang.String msgId,
AgentId from)
Adds a server to the configuration. |
private void |
doProcess(AgentId replyTo,
java.lang.String msgId)
|
private void |
doProcess(CreateDestinationRequest request,
AgentId replyTo,
java.lang.String msgId)
Processes a CreateDestinationRequest instance
requesting the creation of a destination. |
private void |
doProcess(CreateUserRequest request,
AgentId replyTo,
java.lang.String msgId)
Processes a CreateUserRequest instance requesting the
creation of a UserAgent for a given user. |
private void |
doProcess(DeleteDestination request,
AgentId replyTo,
java.lang.String msgId)
Processes a DeleteDestination instance requesting the
deletion of a destination. |
private void |
doProcess(DeleteUser request,
AgentId replyTo,
java.lang.String msgId)
Processes a DeleteUser instance requesting the deletion
of a user. |
private void |
doProcess(GetClusterRequest request,
AgentId replyTo,
java.lang.String msgId)
Processes a Monitor_GetCluster request by forwarding it to
its target topic, if local. |
private void |
doProcess(GetConfigRequest request,
AgentId replyTo,
java.lang.String msgId)
Gets the current configuration. |
private void |
doProcess(GetDestinationsRequest request,
AgentId replyTo,
java.lang.String msgId)
Processes a Monitor_GetDestinations request by sending
registered destinations. |
private void |
doProcess(GetDMQSettingsRequest request,
AgentId replyTo,
java.lang.String msgId)
Processes a Monitor_GetDMQSettings request either by
processing it and sending back the default DMQ settings, or by
forwarding it to its target destination or proxy. |
private void |
doProcess(GetDomainNames request,
AgentId replyTo,
java.lang.String msgId)
|
private void |
doProcess(GetFatherRequest request,
AgentId replyTo,
java.lang.String msgId)
Processes a Monitor_GetFather request by forwarding it to
its target topic, if local. |
private void |
doProcess(GetNbMaxMsgRequest request,
AgentId replyTo,
java.lang.String msgId)
Processes an Monitor_GetNbMaxMsg request requesting
to get the maximum number of messages. |
private void |
doProcess(GetPendingMessages request,
AgentId replyTo,
java.lang.String msgId)
Processes a Monitor_GetPendingMessages request by
forwarding it to its target queue, if local. |
private void |
doProcess(GetPendingRequests request,
AgentId replyTo,
java.lang.String msgId)
Processes a Monitor_GetPendingRequests request by
forwarding it to its target queue, if local. |
private AdminReply |
doProcess(GetRightsReplyNot not)
Processes a Monit_GetUsersRep notification holding a
destination's readers' or writers' identifiers. |
private void |
doProcess(GetRightsRequest request,
AgentId replyTo,
java.lang.String msgId)
Processes a GetRightsRequest request by forwarding it
to its target destination, if local. |
private void |
doProcess(GetServersIdsRequest request,
AgentId replyTo,
java.lang.String msgId)
Processes a Monitor_GetServersIds request by sending
the list of the platform servers' ids. |
private void |
doProcess(GetStatsRequest request,
AgentId replyTo,
java.lang.String msgId)
Processes a Monitor_GetStat request by
forwarding it to its target destination, if local. |
private void |
doProcess(GetSubscriberIds request,
AgentId replyTo,
java.lang.String requestMsgId)
|
private void |
doProcess(GetSubscriptionsRequest request,
AgentId replyTo,
java.lang.String msgId)
Processes a Monitor_GetSubscriptions request by
forwarding it to its target queue, if local. |
private void |
doProcess(GetUsersRequest request,
AgentId replyTo,
java.lang.String msgId)
Processes a Monitor_GetUsers request by sending the
users table. |
private void |
doProcess(QueueAdminRequest request,
AgentId replyTo,
java.lang.String requestMsgId)
|
private void |
doProcess(RemoveDomainRequest request,
AgentId replyTo,
java.lang.String msgId,
AgentId from)
Removes a domain in the configuration. |
private void |
doProcess(RemoveServerRequest request,
AgentId replyTo,
java.lang.String msgId,
AgentId from)
Removes a server in the configuration. |
private void |
doProcess(SetCluster request,
AgentId replyTo,
java.lang.String msgId)
Processes a SetCluster |
private void |
doProcess(SetDMQRequest request,
AgentId replyTo,
java.lang.String msgId)
Processes a SetDMQ request requesting a given queue to be set as
the DMQ of a given destination or user. |
private void |
doProcess(SetFather request,
AgentId replyTo,
java.lang.String msgId)
Processes a SetFather |
private void |
doProcess(SetNbMaxMsgRequest request,
AgentId replyTo,
java.lang.String msgId)
Processes a SetNbMaxMsg request requesting
a given nbMaxMsg value to be set in queue or subscription. |
void |
doProcess(SetRight request,
AgentId replyTo,
java.lang.String msgId)
Processes a SetRight instance requesting to grant a user
a given right on a given destination. |
private void |
doProcess(SetThresholdRequest request,
AgentId replyTo,
java.lang.String msgId)
Processes a SetThreshold request requesting a given threshold value to be set
as the threshold of a given destination or user. |
private void |
doProcess(SpecialAdmin request,
AgentId replyTo,
java.lang.String msgId)
|
private void |
doProcess(StopServerRequest request,
AgentId replyTo,
java.lang.String msgId)
Processes a StopServerRequest instance requesting to stop
a given server. |
private void |
doProcess(UpdateUser request,
AgentId replyTo,
java.lang.String msgId)
Processes an UpdateUser instance requesting to modify the
identification of a user. |
private void |
doProcess(UserAdminRequest request,
AgentId replyTo,
java.lang.String requestMsgId)
Handle administration request about user. |
protected void |
doUnknownAgent(UnknownAgent uA)
Specializes this TopicImpl reaction. |
java.lang.String |
getName(AgentId proxyId)
Method used by proxies for retrieving their name. |
java.lang.Object |
getPassword(AgentId proxyId)
Method used by proxies for retrieving their password. |
AgentId |
getProxyId(Identity identity,
java.lang.String inaddr)
Method used by ConnectionManager proxies to check their
clients identification. |
void |
GetProxyIdListNot(GetProxyIdListNot not)
|
void |
GetProxyIdNot(GetProxyIdNot not)
|
protected void |
handleDeniedMessage(java.lang.String msgId,
AgentId replyTo)
Method used to send a response when a message is denied because of a lack of rights. |
boolean |
isTaken(java.lang.String name)
Method used by proxies for checking if a given name is already used. |
static AdminTopicImpl.DestinationDesc |
lookupDest(java.lang.String name,
byte type)
Retrieves an existing destination. |
ClientMessages |
preProcess(AgentId from,
ClientMessages msgs)
Overrides this DestinationImpl method;
ClientMessages notifications hold requests sent by an
administrator. |
(package private) void |
processAdminRequests(AgentId replyTo,
java.lang.String msgId,
AdminRequest request,
AgentId from)
Method getting the administration requests from messages, and distributing them to the appropriate reactions. |
private void |
processAdminRequests(ClientMessages not)
Method getting the administration requests from messages, and distributing them to the appropriate reactions. |
private void |
readObject(java.io.ObjectInputStream in)
Deserializes an AdminTopicImpl instance. |
static void |
registerDest(AgentId id,
java.lang.String name,
byte type)
Registers a newly created destination. |
void |
requestGroupNot(AgentId from,
RequestGroupNot not)
|
void |
topicForwardNot(AgentId from,
TopicForwardNot not)
Overrides this TopicImpl method; the forwarded messages
contain admin requests and will be processed. |
java.lang.String |
toString()
Returns a string representation of this destination. |
static void |
unregisterDest(java.lang.String name)
Removes a registered destination. |
private void |
writeObject(java.io.ObjectOutputStream out)
Serializes an AdminTopicImpl instance. |
Methods inherited from class org.objectweb.joram.mom.dest.TopicImpl |
---|
doClientMessages, doDeleteNot, doRightRequest, forwardMessages, getNbMsgsReceiveSinceCreation, getNumberOfSubscribers, getSubscriberIds, handleAdminRequestNot, initialize, postSubscribe, postUnsubscribe, preSubscribe, preUnsubscribe, processMessages, setAlreadySentLocally, subscribeRequest, topicForwardNot, unsubscribeRequest, wakeUpNot |
Methods inherited from class org.objectweb.joram.mom.dest.DestinationImpl |
---|
canBeDeleted, clientMessages, delete, forward, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQAgentId, getDMQId, getId, getJMXStatistics, getName, getNbMsgsDeliverSinceCreation, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, getRights, isAdministrator, isFreeReading, isFreeWriting, isLocal, isReader, isValidJMXAttribute, isWriter, postProcess, processSetRight, replyToTopic, setAgent, setFreeReading, setFreeWriting, setNoSave, setPeriod, setRight, setSave, specialAdminProcess, specialAdminRequest, unknownAgent |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.objectweb.joram.mom.dest.TopicImplMBean |
---|
getNumberOfSubscribers, getSubscriberIds |
Methods inherited from interface org.objectweb.joram.mom.dest.DestinationImplMBean |
---|
delete, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQId, getName, getNbMsgsDeliverSinceCreation, getNbMsgsReceiveSinceCreation, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, isFreeReading, isFreeWriting, setFreeReading, setFreeWriting, setPeriod |
Field Detail |
---|
private static final long serialVersionUID
private static AdminTopicImpl ref
private int serverId
private java.util.Map destinationsTable
Key: destination name
Object: destination agent identifier
private java.util.Map usersTable
Key: user name
Object: user password
private java.util.Map proxiesTable
Key: user name
Object: proxy's identifier
private java.util.Map requestsTable
Key: request's message identifier
Value: request's message ReplyTo field
private long msgCounter
Constructor Detail |
---|
public AdminTopicImpl(AgentId topicId)
AdminTopicImpl
instance.
topicId
- Identifier of the agent hosting the AdminTopicImpl.Method Detail |
---|
public java.lang.String toString()
TopicImpl
toString
in interface DestinationImplMBean
toString
in class TopicImpl
public AgentId getProxyId(Identity identity, java.lang.String inaddr) throws java.lang.Exception
ConnectionManager
proxies to check their
clients identification.
identity
- inaddr
-
java.lang.Exception
- If the user does not exist, is wrongly identified,
or does not have any proxy deployed.ConnectionManager
public java.lang.String getName(AgentId proxyId)
public java.lang.Object getPassword(AgentId proxyId)
public boolean isTaken(java.lang.String name)
protected void handleDeniedMessage(java.lang.String msgId, AgentId replyTo)
handleDeniedMessage
in class DestinationImpl
public void AdminNotification(AdminNotification adminNot)
AdminNotification
notification notifying of the creation of an administrator proxy.
adminNot
- the AdminNotification
notification.public void AdminReply(AdminReplyNot not)
org.objectweb.joram.mom.notifications.AdminReply
notification replying to an administration request.
A reply is sent back to the connected administrator if needed.
public void GetProxyIdNot(GetProxyIdNot not)
public void GetProxyIdListNot(GetProxyIdListNot not)
private AdminReply doProcess(GetRightsReplyNot not)
Monit_GetUsersRep
notification holding a
destination's readers' or writers' identifiers.
public void requestGroupNot(AgentId from, RequestGroupNot not)
requestGroupNot
in class DestinationImpl
public ClientMessages preProcess(AgentId from, ClientMessages msgs)
DestinationImpl
method;
ClientMessages
notifications hold requests sent by an
administrator.
preProcess
in class DestinationImpl
from
- The sender of the messagemsgs
- The incoming messages.
public void clusterTest(AgentId from, ClusterTest request)
TopicImpl
method; AdminTopics do not
accept to join clusters other than their admin topics cluster.
clusterTest
in class TopicImpl
public void clusterAck(AgentId from, ClusterAck ack)
TopicImpl
method; a ClusterAck
is not expected by an AdminTopic.
clusterAck
in class TopicImpl
public void clusterNot(AgentId from, ClusterNot not)
TopicImpl
method; if this AdminTopic is on
server0, new cluster fellow is notified to other fellows and other
fellows are notified to it.
clusterNot
in class TopicImpl
public void topicForwardNot(AgentId from, TopicForwardNot not)
TopicImpl
method; the forwarded messages
contain admin requests and will be processed.
public void deleteNot(AgentId from, DeleteNot not)
DestinationImpl
method.
Deletion requests are not accepted by AdminTopics.
deleteNot
in class DestinationImpl
protected void doUnknownAgent(UnknownAgent uA)
TopicImpl
reaction.
doUnknownAgent
in class TopicImpl
private void processAdminRequests(ClientMessages not)
void processAdminRequests(AgentId replyTo, java.lang.String msgId, AdminRequest request, AgentId from)
private void doProcess(StopServerRequest request, AgentId replyTo, java.lang.String msgId) throws UnknownServerException
StopServerRequest
instance requesting to stop
a given server.
UnknownServerException
private void doProcess(CreateDestinationRequest request, AgentId replyTo, java.lang.String msgId) throws UnknownServerException, RequestException
CreateDestinationRequest
instance
requesting the creation of a destination.
UnknownServerException
- If the target server does not exist.
RequestException
- If the destination deployment fails.public AdminTopicImpl.DestinationDesc createDestination(java.lang.String destName, AgentId adminId, java.util.Properties properties, byte type, java.lang.String className, java.lang.String requestClassName, java.lang.StringBuffer strbuf) throws UnknownServerException, RequestException
destName
- destination NameadminId
- other admin (null for TopicAdmin)properties
- destination propertiestype
- destination type ("queue" or "topic")className
- creates an instance of the classrequestClassName
- strbuf
- information
UnknownServerException
RequestException
private void doProcess(DeleteDestination request, AgentId replyTo, java.lang.String msgId) throws UnknownServerException
DeleteDestination
instance requesting the
deletion of a destination.
UnknownServerException
private void doProcess(GetClusterRequest request, AgentId replyTo, java.lang.String msgId)
Monitor_GetCluster
request by forwarding it to
its target topic, if local.
private void doProcess(SetCluster request, AgentId replyTo, java.lang.String msgId)
SetCluster instance requesting to link two topics
in a cluster relationship.
private void doProcess(GetFatherRequest request, AgentId replyTo, java.lang.String msgId)
Monitor_GetFather
request by forwarding it to
its target topic, if local.
private void doProcess(SetFather request, AgentId replyTo, java.lang.String msgId)
SetFather instance requesting to link two topics
in a hierarchical relationship.
private void doProcess(CreateUserRequest request, AgentId replyTo, java.lang.String msgId) throws UnknownServerException, RequestException
CreateUserRequest
instance requesting the
creation of a UserAgent
for a given user.
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.private void doProcess(UpdateUser request, AgentId replyTo, java.lang.String msgId) throws RequestException, UnknownServerException
UpdateUser
instance requesting to modify the
identification of a user.
RequestException
- If the user does not exist, or if it's new
name is already used.
UnknownServerException
private void doProcess(DeleteUser request, AgentId replyTo, java.lang.String msgId) throws UnknownServerException
DeleteUser
instance requesting the deletion
of a user.
UnknownServerException
public void doProcess(SetRight request, AgentId replyTo, java.lang.String msgId)
SetRight
instance requesting to grant a user
a given right on a given destination.
private void doProcess(SetDMQRequest request, AgentId replyTo, java.lang.String msgId) throws UnknownServerException
SetDMQ
request requesting a given queue to be set as
the DMQ of a given destination or user.
If the AgentId of the destination is NullId set the default DMQ.
If the AgentId of the DMQ is NullId unset the DMQ.
UnknownServerException
- If the target server does not exist.private void doProcess(SetThresholdRequest request, AgentId replyTo, java.lang.String msgId) throws UnknownServerException
SetThreshold
request requesting a given threshold value to be set
as the threshold of a given destination or user.
If the AgentId of the destination is NullId set the default threshold.
If the threshold value is less than 0 reset the threshold.
UnknownServerException
- If the target server does not exist.private void doProcess(SetNbMaxMsgRequest request, AgentId replyTo, java.lang.String msgId)
SetNbMaxMsg
request requesting
a given nbMaxMsg value to be set in queue or subscription.
private void doProcess(GetServersIdsRequest request, AgentId replyTo, java.lang.String msgId) throws UnknownServerException
Monitor_GetServersIds
request by sending
the list of the platform servers' ids.
UnknownServerException
- If the target server does not exist.private void doProcess(AgentId replyTo, java.lang.String msgId)
private void doProcess(GetDomainNames request, AgentId replyTo, java.lang.String msgId)
private void doProcess(GetDestinationsRequest request, AgentId replyTo, java.lang.String msgId) throws UnknownServerException
Monitor_GetDestinations
request by sending
registered destinations.
UnknownServerException
- If the target server does not exist.private void doProcess(GetUsersRequest request, AgentId replyTo, java.lang.String msgId) throws UnknownServerException
Monitor_GetUsers
request by sending the
users table.
UnknownServerException
- If the target server does not exist.private void doProcess(GetRightsRequest request, AgentId replyTo, java.lang.String msgId) throws UnknownServerException
GetRightsRequest
request by forwarding it
to its target destination, if local.
UnknownServerException
private void doProcess(GetDMQSettingsRequest request, AgentId replyTo, java.lang.String msgId) throws UnknownServerException
Monitor_GetDMQSettings
request either by
processing it and sending back the default DMQ settings, or by
forwarding it to its target destination or proxy.
UnknownServerException
- If the target server does not exist.private void doProcess(GetPendingMessages request, AgentId replyTo, java.lang.String msgId)
Monitor_GetPendingMessages
request by
forwarding it to its target queue, if local.
private void doProcess(GetPendingRequests request, AgentId replyTo, java.lang.String msgId)
Monitor_GetPendingRequests
request by
forwarding it to its target queue, if local.
private void doProcess(GetStatsRequest request, AgentId replyTo, java.lang.String msgId)
Monitor_GetStat
request by
forwarding it to its target destination, if local.
private void doProcess(GetNbMaxMsgRequest request, AgentId replyTo, java.lang.String msgId)
Monitor_GetNbMaxMsg
request requesting
to get the maximum number of messages.
private void doProcess(GetSubscriptionsRequest request, AgentId replyTo, java.lang.String msgId)
Monitor_GetSubscriptions
request by
forwarding it to its target queue, if local.
private void doProcess(SpecialAdmin request, AgentId replyTo, java.lang.String msgId) throws UnknownServerException
UnknownServerException
private void doProcess(AddDomainRequest request, AgentId replyTo, java.lang.String msgId, AgentId from)
request
- The request describing the domain to create.replyTo
- The destination to reply.msgId
- The JMS message id needed to reply.from
- The AgentId
of sender.private void doProcess(RemoveDomainRequest request, AgentId replyTo, java.lang.String msgId, AgentId from)
request
- The request describing the domain to remove.replyTo
- The destination to reply.msgId
- The JMS message id needed to reply.from
- The AgentId
of sender.private void doProcess(AddServerRequest request, AgentId replyTo, java.lang.String msgId, AgentId from)
request
- The request describing the server to create.replyTo
- The destination to reply.msgId
- The JMS message id needed to reply.from
- The AgentId
of sender.private void doProcess(RemoveServerRequest request, AgentId replyTo, java.lang.String msgId, AgentId from)
request
- The request describing the server to remove.replyTo
- The destination to reply.msgId
- The JMS message id needed to reply.from
- The AgentId
of sender.private void broadcastRequest(AdminRequest request, int avoidServerId, AgentId replyTo, java.lang.String msgId)
request
- The administration request.avoidServerId
- The id. of the server to avoid.replyTo
- The destination to reply.msgId
- The JMS message id needed to reply.private void doProcess(GetConfigRequest request, AgentId replyTo, java.lang.String msgId)
request
- replyTo
- msgId
- private void distributeReply(AgentId to, java.lang.String msgId, AdminReply reply)
AdminReply
object to an identified
destination.
to
- Identifier of a destination to send the reply to.msgId
- Identifier of the original request.reply
- The AdminReply
instance to send.private java.lang.String createMessageId()
private void doProcess(UserAdminRequest request, AgentId replyTo, java.lang.String requestMsgId) throws UnknownServerException
request
- replyTo
- requestMsgId
-
UnknownServerException
private void doProcess(GetSubscriberIds request, AgentId replyTo, java.lang.String requestMsgId)
private void doProcess(QueueAdminRequest request, AgentId replyTo, java.lang.String requestMsgId)
private boolean checkServerId(int serverId) throws UnknownServerException
true
if a given server identification corresponds
to the local server's.
serverId
- Server identifier.
UnknownServerException
- If the server does not exist.private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException
AdminTopicImpl
instance.
java.io.IOException
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException
AdminTopicImpl
instance.
java.io.IOException
java.lang.ClassNotFoundException
public void createUser(java.lang.String user, java.lang.String passwd) throws java.lang.Exception
SimpleIdentity
class is
used.
createUser
in interface AdminTopicImplMBean
user
- the user namepasswd
- the user password
java.lang.Exception
public void createUser(java.lang.String user, java.lang.String passwd, int serverId) throws java.lang.Exception
SimpleIdentity
class is
used.
createUser
in interface AdminTopicImplMBean
user
- the user namepasswd
- the user passwordserverId
- the server where the user will be created
java.lang.Exception
public void createUser(java.lang.String user, java.lang.String passwd, int serverId, java.lang.String identityClassName) throws java.lang.Exception
createUser
in interface AdminTopicImplMBean
user
- the user namepasswd
- the user passwordserverId
- the server where the user will be createdidentityClassName
- the identity class name to instantiate
java.lang.Exception
public void createQueue(java.lang.String name)
createQueue
in interface AdminTopicImplMBean
name
- the queue namepublic void createQueue(java.lang.String name, int serverId)
Queue
.
createQueue
in interface AdminTopicImplMBean
name
- the topic nameserverId
- the server where the queue will be deployedpublic void createQueue(java.lang.String name, java.lang.String queueClassName, int serverId)
createQueue
in interface AdminTopicImplMBean
name
- the topic namequeueClassName
- the queue class to instantiateserverId
- the server where the queue will be deployedpublic void createTopic(java.lang.String name)
createTopic
in interface AdminTopicImplMBean
name
- the topic namepublic void createTopic(java.lang.String name, int serverId)
Topic
.
createTopic
in interface AdminTopicImplMBean
name
- the topic nameserverId
- the server where the topic will be deployedpublic void createTopic(java.lang.String name, java.lang.String topicClassName, int serverId)
createTopic
in interface AdminTopicImplMBean
name
- the topic nametopicClassName
- the topic class to instantiateserverId
- the server where the topic will be deployedpublic static void deleteUser(java.lang.String userName)
public static AdminTopicImpl.DestinationDesc lookupDest(java.lang.String name, byte type) throws RequestException
name
- The name of the destination.type
- The type of the destination.
RequestException
- If the existing destination have a different type.public static void registerDest(AgentId id, java.lang.String name, byte type)
id
- The unique identifier of the created destination.name
- The name of the created destination.type
- The type of the created destination.
java.io.IOException
- If an error occurs during saving.public static void unregisterDest(java.lang.String name)
name
- The name of the destination to remove.
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |