| org.jboss.mq.server.JMSServerInterceptor
All known Subclasses: org.jboss.mq.server.JMSServerInterceptorSupport,
| JMSServerInterceptor | | public interface JMSServerInterceptor (Code) | | Interceptor interface for clients IL accessing the JMSServer.
Using an iterface for this layer makes it possible to put in logic
without having to modify the server objet. And also makes this
pluggable.
author:
Peter Antman
version:
$Revision: 57198 $ |
| 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 JMSServerInterceptor | getNext()
Get next invoker in chain to be called. | | 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)
| | public void | setNext(JMSServerInterceptor server)
Set next Interceptor in chain to be called. | | 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 |
| setNext | | public void setNext(JMSServerInterceptor server)(Code) | | Set next Interceptor in chain to be called. Is mot often the real JMSServer
|
| 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 |
|
|