|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.jboss.mq.server.JMSServerInvoker
A pass through JMSServerInvoker.
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 |
protected org.jboss.logging.Logger log
protected JMSServerInterceptor nextInterceptor
Constructor Detail |
public JMSServerInvoker()
Method Detail |
public void setNext(JMSServerInterceptor server)
public JMSServerInterceptor getNext()
JMSServerInterceptor.getNext()
public ThreadGroup getThreadGroup()
getThreadGroup
in interface Invoker
public String getID() throws javax.jms.JMSException
javax.jms.JMSException
- Description of Exceptionpublic javax.jms.TemporaryTopic getTemporaryTopic(ConnectionToken dc) throws javax.jms.JMSException
getTemporaryTopic
in interface Invoker
dc
- Description of Parameter
javax.jms.JMSException
- Description of Exceptionpublic javax.jms.TemporaryQueue getTemporaryQueue(ConnectionToken dc) throws javax.jms.JMSException
getTemporaryQueue
in interface Invoker
dc
- Description of Parameter
javax.jms.JMSException
- Description of Exceptionpublic void connectionClosing(ConnectionToken dc) throws javax.jms.JMSException
connectionClosing
in interface Invoker
dc
- Description of Parameter
javax.jms.JMSException
- Description of Exceptionpublic void checkID(String ID) throws javax.jms.JMSException
ID
- a clientID
javax.jms.JMSException
- if ID is already takenpublic void addMessage(ConnectionToken dc, SpyMessage message) throws javax.jms.JMSException
addMessage
in interface Invoker
dc
- The feature to be added to the Message attributemessage
- The feature to be added to the Message attribute
javax.jms.JMSException
- Description of Exceptionpublic javax.jms.Queue createQueue(ConnectionToken dc, String dest) throws javax.jms.JMSException
createQueue
in interface Invoker
dc
- Description of Parameterdest
- Description of Parameter
javax.jms.JMSException
- Description of Exceptionpublic javax.jms.Topic createTopic(ConnectionToken dc, String dest) throws javax.jms.JMSException
createTopic
in interface Invoker
dc
- Description of Parameterdest
- Description of Parameter
javax.jms.JMSException
- Description of Exceptionpublic void deleteTemporaryDestination(ConnectionToken dc, SpyDestination dest) throws javax.jms.JMSException
deleteTemporaryDestination
in interface Invoker
dc
- Description of Parameterdest
- Description of Parameter
javax.jms.JMSException
- Description of Exceptionpublic void transact(ConnectionToken dc, TransactionRequest t) throws javax.jms.JMSException
dc
- Description of Parametert
- Description of Parameter
javax.jms.JMSException
- Description of Exceptionpublic void acknowledge(ConnectionToken dc, AcknowledgementRequest item) throws javax.jms.JMSException
acknowledge
in interface Invoker
dc
- Description of Parameteritem
- Description of Parameter
javax.jms.JMSException
- Description of Exceptionpublic SpyMessage[] browse(ConnectionToken dc, javax.jms.Destination dest, String selector) throws javax.jms.JMSException
dc
- Description of Parameterdest
- Description of Parameterselector
- Description of Parameter
javax.jms.JMSException
- Description of Exceptionpublic SpyMessage receive(ConnectionToken dc, int subscriberId, long wait) throws javax.jms.JMSException
dc
- Description of ParametersubscriberId
- Description of Parameterwait
- Description of Parameter
javax.jms.JMSException
- Description of Exceptionpublic void setEnabled(ConnectionToken dc, boolean enabled) throws javax.jms.JMSException
setEnabled
in interface Invoker
dc
- The new Enabled valueenabled
- The new Enabled value
javax.jms.JMSException
- Description of Exceptionpublic void unsubscribe(ConnectionToken dc, int subscriptionId) throws javax.jms.JMSException
unsubscribe
in interface Invoker
dc
- Description of ParametersubscriptionId
- Description of Parameter
javax.jms.JMSException
- Description of Exceptionpublic void destroySubscription(ConnectionToken dc, DurableSubscriptionID id) throws javax.jms.JMSException
destroySubscription
in interface Invoker
id
- Description of Parameter
javax.jms.JMSException
- Description of Exceptionpublic String checkUser(String userName, String password) throws javax.jms.JMSException
userName
- Description of Parameterpassword
- Description of Parameter
javax.jms.JMSException
- if user was not allowed to loginpublic String authenticate(String userName, String password) throws javax.jms.JMSException
authenticate
in interface Invoker
userName
- Description of Parameterpassword
- Description of Parameter
javax.jms.JMSException
- if user was not allowed to loginpublic void subscribe(ConnectionToken dc, Subscription s) throws javax.jms.JMSException
dc
- org.jboss.mq.ConnectionTokens
- org.jboss.mq.Subscription
javax.jms.JMSException
- The exception description.public void ping(ConnectionToken dc, long clientTime) throws javax.jms.JMSException
dc
- Description of ParameterclientTime
- Description of Parameter
javax.jms.JMSException
- Description of Exceptionpublic SpyTopic getDurableTopic(DurableSubscriptionID sub) throws javax.jms.JMSException
Invoker
getDurableTopic
in interface Invoker
javax.jms.JMSException
public Subscription getSubscription(ConnectionToken dc, int subscriberId) throws javax.jms.JMSException
Invoker
getSubscription
in interface Invoker
javax.jms.JMSException
- if it can not find the subscription.
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |