public final class AdminTopic extends Topic implements AdminTopicMBean
AdminTopic
class implements the administration topic
behavior, basically processing administration requests.
It receives administration requests from the client encapsulated in JMS messages:
Modifier and Type | Class and Description |
---|---|
static class |
AdminTopic.DestinationDesc |
Modifier and Type | Field and Description |
---|---|
(package private) static AgentId |
adminId |
private Map |
destinationsTable
Table holding the local server's destinations names.
|
private long |
msgCounter
Counter of messages produced by this AdminTopic.
|
private Map |
proxiesTable
Table holding the TCP users proxies identifiers.
|
private static AdminTopic |
ref
Reference of the server's local AdminTopic instance.
|
private 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 Map |
usersTable
Table holding the TCP users identifications.
|
alreadySentLocally, fatherId, friends, logger, nbMsgsReceiveSinceCreation, selectors, subscribers
_rights, clients, creationDate, dmqId, freeReading, freeWriting, nbMsgsDeliverSinceCreation, nbMsgsSentToDMQSinceCreation, READ, READWRITE, strbuf, task, WAKEUP_PERIOD, WRITE
agentProfiling, emptyString, fixed, logmon
BOOLEAN_ENCODED_SIZE, BYTE_ENCODED_SIZE, DOUBLE_ENCODED_SIZE, FLOAT_ENCODED_SIZE, INT_ENCODED_SIZE, LONG_ENCODED_SIZE, SHORT_ENCODED_SIZE
Constructor and Description |
---|
AdminTopic()
Constructs an
AdminTopic agent. |
Modifier and Type | Method and Description |
---|---|
private void |
broadcastRequest(AdminRequest request,
int avoidServerId,
AgentId replyTo,
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. |
protected void |
clusterJoin(ClusterJoinNot not)
Overrides this
Topic method; if this AdminTopic is on
server0, new cluster fellow is notified to other fellows and other
fellows are notified to it. |
protected void |
clusterJoinAck(ClusterJoinAck ack)
Overrides this
Topic method; a ClusterAck is not
expected by an AdminTopic. |
private AdminTopic.DestinationDesc |
createDestination(String destName,
AgentId adminId,
Properties properties,
byte type,
String className,
String requestClassName,
StringBuffer strbuf)
Instantiating the destination class or retrieving the destination.
|
static AdminTopic.DestinationDesc |
createDestinationAndSave(String destName,
AgentId adminId,
Properties properties,
byte type,
String className,
String requestClassName,
StringBuffer strbuf)
Deprecated.
|
private String |
createMessageId() |
void |
createQueue(String name)
Creates a new queue on the local server.
|
void |
createQueue(String name,
int serverId)
Creates a new queue on the selected server.
|
void |
createQueue(String name,
String queueClassName,
int serverId)
Creates a new queue on the selected server.
|
void |
createTopic(String name)
Creates a new topic on the local server.
|
void |
createTopic(String name,
int serverId)
Creates a new topic on the selected server.
|
void |
createTopic(String name,
String topicClassName,
int serverId)
Creates a new topic on the selected server.
|
void |
createUser(String user,
String passwd)
Creates a new user on the local server.
|
void |
createUser(String user,
String passwd,
int serverId)
Creates a new user on the selected server.
|
void |
createUser(String user,
String passwd,
int serverId,
String identityClassName)
Creates a new user on the selected server.
|
static void |
CreateUserAndSave(CreateUserRequest request,
AgentId replyTo,
String msgId)
Deprecated.
|
void |
deleteNot(AgentId from,
DeleteNot not)
Overrides this
Destination method. |
static void |
deleteUser(String userName) |
private void |
distributeReply(AgentId to,
String msgId,
AdminReply reply)
Actually sends an
AdminReply object to an identified
destination. |
private void |
doProcess(AddDomainRequest request,
AgentId replyTo,
String msgId,
AgentId from)
Adds a new domain to the configuration.
|
private void |
doProcess(AddServerRequest request,
AgentId replyTo,
String msgId,
AgentId from)
Adds a server to the configuration.
|
private void |
doProcess(AdminCommandRequest request,
AgentId replyTo,
String requestMsgId)
Process an admin command.
|
private void |
doProcess(AgentId replyTo,
String msgId) |
private void |
doProcess(CreateDestinationRequest request,
AgentId replyTo,
String msgId)
Processes a
CreateDestinationRequest instance
requesting the creation of a destination. |
private void |
doProcess(CreateUserRequest request,
AgentId replyTo,
String msgId)
Processes a
CreateUserRequest instance requesting the
creation of a UserAgent for a given user. |
private void |
doProcess(DeleteDestination request,
AgentId replyTo,
String msgId)
Processes a
DeleteDestination instance requesting the
deletion of a destination. |
private void |
doProcess(DeleteUser request,
AgentId replyTo,
String msgId)
Processes a
DeleteUser instance requesting the deletion
of a user. |
private void |
doProcess(DestinationAdminRequest request,
AgentId replyTo,
String msgId)
Processes a
DestinationRequest request by
forwarding it to its target destination, if local. |
private void |
doProcess(GetConfigRequest request,
AgentId replyTo,
String msgId)
Gets the current configuration.
|
private void |
doProcess(GetDestinationsRequest request,
AgentId replyTo,
String msgId)
Processes a
Monitor_GetDestinations request by sending
registered destinations. |
private void |
doProcess(GetDMQSettingsRequest request,
AgentId replyTo,
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,
String msgId) |
private void |
doProcess(GetJMXAttsRequest request,
AgentId replyTo,
String msgId)
Processes a
Monitor_GetJMXAtts request or forwards it to its target
destination if needed. |
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,
String msgId)
Processes a
GetRightsRequest request by forwarding it
to its target destination, if local. |
private void |
doProcess(GetServersIdsRequest request,
AgentId replyTo,
String msgId)
Processes a
Monitor_GetServersIds request by sending
the list of the platform servers' ids. |
private void |
doProcess(GetStatsRequest request,
AgentId replyTo,
String msgId)
Processes a
Monitor_GetStat request or forwards it to its target
destination if needed. |
private void |
doProcess(GetUsersRequest request,
AgentId replyTo,
String msgId)
Processes a
Monitor_GetUsers request by sending the
users table. |
private void |
doProcess(RemoveDomainRequest request,
AgentId replyTo,
String msgId,
AgentId from)
Removes a domain in the configuration.
|
private void |
doProcess(RemoveServerRequest request,
AgentId replyTo,
String msgId,
AgentId from)
Removes a server in the configuration.
|
private void |
doProcess(SetDMQRequest request,
AgentId replyTo,
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(SetThresholdRequest request,
AgentId replyTo,
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(StopServerRequest request,
AgentId replyTo,
String msgId)
Processes a
StopServerRequest instance requesting to stop
a given server. |
private void |
doProcess(UpdateUser request,
AgentId replyTo,
String msgId)
Processes an
UpdateUser instance requesting to modify the
identification of a user. |
private void |
doProcess(UserAdminRequest request,
AgentId replyTo,
String requestMsgId)
Handle administration request about user.
|
protected void |
doUnknownAgent(UnknownAgent uA)
Specializes this
Topic reaction. |
static AgentId |
getDefault()
Gets the identifier of the default administration topic on the
current server.
|
static AgentId |
getDefault(short serverId)
Gets the identifier of the default administration topic on a given server.
|
private AgentId |
getProxyId(Identity identity,
String inaddr)
Method used by
ConnectionManager proxies to check their
clients identification. |
private void |
handleAdminNotification(AdminNotification adminNot)
Method implementing the reaction to a
AdminNotification
notification notifying of the creation of an administrator proxy. |
private void |
handleAdminReply(AdminReplyNot not)
Method implementing the reaction to a
org.objectweb.joram.mom.notifications.AdminReply
notification replying to an administration request. |
protected void |
handleDeniedMessage(String msgId,
AgentId replyTo)
Method used to send a response when a message is denied because of a lack
of rights.
|
private void |
handleGetProxyIdListNot(GetProxyIdListNot not) |
private void |
handleGetProxyIdNot(GetProxyIdNot not) |
private static Object |
invokeStaticMethod(Properties prop)
Invokes a static method on the server using the specified properties.
|
static boolean |
isAdminTopicId(AgentId id)
Returns true if the given AgentId is the unique identifier of an AdminTopic
agent.
|
static boolean |
isDestinationTableContain(String destName)
Deprecated.
|
static AdminTopic.DestinationDesc |
lookupDest(String name,
byte type)
Retrieves an existing destination.
|
static AgentId |
lookupUser(String name)
Retrieves an existing user
|
protected ClientMessages |
preProcess(AgentId from,
ClientMessages msgs)
Overrides this
Destination method; |
private void |
processAdminRequests(AgentId replyTo,
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.
|
void |
react(AgentId from,
Notification not)
Distributes the received notifications to the appropriate reactions.
|
private void |
readObject(ObjectInputStream in)
Deserializes an
AdminTopic instance. |
static void |
registerDest(AgentId id,
String name,
byte type)
Registers a newly created destination.
|
protected void |
requestGroupNot(AgentId from,
RequestGroupNot not) |
static AdminTopic.DestinationDesc |
reverseLookupDest(String agentId,
byte type)
Retrieves an existing destination.
|
static void |
setRightAndSave(SetRight request,
AgentId replyTo,
String msgId)
Deprecated.
|
protected void |
topicForwardNot(AgentId from,
TopicForwardNot not)
Overrides this
Topic method; the forwarded messages
contain admin requests and will be processed. |
String |
toString()
Returns a string representation of this destination.
|
static void |
unregisterDest(String name)
Removes a registered destination.
|
private void |
writeObject(ObjectOutputStream out)
Serializes an
AdminTopic instance. |
createTopicForward, doClientMessages, doDeleteNot, doRightRequest, finalize, forwardMessages, forwardMessages, getClusterElements, getNbMsgsReceiveSinceCreation, getNumberOfSubscribers, getStats, getSubscriberIds, getTxName, getType, handleAdminRequestNot, initialize, postSubscribe, postUnsubscribe, preSubscribe, preUnsubscribe, processMessages, sendToCluster, setAlreadySentLocally, subscribeRequest, unsubscribeRequest, wakeUpNot
agentFinalize, agentInitialize, clientMessages, decode, delete, encode, forward, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQAgentId, getDMQId, getEncodedSize, getJMXStatistics, getMBeanName, getNbMsgsDeliverSinceCreation, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, getRights, interceptorsAvailable, isAdministrator, isFreeReading, isFreeWriting, isLocal, isReader, isValidJMXAttribute, isWriter, postProcess, processAdminCommand, processInterceptors, processSetRight, processStartHandler, processStopHandler, replyToTopic, setAdminId, setFreeReading, setFreeWriting, setPeriod, setProperties, setRight, unknownAgent
agentSave, delete, delete, deploy, deploy, getAgentId, getCommitTime, getEncodableClassId, getId, getLogTopic, getName, getReactNb, getReactTime, hasName, isAgentProfiling, isDeployed, isFixed, isUpdated, needToBeCommited, resetCommitTime, resetReactTime, resetTimer, save, sendTo, sendTo, sendTo, setAgentProfiling, setName, setNoSave, setSave
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getNumberOfSubscribers, getSubscriberIds
delete, getCreationDate, getCreationTimeInMillis, getDestinationId, getDMQId, getName, getNbMsgsDeliverSinceCreation, getNbMsgsReceiveSinceCreation, getNbMsgsSentToDMQSinceCreation, getPeriod, getRight, getRights, isFreeReading, isFreeWriting, setFreeReading, setFreeWriting, setPeriod
getAgentId, getCommitTime, getReactNb, getReactTime, isAgentProfiling, isFixed, resetCommitTime, resetReactTime, resetTimer, setAgentProfiling
getClusterElements
private static final long serialVersionUID
private static AdminTopic ref
private int serverId
private Map destinationsTable
Key: destination name
Object: destination agent identifier
private Map usersTable
Key: user name
Object: user password
private Map proxiesTable
Key: user name
Object: proxy's identifier
private Map requestsTable
Key: request's message identifier
Value: request's message ReplyTo field
private long msgCounter
static AgentId adminId
public AdminTopic() throws RequestException
AdminTopic
agent.RequestException
public String toString()
Topic
toString
in interface AgentMBean
toString
in interface DestinationMBean
toString
in class Topic
public static AgentId getDefault(short serverId)
public static final AgentId getDefault()
public static final boolean isAdminTopicId(AgentId id)
id
- the AgentId to verify.public void react(AgentId from, Notification not) throws Exception
private AgentId getProxyId(Identity identity, String inaddr) throws Exception
ConnectionManager
proxies to check their
clients identification.identity
- inaddr
- Exception
- If the user does not exist, is wrongly identified,
or does not have any proxy deployed.ConnectionManager
protected void handleDeniedMessage(String msgId, AgentId replyTo)
handleDeniedMessage
in class Destination
private void handleAdminNotification(AdminNotification adminNot)
AdminNotification
notification notifying of the creation of an administrator proxy.adminNot
- the AdminNotification
notification.private void handleAdminReply(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.
private void handleGetProxyIdNot(GetProxyIdNot not)
private void handleGetProxyIdListNot(GetProxyIdListNot not)
private AdminReply doProcess(GetRightsReplyNot not)
Monit_GetUsersRep
notification holding a
destination's readers' or writers' identifiers.protected void requestGroupNot(AgentId from, RequestGroupNot not)
requestGroupNot
in class Destination
protected ClientMessages preProcess(AgentId from, ClientMessages msgs)
Destination
method;preProcess
in class Destination
msgs
- ClientMessages
notifications hold requests sent by
an administrator.from
- The sender of the messageprotected void clusterJoinAck(ClusterJoinAck ack)
Topic
method; a ClusterAck
is not
expected by an AdminTopic.clusterJoinAck
in class Topic
protected void clusterJoin(ClusterJoinNot not)
Topic
method; if this AdminTopic is on
server0, new cluster fellow is notified to other fellows and other
fellows are notified to it.clusterJoin
in class Topic
protected void topicForwardNot(AgentId from, TopicForwardNot not)
Topic
method; the forwarded messages
contain admin requests and will be processed.topicForwardNot
in class Topic
public void deleteNot(AgentId from, DeleteNot not)
Destination
method.
Deletion requests are not accepted by AdminTopics.deleteNot
in class Destination
protected void doUnknownAgent(UnknownAgent uA)
Topic
reaction.doUnknownAgent
in class Topic
private void processAdminRequests(ClientMessages not)
private void processAdminRequests(AgentId replyTo, String msgId, AdminRequest request, AgentId from)
private void doProcess(StopServerRequest request, AgentId replyTo, String msgId) throws UnknownServerException
StopServerRequest
instance requesting to stop
a given server.UnknownServerException
private void doProcess(CreateDestinationRequest request, AgentId replyTo, 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.private AdminTopic.DestinationDesc createDestination(String destName, AgentId adminId, Properties properties, byte type, String className, String requestClassName, 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
- informationUnknownServerException
RequestException
private void doProcess(DeleteDestination request, AgentId replyTo, String msgId) throws UnknownServerException
DeleteDestination
instance requesting the
deletion of a destination.UnknownServerException
private void doProcess(CreateUserRequest request, AgentId replyTo, 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, 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, String msgId) throws UnknownServerException
DeleteUser
instance requesting the deletion
of a user.UnknownServerException
private void doProcess(SetDMQRequest request, AgentId replyTo, 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, 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(GetServersIdsRequest request, AgentId replyTo, 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(GetDomainNames request, AgentId replyTo, String msgId)
private void doProcess(GetDestinationsRequest request, AgentId replyTo, 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, 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, String msgId) throws UnknownServerException
GetRightsRequest
request by forwarding it
to its target destination, if local.UnknownServerException
private void doProcess(GetDMQSettingsRequest request, AgentId replyTo, 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(GetStatsRequest request, AgentId replyTo, String msgId)
Monitor_GetStat
request or forwards it to its target
destination if needed.private void doProcess(GetJMXAttsRequest request, AgentId replyTo, String msgId)
Monitor_GetJMXAtts
request or forwards it to its target
destination if needed.private void doProcess(DestinationAdminRequest request, AgentId replyTo, String msgId)
DestinationRequest
request by
forwarding it to its target destination, if local.private void doProcess(AddDomainRequest request, AgentId replyTo, 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, 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, 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, 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, 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, String msgId)
request
- replyTo
- msgId
- private void distributeReply(AgentId to, 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 String createMessageId()
private void doProcess(UserAdminRequest request, AgentId replyTo, String requestMsgId) throws UnknownServerException
request
- replyTo
- requestMsgId
- UnknownServerException
private void doProcess(AdminCommandRequest request, AgentId replyTo, String requestMsgId) throws UnknownServerException
request
- The administration request.replyTo
- The destination to reply.requestMsgId
- The JMS message id needed to reply.UnknownServerException
private static Object invokeStaticMethod(Properties prop) throws Exception
prop
- Exception
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(ObjectOutputStream out) throws IOException
AdminTopic
instance.IOException
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
AdminTopic
instance.IOException
ClassNotFoundException
public void createUser(String user, String passwd) throws Exception
SimpleIdentity
class is
used.createUser
in interface AdminTopicMBean
user
- the user namepasswd
- the user passwordException
public void createUser(String user, String passwd, int serverId) throws Exception
SimpleIdentity
class is
used.createUser
in interface AdminTopicMBean
user
- the user namepasswd
- the user passwordserverId
- the server where the user will be createdException
public void createUser(String user, String passwd, int serverId, String identityClassName) throws Exception
createUser
in interface AdminTopicMBean
user
- the user namepasswd
- the user passwordserverId
- the server where the user will be createdidentityClassName
- the identity class name to instantiateException
public void createQueue(String name)
createQueue
in interface AdminTopicMBean
name
- the queue namepublic void createQueue(String name, int serverId)
Queue
.createQueue
in interface AdminTopicMBean
name
- the topic nameserverId
- the server where the queue will be deployedpublic void createQueue(String name, String queueClassName, int serverId)
createQueue
in interface AdminTopicMBean
name
- the topic namequeueClassName
- the queue class to instantiateserverId
- the server where the queue will be deployedpublic void createTopic(String name)
createTopic
in interface AdminTopicMBean
name
- the topic namepublic void createTopic(String name, int serverId)
Topic
.createTopic
in interface AdminTopicMBean
name
- the topic nameserverId
- the server where the topic will be deployedpublic void createTopic(String name, String topicClassName, int serverId)
createTopic
in interface AdminTopicMBean
name
- the topic nametopicClassName
- the topic class to instantiateserverId
- the server where the topic will be deployedpublic static void deleteUser(String userName)
public static AdminTopic.DestinationDesc lookupDest(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 AgentId lookupUser(String name)
name
- The name of the userpublic static void registerDest(AgentId id, 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.IOException
- If an error occurs during saving.public static void unregisterDest(String name)
name
- The name of the destination to remove.public static void CreateUserAndSave(CreateUserRequest request, AgentId replyTo, String msgId) throws UnknownServerException, RequestException, IOException
CreateUserRequest
instance requesting the
creation of a UserAgent
for a given user and save Agent
AdminTopic. (used by ScalAgent mediation)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 exceptionpublic static AdminTopic.DestinationDesc createDestinationAndSave(String destName, AgentId adminId, Properties properties, byte type, String className, String requestClassName, StringBuffer strbuf) throws UnknownServerException, RequestException, IOException
destName
- destination NameadminId
- other admin (null for TopicAdmin)properties
- destination propertiestype
- destination type ("queue" or "topic")className
- creates an instance of the classrequestClassName
- strbuf
- informationUnknownServerException
RequestException
IOException
- transaction exception.public static void setRightAndSave(SetRight request, AgentId replyTo, String msgId) throws UnknownServerException, IOException
SetRight
instance requesting to grant a user
a given right on a given destination. And save Agent TopicAdmin.
(used by ScalAgent mediation)request
- replyTo
- msgId
- UnknownServerException
IOException
public static boolean isDestinationTableContain(String destName)
destName
- destination name.public static AdminTopic.DestinationDesc reverseLookupDest(String agentId, byte type)
agentId
- The identifier of the destination.type
- The type of the destination.Copyright © 2016 ScalAgent D.T.. All Rights Reserved.