站内搜索: 请输入搜索关键词
当前页面: 在线文档首页 > JBoss 3.2.7 messaging API Documentation 英文版文档

JMSServerInvoker (JBoss Messaging API) - JBoss 3.2.7 messaging API Documentation 英文版文档


org.jboss.mq.server
Class JMSServerInvoker

java.lang.Object
  extended byorg.jboss.mq.server.JMSServerInvoker
All Implemented Interfaces:
Invoker

public class JMSServerInvoker
extends Object
implements Invoker

A pass through JMSServerInvoker.

Version:
$Revision: 1.2.2.1 $
Author:
Peter Antman

Field Summary
protected  org.jboss.logging.Logger log
           
protected  JMSServerInterceptor nextInterceptor
          Next invoker in chain.
 
Constructor Summary
JMSServerInvoker()
           
 
Method Summary
 void acknowledge(ConnectionToken dc, AcknowledgementRequest item)
          #Description of the Method
 void addMessage(ConnectionToken dc, SpyMessage message)
          Add the message to the destination.
 String authenticate(String userName, String password)
          Check user for autentication.
 SpyMessage[] browse(ConnectionToken dc, javax.jms.Destination dest, String selector)
          #Description of the Method
 void checkID(String ID)
          Check id, must not be taken.
 String checkUser(String userName, String password)
          Check user for autentication.
 void connectionClosing(ConnectionToken dc)
          #Description of the Method
 javax.jms.Queue createQueue(ConnectionToken dc, String dest)
          #Description of the Method
 javax.jms.Topic createTopic(ConnectionToken dc, String dest)
          #Description of the Method
 void deleteTemporaryDestination(ConnectionToken dc, SpyDestination dest)
          #Description of the Method
 void destroySubscription(ConnectionToken dc, DurableSubscriptionID id)
          #Description of the Method
 SpyTopic getDurableTopic(DurableSubscriptionID sub)
          Get the topic the durable subscription is on.
 String getID()
          Gets a clientID from server.
 JMSServerInterceptor getNext()
           
 Subscription getSubscription(ConnectionToken dc, int subscriberId)
          Get the subscription that match the id.
 javax.jms.TemporaryQueue getTemporaryQueue(ConnectionToken dc)
          Gets the TemporaryQueue attribute of the ServerIL object
 javax.jms.TemporaryTopic getTemporaryTopic(ConnectionToken dc)
          Gets the TemporaryTopic attribute of the ServerIL object
 ThreadGroup getThreadGroup()
          Get the thread group of the server.
 void ping(ConnectionToken dc, long clientTime)
          #Description of the Method
 SpyMessage receive(ConnectionToken dc, int subscriberId, long wait)
          #Description of the Method
 void setEnabled(ConnectionToken dc, boolean enabled)
          Sets the Enabled attribute of the ServerIL object
 void setNext(JMSServerInterceptor server)
          Set next invoker in chain to be called.
 void subscribe(ConnectionToken dc, Subscription s)
           
 void transact(ConnectionToken dc, TransactionRequest t)
          #Description of the Method
 void unsubscribe(ConnectionToken dc, int subscriptionId)
          #Description of the Method
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

log

protected org.jboss.logging.Logger log

nextInterceptor

protected JMSServerInterceptor nextInterceptor
Next invoker in chain.

Constructor Detail

JMSServerInvoker

public JMSServerInvoker()
Method Detail

setNext

public void setNext(JMSServerInterceptor server)
Set next invoker in chain to be called. Is mot often the real JMSServer


getNext

public JMSServerInterceptor getNext()
See Also:
JMSServerInterceptor.getNext()

getThreadGroup

public ThreadGroup getThreadGroup()
Get the thread group of the server.

Specified by:
getThreadGroup in interface Invoker

getID

public String getID()
             throws javax.jms.JMSException
Gets a clientID from server.

Specified by:
getID in interface Invoker
Returns:
The ID value
Throws:
javax.jms.JMSException - Description of Exception

getTemporaryTopic

public javax.jms.TemporaryTopic getTemporaryTopic(ConnectionToken dc)
                                           throws javax.jms.JMSException
Gets the TemporaryTopic attribute of the ServerIL object

Specified by:
getTemporaryTopic in interface Invoker
Parameters:
dc - Description of Parameter
Returns:
The TemporaryTopic value
Throws:
javax.jms.JMSException - Description of Exception

getTemporaryQueue

public javax.jms.TemporaryQueue getTemporaryQueue(ConnectionToken dc)
                                           throws javax.jms.JMSException
Gets the TemporaryQueue attribute of the ServerIL object

Specified by:
getTemporaryQueue in interface Invoker
Parameters:
dc - Description of Parameter
Returns:
The TemporaryQueue value
Throws:
javax.jms.JMSException - Description of Exception

connectionClosing

public void connectionClosing(ConnectionToken dc)
                       throws javax.jms.JMSException
#Description of the Method

Specified by:
connectionClosing in interface Invoker
Parameters:
dc - Description of Parameter
Throws:
javax.jms.JMSException - Description of Exception

checkID

public void checkID(String ID)
             throws javax.jms.JMSException
Check id, must not be taken.

Specified by:
checkID in interface Invoker
Parameters:
ID - a clientID
Throws:
javax.jms.JMSException - if ID is already taken

addMessage

public void addMessage(ConnectionToken dc,
                       SpyMessage message)
                throws javax.jms.JMSException
Add the message to the destination.

Specified by:
addMessage in interface Invoker
Parameters:
dc - The feature to be added to the Message attribute
message - The feature to be added to the Message attribute
Throws:
javax.jms.JMSException - Description of Exception

createQueue

public javax.jms.Queue createQueue(ConnectionToken dc,
                                   String dest)
                            throws javax.jms.JMSException
#Description of the Method

Specified by:
createQueue in interface Invoker
Parameters:
dc - Description of Parameter
dest - Description of Parameter
Returns:
Description of the Returned Value
Throws:
javax.jms.JMSException - Description of Exception

createTopic

public javax.jms.Topic createTopic(ConnectionToken dc,
                                   String dest)
                            throws javax.jms.JMSException
#Description of the Method

Specified by:
createTopic in interface Invoker
Parameters:
dc - Description of Parameter
dest - Description of Parameter
Returns:
Description of the Returned Value
Throws:
javax.jms.JMSException - Description of Exception

deleteTemporaryDestination

public void deleteTemporaryDestination(ConnectionToken dc,
                                       SpyDestination dest)
                                throws javax.jms.JMSException
#Description of the Method

Specified by:
deleteTemporaryDestination in interface Invoker
Parameters:
dc - Description of Parameter
dest - Description of Parameter
Throws:
javax.jms.JMSException - Description of Exception

transact

public void transact(ConnectionToken dc,
                     TransactionRequest t)
              throws javax.jms.JMSException
#Description of the Method

Specified by:
transact in interface Invoker
Parameters:
dc - Description of Parameter
t - Description of Parameter
Throws:
javax.jms.JMSException - Description of Exception

acknowledge

public void acknowledge(ConnectionToken dc,
                        AcknowledgementRequest item)
                 throws javax.jms.JMSException
#Description of the Method

Specified by:
acknowledge in interface Invoker
Parameters:
dc - Description of Parameter
item - Description of Parameter
Throws:
javax.jms.JMSException - Description of Exception

browse

public SpyMessage[] browse(ConnectionToken dc,
                           javax.jms.Destination dest,
                           String selector)
                    throws javax.jms.JMSException
#Description of the Method

Specified by:
browse in interface Invoker
Parameters:
dc - Description of Parameter
dest - Description of Parameter
selector - Description of Parameter
Returns:
Description of the Returned Value
Throws:
javax.jms.JMSException - Description of Exception

receive

public SpyMessage receive(ConnectionToken dc,
                          int subscriberId,
                          long wait)
                   throws javax.jms.JMSException
#Description of the Method

Specified by:
receive in interface Invoker
Parameters:
dc - Description of Parameter
subscriberId - Description of Parameter
wait - Description of Parameter
Returns:
Description of the Returned Value
Throws:
javax.jms.JMSException - Description of Exception

setEnabled

public void setEnabled(ConnectionToken dc,
                       boolean enabled)
                throws javax.jms.JMSException
Sets the Enabled attribute of the ServerIL object

Specified by:
setEnabled in interface Invoker
Parameters:
dc - The new Enabled value
enabled - The new Enabled value
Throws:
javax.jms.JMSException - Description of Exception

unsubscribe

public void unsubscribe(ConnectionToken dc,
                        int subscriptionId)
                 throws javax.jms.JMSException
#Description of the Method

Specified by:
unsubscribe in interface Invoker
Parameters:
dc - Description of Parameter
subscriptionId - Description of Parameter
Throws:
javax.jms.JMSException - Description of Exception

destroySubscription

public void destroySubscription(ConnectionToken dc,
                                DurableSubscriptionID id)
                         throws javax.jms.JMSException
#Description of the Method

Specified by:
destroySubscription in interface Invoker
Parameters:
id - Description of Parameter
Throws:
javax.jms.JMSException - Description of Exception

checkUser

public String checkUser(String userName,
                        String password)
                 throws javax.jms.JMSException
Check user for autentication.

Specified by:
checkUser in interface Invoker
Parameters:
userName - Description of Parameter
password - Description of Parameter
Returns:
a clientId.
Throws:
javax.jms.JMSException - if user was not allowed to login

authenticate

public String authenticate(String userName,
                           String password)
                    throws javax.jms.JMSException
Check user for autentication.

Specified by:
authenticate in interface Invoker
Parameters:
userName - Description of Parameter
password - Description of Parameter
Returns:
a sessionId
Throws:
javax.jms.JMSException - if user was not allowed to login

subscribe

public void subscribe(ConnectionToken dc,
                      Subscription s)
               throws javax.jms.JMSException
Specified by:
subscribe in interface Invoker
Parameters:
dc - org.jboss.mq.ConnectionToken
s - org.jboss.mq.Subscription
Throws:
javax.jms.JMSException - The exception description.

ping

public void ping(ConnectionToken dc,
                 long clientTime)
          throws javax.jms.JMSException
#Description of the Method

Specified by:
ping in interface Invoker
Parameters:
dc - Description of Parameter
clientTime - Description of Parameter
Throws:
javax.jms.JMSException - Description of Exception

getDurableTopic

public SpyTopic getDurableTopic(DurableSubscriptionID sub)
                         throws javax.jms.JMSException
Description copied from interface: Invoker
Get the topic the durable subscription is on. Primary for internal use in the server, and not for the IL's.

Specified by:
getDurableTopic in interface Invoker
Throws:
javax.jms.JMSException

getSubscription

public Subscription getSubscription(ConnectionToken dc,
                                    int subscriberId)
                             throws javax.jms.JMSException
Description copied from interface: Invoker
Get the subscription that match the id.

Specified by:
getSubscription in interface Invoker
Throws:
javax.jms.JMSException - if it can not find the subscription.


Copyright © 2002 JBoss Group, LLC. All Rights Reserved.