|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.exolab.jms.net.orb.UnicastObject
org.exolab.jms.server.net.JmsAdminConnectionImpl
public class JmsAdminConnectionImpl
This class implements the RemoteJmsAdminServerIfc and simply delegates all the request to the JmsAdmin singleton instance.
Remote
Field Summary | |
---|---|
protected AdminConnection |
_connection
The connection to delegate calls to |
Constructor Summary | |
---|---|
protected |
JmsAdminConnectionImpl(AdminConnection connection,
org.exolab.jms.net.orb.ORB orb)
Construct a new JmsAdminConnectionImpl |
Method Summary | |
---|---|
boolean |
addDestination(java.lang.String destination,
java.lang.Boolean queue)
Add a specific destination with the specified name |
boolean |
addDurableConsumer(java.lang.String topic,
java.lang.String name)
Add a consumer for the specified topic |
boolean |
addUser(java.lang.String username,
java.lang.String password)
Add a user with the specified name |
boolean |
changePassword(java.lang.String username,
java.lang.String password)
Change password for the specified user |
boolean |
destinationExists(java.lang.String name)
Determine whether the destination with the specified name exists |
boolean |
durableConsumerExists(java.lang.String name)
Check if a durable consumer, with the specified name, already exists |
java.util.Vector |
getAllDestinations()
Return a list of all registered destinations. |
java.util.Vector |
getAllUsers()
Return a list of all registered users. |
int |
getDurableConsumerMessageCount(java.lang.String topic,
java.lang.String name)
Return the number of outstanding messages for a particular destination. |
java.util.Vector |
getDurableConsumers(java.lang.String topic)
Return the collection of durable consumer names for a particular topic destination. |
int |
getQueueMessageCount(java.lang.String queue)
Return the number of outstanding messages for a particular queue. |
boolean |
isConnected(java.lang.String name)
Check to see if the given consumer is currently connected to the OpenJMSServer. |
int |
purgeMessages()
Purge all processed messages from the database |
boolean |
removeDestination(java.lang.String name)
Destroy the specified destination and all associated messsages and consumers. |
boolean |
removeDurableConsumer(java.lang.String name)
Remove the consumer attached to the specified destination and with the passed in name |
boolean |
removeUser(java.lang.String username)
Remove the specified user |
void |
stopServer()
Terminate the JMS Server. |
boolean |
unregisterConsumer(java.lang.String name)
Deactivate an active persistent consumer. |
Methods inherited from class org.exolab.jms.net.orb.UnicastObject |
---|
getORB, getProxy, getURI, unexportObject |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected AdminConnection _connection
Constructor Detail |
---|
protected JmsAdminConnectionImpl(AdminConnection connection, org.exolab.jms.net.orb.ORB orb) throws java.rmi.RemoteException
JmsAdminConnectionImpl
connection
- the connection to calls delegate toorb
- the ORB to export this with
java.rmi.RemoteException
- if this can't be exportedMethod Detail |
---|
public boolean addDurableConsumer(java.lang.String topic, java.lang.String name) throws java.rmi.RemoteException
RemoteJmsAdminConnectionIfc
addDurableConsumer
in interface RemoteJmsAdminConnectionIfc
topic
- name of the destinationname
- name of the consumer
java.rmi.RemoteException
- if the connection cannot be createdpublic boolean removeDurableConsumer(java.lang.String name) throws java.rmi.RemoteException
RemoteJmsAdminConnectionIfc
removeDurableConsumer
in interface RemoteJmsAdminConnectionIfc
name
- name of the consumer
java.rmi.RemoteException
- if the connection cannot be createdpublic boolean durableConsumerExists(java.lang.String name) throws java.rmi.RemoteException
RemoteJmsAdminConnectionIfc
durableConsumerExists
in interface RemoteJmsAdminConnectionIfc
name
- name of the consumer
java.rmi.RemoteException
- if the connection cannot be createdpublic boolean unregisterConsumer(java.lang.String name) throws java.rmi.RemoteException
RemoteJmsAdminConnectionIfc
unregisterConsumer
in interface RemoteJmsAdminConnectionIfc
name
- name of the consumer
java.rmi.RemoteException
- if the consumer cannot be unregisteredpublic boolean isConnected(java.lang.String name) throws java.rmi.RemoteException
RemoteJmsAdminConnectionIfc
isConnected
in interface RemoteJmsAdminConnectionIfc
name
- The name of the onsumer.
java.rmi.RemoteException
- if the connection cannot be createdpublic java.util.Vector getAllDestinations() throws java.rmi.RemoteException
RemoteJmsAdminConnectionIfc
getAllDestinations
in interface RemoteJmsAdminConnectionIfc
java.rmi.RemoteException
- if the connection cannot be createdpublic boolean addDestination(java.lang.String destination, java.lang.Boolean queue) throws java.rmi.RemoteException
RemoteJmsAdminConnectionIfc
addDestination
in interface RemoteJmsAdminConnectionIfc
destination
- destination namequeue
- whether it is queue or a topic
java.rmi.RemoteException
- if the connection cannot be createdpublic int getDurableConsumerMessageCount(java.lang.String topic, java.lang.String name) throws java.rmi.RemoteException
RemoteJmsAdminConnectionIfc
getDurableConsumerMessageCount
in interface RemoteJmsAdminConnectionIfc
topic
- name of the topicname
- durable consumer name
java.rmi.RemoteException
- if the connection cannot be createdpublic int getQueueMessageCount(java.lang.String queue) throws java.rmi.RemoteException
RemoteJmsAdminConnectionIfc
getQueueMessageCount
in interface RemoteJmsAdminConnectionIfc
queue
- the queue name
java.rmi.RemoteException
- if the connection cannot be createdpublic java.util.Vector getDurableConsumers(java.lang.String topic) throws java.rmi.RemoteException
RemoteJmsAdminConnectionIfc
getDurableConsumers
in interface RemoteJmsAdminConnectionIfc
topic
- the destination name
java.rmi.RemoteException
- if the connection cannot be createdpublic boolean removeDestination(java.lang.String name) throws java.rmi.RemoteException
RemoteJmsAdminConnectionIfc
removeDestination
in interface RemoteJmsAdminConnectionIfc
name
- destination to destroy
java.rmi.RemoteException
- if the connection cannot be createdpublic boolean destinationExists(java.lang.String name) throws java.rmi.RemoteException
RemoteJmsAdminConnectionIfc
destinationExists
in interface RemoteJmsAdminConnectionIfc
name
- - the destination to check
java.rmi.RemoteException
- if the connection cannot be createdpublic int purgeMessages() throws java.rmi.RemoteException
RemoteJmsAdminConnectionIfc
purgeMessages
in interface RemoteJmsAdminConnectionIfc
java.rmi.RemoteException
- if the connection cannot be createdpublic void stopServer() throws java.rmi.RemoteException
RemoteJmsAdminConnectionIfc
stopServer
in interface RemoteJmsAdminConnectionIfc
java.rmi.RemoteException
- if the connection cannot be createdpublic boolean addUser(java.lang.String username, java.lang.String password) throws java.rmi.RemoteException
RemoteJmsAdminConnectionIfc
addUser
in interface RemoteJmsAdminConnectionIfc
username
- the users namepassword
- the users password
true
if the user is added
otherwise false
java.rmi.RemoteException
- if the connection cannot be createdpublic boolean changePassword(java.lang.String username, java.lang.String password) throws java.rmi.RemoteException
RemoteJmsAdminConnectionIfc
changePassword
in interface RemoteJmsAdminConnectionIfc
username
- the users namepassword
- the users password
true
if the password is changed
otherwise false
java.rmi.RemoteException
- if the connection cannot be createdpublic boolean removeUser(java.lang.String username) throws java.rmi.RemoteException
RemoteJmsAdminConnectionIfc
removeUser
in interface RemoteJmsAdminConnectionIfc
username
- the users name
true
if the user is removed
otherwise false
java.rmi.RemoteException
- if the connection cannot be createdpublic java.util.Vector getAllUsers() throws java.rmi.RemoteException
RemoteJmsAdminConnectionIfc
getAllUsers
in interface RemoteJmsAdminConnectionIfc
java.rmi.RemoteException
- if the connection cannot be created
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |