| org.jboss.mq.il.Invoker
All known Subclasses: org.jboss.mq.server.JMSServerInvoker,
| Method Summary | |
| public void | acknowledge(ConnectionToken dc, AcknowledgementRequest item)
| | public void | addMessage(ConnectionToken dc, SpyMessage message)
Add the message to the destination. | | public String | authenticate(String userName, String password)
Check user for autentication. | | public SpyMessage[] | browse(ConnectionToken dc, Destination dest, String selector)
| | public void | checkID(String ID)
Check id, must not be taken. | | public String | checkUser(String userName, String password)
Check user for autentication. | | public void | connectionClosing(ConnectionToken dc)
Close connection. | | public Queue | createQueue(ConnectionToken dc, String dest)
Create a queue. | | public Topic | createTopic(ConnectionToken dc, String dest)
Create a topic. | | public void | deleteTemporaryDestination(ConnectionToken dc, SpyDestination dest)
| | public void | destroySubscription(ConnectionToken dc, DurableSubscriptionID id)
Unsubscribe from the durable subscription. | | public SpyTopic | getDurableTopic(DurableSubscriptionID sub)
Get the topic the durable subscription is on. | | public String | getID()
Gets a clientID from server. | | public Subscription | getSubscription(ConnectionToken dc, int subscriberId)
Get the subscription that match the id. | | public TemporaryQueue | getTemporaryQueue(ConnectionToken dc)
| | public TemporaryTopic | getTemporaryTopic(ConnectionToken dc)
Get a temporary topic. | | public ThreadGroup | getThreadGroup()
Get the thread group of the server. | | public void | ping(ConnectionToken dc, long clientTime)
Ping the server. | | public SpyMessage | receive(ConnectionToken dc, int subscriberId, long wait)
| | public void | setEnabled(ConnectionToken dc, boolean enabled)
| | void | subscribe(org.jboss.mq.ConnectionToken dc, org.jboss.mq.Subscription s)
| | public void | transact(ConnectionToken dc, TransactionRequest t)
| | public void | unsubscribe(ConnectionToken dc, int subscriptionId)
Close the server side message consumer. |
| acknowledge | | public void acknowledge(ConnectionToken dc, AcknowledgementRequest item) throws JMSException(Code) | | #Description of the Method
Parameters:
dc - Description of Parameter
Parameters:
item - Description of Parameter
exception:
JMSException - Description of Exception |
| addMessage | | public void addMessage(ConnectionToken dc, SpyMessage message) throws JMSException(Code) | | Add the message to the destination.
Parameters:
dc - The feature to be added to the Message attribute
Parameters:
message - The feature to be added to the Message attribute
exception:
JMSException - Description of Exception |
| authenticate | | public String authenticate(String userName, String password) throws JMSException(Code) | | Check user for autentication.
Parameters:
userName - Description of Parameter
Parameters:
password - Description of Parameter a sessionId.
exception:
JMSException - if user was not allowed to login |
| browse | | public SpyMessage[] browse(ConnectionToken dc, Destination dest, String selector) throws JMSException(Code) | | #Description of the Method
Parameters:
dc - Description of Parameter
Parameters:
dest - Description of Parameter
Parameters:
selector - Description of Parameter Description of the Returned Value
exception:
JMSException - Description of Exception |
| checkID | | public void checkID(String ID) throws JMSException(Code) | | Check id, must not be taken.
Parameters:
ID - Description of Parameter
exception:
JMSException - Description of Exception |
| checkUser | | public String checkUser(String userName, String password) throws JMSException(Code) | | Check user for autentication.
Parameters:
userName - Description of Parameter
Parameters:
password - Description of Parameter a preconfigured clientId.
exception:
JMSException - if user was not allowed to login |
| connectionClosing | | public void connectionClosing(ConnectionToken dc) throws JMSException(Code) | | Close connection.
Parameters:
dc - Description of Parameter
exception:
JMSException - Description of Exception |
| createQueue | | public Queue createQueue(ConnectionToken dc, String dest) throws JMSException(Code) | | Create a queue.
The destination name must be the name of an already existing
destination. This method should only be used to skip looking
up a destination through JNDI, not to actually create a new destination.
Parameters:
dc - Description of Parameter
Parameters:
dest - Description of Parameter Description of the Returned Value
exception:
JMSException - Description of Exception |
| createTopic | | public Topic createTopic(ConnectionToken dc, String dest) throws JMSException(Code) | | Create a topic.
The destination name must be the name of an already existing
destination. This method should only be used to skip looking
up a destination through JNDI, not to actually create a new destination.
Parameters:
dc - Description of Parameter
Parameters:
dest - Description of Parameter Description of the Returned Value
exception:
JMSException - Description of Exception |
| deleteTemporaryDestination | | public void deleteTemporaryDestination(ConnectionToken dc, SpyDestination dest) throws JMSException(Code) | | #Description of the Method
Parameters:
dc - Description of Parameter
Parameters:
dest - Description of Parameter
exception:
JMSException - Description of Exception |
| destroySubscription | | public void destroySubscription(ConnectionToken dc, DurableSubscriptionID id) throws JMSException(Code) | | Unsubscribe from the durable subscription.
Parameters:
id - Description of Parameter
exception:
JMSException - Description of Exception |
| getDurableTopic | | public SpyTopic getDurableTopic(DurableSubscriptionID sub) throws JMSException(Code) | | Get the topic the durable subscription is on.
Primary for internal use in the server, and not for the IL's.
|
| getID | | public String getID() throws JMSException(Code) | | Gets a clientID from server.
The ID value
exception:
JMSException - Description of Exception |
| getSubscription | | public Subscription getSubscription(ConnectionToken dc, int subscriberId) throws JMSException(Code) | | Get the subscription that match the id.
exception:
JMSException - if it can not find the subscription. |
| getTemporaryQueue | | public TemporaryQueue getTemporaryQueue(ConnectionToken dc) throws JMSException(Code) | | Get a temporary queue
Parameters:
dc - Description of Parameter The TemporaryQueue value
exception:
JMSException - Description of Exception |
| getTemporaryTopic | | public TemporaryTopic getTemporaryTopic(ConnectionToken dc) throws JMSException(Code) | | Get a temporary topic.
Parameters:
dc - Description of Parameter The TemporaryTopic value
exception:
JMSException - Description of Exception |
| getThreadGroup | | public ThreadGroup getThreadGroup()(Code) | | Get the thread group of the server.
|
| ping | | public void ping(ConnectionToken dc, long clientTime) throws JMSException(Code) | | Ping the server.
Parameters:
dc - Description of Parameter
Parameters:
clientTime - Description of Parameter
exception:
JMSException - Description of Exception |
| receive | | public SpyMessage receive(ConnectionToken dc, int subscriberId, long wait) throws JMSException(Code) | | #Description of the Method
Parameters:
dc - Description of Parameter
Parameters:
subscriberId - Description of Parameter
Parameters:
wait - Description of Parameter Description of the Returned Value
exception:
JMSException - Description of Exception |
| setEnabled | | public void setEnabled(ConnectionToken dc, boolean enabled) throws JMSException(Code) | | Sets the Enabled attribute of the ServerIL object
Parameters:
dc - The new Enabled value
Parameters:
enabled - The new Enabled value
exception:
JMSException - Description of Exception |
| transact | | public void transact(ConnectionToken dc, TransactionRequest t) throws JMSException(Code) | | #Description of the Method
Parameters:
dc - Description of Parameter
Parameters:
t - Description of Parameter
exception:
JMSException - Description of Exception |
| unsubscribe | | public void unsubscribe(ConnectionToken dc, int subscriptionId) throws JMSException(Code) | | Close the server side message consumer. Client is no longer
available to receive messages.
Parameters:
dc - Description of Parameter
Parameters:
subscriptionId - Description of Parameter
exception:
JMSException - Description of Exception |
|
|