|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.exolab.jms.administration.mipc.IpcJmsAdminConnection
public class IpcJmsAdminConnection
This class is repsonsible for opening a TCP connection to the server and passing and packing all requests for delivery.
Constructor Summary | |
---|---|
protected |
IpcJmsAdminConnection(java.lang.String host,
int port)
Construct a new IpcJmsAdminConnection ,
without establishing a connection |
|
IpcJmsAdminConnection(java.lang.String host,
int port,
java.lang.String username,
java.lang.String password)
Construct a new IpcJmsAdminConnection ,
establishing a connection to the server |
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 durable consumer for the specified name |
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 |
void |
close()
Close the connection. |
protected void |
connect(java.lang.String username,
java.lang.String password)
Opens an authenticated connection to the server |
protected org.exolab.core.mipc.MultiplexConnectionIfc |
createClientConnection(java.lang.String host,
int port)
Create an MIPC client connection |
boolean |
destinationExists(java.lang.String name)
Determine if the specified destination exists |
boolean |
durableConsumerExists(java.lang.String name)
Check if the specified durable consumer exists |
java.util.Vector |
getAllDestinations()
Return a list of all registered destinations. |
java.util.Vector |
getAllUsers()
Return a list of all registered users. |
protected org.exolab.core.ipc.IpcIfc |
getConnection()
Returns the underlying connection |
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. |
protected java.lang.String |
getHost()
Returns the server host |
protected int |
getPort()
Returns the server port |
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 |
protected void |
openConnection()
Opens a connection to the server. |
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 specified durable consumer |
boolean |
removeUser(java.lang.String username)
Remove the specified user |
protected void |
setConnection(org.exolab.core.ipc.IpcIfc connection)
Sets the underlying connection |
void |
stopServer()
Terminate the JMS Server. |
boolean |
unregisterConsumer(java.lang.String name)
De-activate an active persistent consumer. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
protected IpcJmsAdminConnection(java.lang.String host, int port)
IpcJmsAdminConnection
,
without establishing a connection
host
- the server hostport
- the server portpublic IpcJmsAdminConnection(java.lang.String host, int port, java.lang.String username, java.lang.String password) throws javax.jms.JMSException
IpcJmsAdminConnection
,
establishing a connection to the server
host
- the server hostport
- the server portusername
- the admin user namepassword
- the admin password
JMSEXception
- if a connection cannot be established
javax.jms.JMSException
Method Detail |
---|
public boolean addDurableConsumer(java.lang.String topic, java.lang.String name) throws javax.jms.JMSException
AdminConnection
addDurableConsumer
in interface AdminConnection
addDurableConsumer
in interface JmsAdminServerIfc
topic
- name of the destinationname
- name of the consumer
javax.jms.JMSException
public boolean removeDurableConsumer(java.lang.String name) throws javax.jms.JMSException
AdminConnection
removeDurableConsumer
in interface AdminConnection
removeDurableConsumer
in interface JmsAdminServerIfc
name
- name of the consumer
javax.jms.JMSException
public java.util.Vector getDurableConsumers(java.lang.String topic) throws javax.jms.JMSException
AdminConnection
getDurableConsumers
in interface AdminConnection
getDurableConsumers
in interface JmsAdminServerIfc
topic
- the destination name
javax.jms.JMSException
- on errorpublic boolean durableConsumerExists(java.lang.String name) throws javax.jms.JMSException
AdminConnection
durableConsumerExists
in interface AdminConnection
durableConsumerExists
in interface JmsAdminServerIfc
name
- durable consumer to query
javax.jms.JMSException
public boolean isConnected(java.lang.String name) throws javax.jms.JMSException
isConnected
in interface AdminConnection
isConnected
in interface JmsAdminServerIfc
name
- the name of the onsumer.
true
if the consumer is connected
javax.jms.JMSException
public boolean unregisterConsumer(java.lang.String name) throws javax.jms.JMSException
AdminConnection
unregisterConsumer
in interface AdminConnection
unregisterConsumer
in interface JmsAdminServerIfc
name
- name of the consumer
javax.jms.JMSException
public boolean addDestination(java.lang.String destination, java.lang.Boolean queue) throws javax.jms.JMSException
AdminConnection
addDestination
in interface AdminConnection
addDestination
in interface JmsAdminServerIfc
queue
- whether it is queue or a topic
javax.jms.JMSException
public boolean removeDestination(java.lang.String name) throws javax.jms.JMSException
AdminConnection
removeDestination
in interface AdminConnection
removeDestination
in interface JmsAdminServerIfc
javax.jms.JMSException
public boolean destinationExists(java.lang.String name) throws javax.jms.JMSException
AdminConnection
destinationExists
in interface AdminConnection
destinationExists
in interface JmsAdminServerIfc
name
- - the destination to check
javax.jms.JMSException
public java.util.Vector getAllDestinations() throws javax.jms.JMSException
AdminConnection
getAllDestinations
in interface AdminConnection
getAllDestinations
in interface JmsAdminServerIfc
javax.jms.JMSException
- on errorpublic int getDurableConsumerMessageCount(java.lang.String topic, java.lang.String name) throws javax.jms.JMSException
AdminConnection
getDurableConsumerMessageCount
in interface AdminConnection
getDurableConsumerMessageCount
in interface JmsAdminServerIfc
topic
- name of the topicname
- durable consumer name
javax.jms.JMSException
- on errorpublic int getQueueMessageCount(java.lang.String queue) throws javax.jms.JMSException
AdminConnection
getQueueMessageCount
in interface AdminConnection
getQueueMessageCount
in interface JmsAdminServerIfc
queue
- the queue name
javax.jms.JMSException
- on errorpublic int purgeMessages() throws javax.jms.JMSException
AdminConnection
purgeMessages
in interface AdminConnection
purgeMessages
in interface JmsAdminServerIfc
javax.jms.JMSException
public void stopServer() throws javax.jms.JMSException
AdminConnection
stopServer
in interface AdminConnection
stopServer
in interface JmsAdminServerIfc
javax.jms.JMSException
public void close()
JmsAdminServerIfc
close
in interface JmsAdminServerIfc
public boolean addUser(java.lang.String username, java.lang.String password) throws javax.jms.JMSException
AdminConnection
addUser
in interface AdminConnection
addUser
in interface JmsAdminServerIfc
username
- the users namepassword
- the users password
true
if the user is added
otherwise false
javax.jms.JMSException
public java.util.Vector getAllUsers() throws javax.jms.JMSException
AdminConnection
getAllUsers
in interface AdminConnection
getAllUsers
in interface JmsAdminServerIfc
javax.jms.JMSException
- on errorpublic boolean removeUser(java.lang.String username) throws javax.jms.JMSException
AdminConnection
removeUser
in interface AdminConnection
removeUser
in interface JmsAdminServerIfc
username
- the users name
true
if the user is removed otherwise
false
javax.jms.JMSException
public boolean changePassword(java.lang.String username, java.lang.String password) throws javax.jms.JMSException
AdminConnection
changePassword
in interface AdminConnection
changePassword
in interface JmsAdminServerIfc
username
- the users namepassword
- the users password
true
if the password is changed
otherwise false
javax.jms.JMSException
protected java.lang.String getHost()
protected int getPort()
protected org.exolab.core.ipc.IpcIfc getConnection()
protected void setConnection(org.exolab.core.ipc.IpcIfc connection)
connection
- the underlying connectionprotected void openConnection() throws javax.jms.JMSException
javax.jms.JMSException
- if an error occursprotected void connect(java.lang.String username, java.lang.String password) throws javax.jms.JMSException
username
- the user's namepassword
- the user's password
javax.jms.JMSException
- if the connection cannot be establishedprotected org.exolab.core.mipc.MultiplexConnectionIfc createClientConnection(java.lang.String host, int port) throws java.io.IOException
host
- the host of the serverport
- the port number to use
java.io.IOException
- if the server fails to initialise the ip service
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |