|
||||||||||
PREV CLASS NEXT CLASS (src) | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
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.
Method Summary | |
void |
acknowledge(ConnectionToken (src) dc,
AcknowledgementRequest (src) item)
#Description of the Method |
void |
addMessage(ConnectionToken (src) dc,
SpyMessage (src) message)
Add the message to the destination. |
java.lang.String |
authenticate(java.lang.String userName,
java.lang.String password)
Check user for autentication. |
SpyMessage (src) [] |
browse(ConnectionToken (src) dc,
Destination (src) dest,
java.lang.String selector)
#Description of the Method |
void |
checkID(java.lang.String ID)
Check id, must not be taken. |
java.lang.String |
checkUser(java.lang.String userName,
java.lang.String password)
Check user for autentication. |
void |
connectionClosing(ConnectionToken (src) dc)
Close connection. |
Queue (src) |
createQueue(ConnectionToken (src) dc,
java.lang.String dest)
Create a queue. |
Topic (src) |
createTopic(ConnectionToken (src) dc,
java.lang.String dest)
Create a topic. |
void |
deleteTemporaryDestination(ConnectionToken (src) dc,
SpyDestination (src) dest)
#Description of the Method |
void |
destroySubscription(ConnectionToken (src) dc,
DurableSubscriptionID (src) id)
Unsubscribe from the durable subscription. |
SpyTopic (src) |
getDurableTopic(DurableSubscriptionID (src) sub)
Get the topic the durable subscription is on. |
java.lang.String |
getID()
Gets a clientID from server. |
JMSServerInterceptor (src) |
getNext()
Get next invoker in chain to be called. |
Subscription (src) |
getSubscription(ConnectionToken (src) dc,
int subscriberId)
Get the subscription that match the id. |
TemporaryQueue (src) |
getTemporaryQueue(ConnectionToken (src) dc)
Get a temporary queue |
TemporaryTopic (src) |
getTemporaryTopic(ConnectionToken (src) dc)
Get a temporary topic. |
java.lang.ThreadGroup |
getThreadGroup()
Get the thread group of the server. |
void |
ping(ConnectionToken (src) dc,
long clientTime)
Ping the server. |
SpyMessage (src) |
receive(ConnectionToken (src) dc,
int subscriberId,
long wait)
#Description of the Method |
void |
setEnabled(ConnectionToken (src) dc,
boolean enabled)
Sets the Enabled attribute of the ServerIL object |
void |
setNext(JMSServerInterceptor (src) server)
Set next Interceptor in chain to be called. |
void |
subscribe(ConnectionToken (src) dc,
Subscription (src) s)
|
void |
transact(ConnectionToken (src) dc,
TransactionRequest (src) t)
#Description of the Method |
void |
unsubscribe(ConnectionToken (src) dc,
int subscriptionId)
Close the server side message consumer. |
Method Detail |
public void setNext(JMSServerInterceptor (src) server)
public JMSServerInterceptor (src) getNext()
public java.lang.ThreadGroup getThreadGroup()
public java.lang.String getID() throws JMSException (src)
JMSException (src)
- Description of Exceptionpublic TemporaryTopic (src) getTemporaryTopic(ConnectionToken (src) dc) throws JMSException (src)
dc
- Description of Parameter
JMSException (src)
- Description of Exceptionpublic TemporaryQueue (src) getTemporaryQueue(ConnectionToken (src) dc) throws JMSException (src)
dc
- Description of Parameter
JMSException (src)
- Description of Exceptionpublic void connectionClosing(ConnectionToken (src) dc) throws JMSException (src)
dc
- Description of Parameter
JMSException (src)
- Description of Exceptionpublic void checkID(java.lang.String ID) throws JMSException (src)
ID
- Description of Parameter
JMSException (src)
- Description of Exceptionpublic void addMessage(ConnectionToken (src) dc, SpyMessage (src) message) throws JMSException (src)
dc
- The feature to be added to the Message attributemessage
- The feature to be added to the Message attribute
JMSException (src)
- Description of Exceptionpublic Queue (src) createQueue(ConnectionToken (src) dc, java.lang.String dest) throws JMSException (src)
dc
- Description of Parameterdest
- Description of Parameter
JMSException (src)
- Description of Exceptionpublic Topic (src) createTopic(ConnectionToken (src) dc, java.lang.String dest) throws JMSException (src)
dc
- Description of Parameterdest
- Description of Parameter
JMSException (src)
- Description of Exceptionpublic void deleteTemporaryDestination(ConnectionToken (src) dc, SpyDestination (src) dest) throws JMSException (src)
dc
- Description of Parameterdest
- Description of Parameter
JMSException (src)
- Description of Exceptionpublic void transact(ConnectionToken (src) dc, TransactionRequest (src) t) throws JMSException (src)
dc
- Description of Parametert
- Description of Parameter
JMSException (src)
- Description of Exceptionpublic void acknowledge(ConnectionToken (src) dc, AcknowledgementRequest (src) item) throws JMSException (src)
dc
- Description of Parameteritem
- Description of Parameter
JMSException (src)
- Description of Exceptionpublic SpyMessage (src) [] browse(ConnectionToken (src) dc, Destination (src) dest, java.lang.String selector) throws JMSException (src)
dc
- Description of Parameterdest
- Description of Parameterselector
- Description of Parameter
JMSException (src)
- Description of Exceptionpublic SpyMessage (src) receive(ConnectionToken (src) dc, int subscriberId, long wait) throws JMSException (src)
dc
- Description of ParametersubscriberId
- Description of Parameterwait
- Description of Parameter
JMSException (src)
- Description of Exceptionpublic void setEnabled(ConnectionToken (src) dc, boolean enabled) throws JMSException (src)
dc
- The new Enabled valueenabled
- The new Enabled value
JMSException (src)
- Description of Exceptionpublic void unsubscribe(ConnectionToken (src) dc, int subscriptionId) throws JMSException (src)
dc
- Description of ParametersubscriptionId
- Description of Parameter
JMSException (src)
- Description of Exceptionpublic void destroySubscription(ConnectionToken (src) dc, DurableSubscriptionID (src) id) throws JMSException (src)
id
- Description of Parameter
JMSException (src)
- Description of Exceptionpublic java.lang.String checkUser(java.lang.String userName, java.lang.String password) throws JMSException (src)
userName
- Description of Parameterpassword
- Description of Parameter
JMSException (src)
- if user was not allowed to loginpublic java.lang.String authenticate(java.lang.String userName, java.lang.String password) throws JMSException (src)
userName
- Description of Parameterpassword
- Description of Parameter
JMSException (src)
- if user was not allowed to loginpublic void subscribe(ConnectionToken (src) dc, Subscription (src) s) throws JMSException (src)
dc
- org.jboss.mq.ConnectionTokens
- org.jboss.mq.Subscription
JMSException (src)
- The exception description.public void ping(ConnectionToken (src) dc, long clientTime) throws JMSException (src)
dc
- Description of ParameterclientTime
- Description of Parameter
JMSException (src)
- Description of Exceptionpublic SpyTopic (src) getDurableTopic(DurableSubscriptionID (src) sub) throws JMSException (src)
JMSException (src)
public Subscription (src) getSubscription(ConnectionToken (src) dc, int subscriberId) throws JMSException (src)
JMSException (src)
- if it can not find the subscription.
|
||||||||||
PREV CLASS NEXT CLASS (src) | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |