|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.jboss.jms.server.endpoint.advised.AdvisedSupport org.jboss.jms.server.endpoint.advised.SessionAdvised
The server-side advised instance corresponding to a Session. It is bound to the AOP Dispatcher's map.
Field Summary | |
protected SessionEndpoint |
endpoint
|
Constructor Summary | |
SessionAdvised(SessionEndpoint endpoint)
|
Method Summary | |
void |
acknowledge(AckInfo ack)
Acknowledge a message - used for auto acknowledge |
void |
acknowledgeBatch(java.util.List ackInfos)
Acknowledge a batch of messages - used with client acknowledge or dups_ok acknowledge |
void |
addTemporaryDestination(JBossDestination destination)
Add a temporary destination. |
void |
cancelDeliveries(java.util.List ackInfos)
Cancel some deliveries. |
void |
close()
Close the instance |
void |
closing()
Tell the instance to prepare to close |
BrowserDelegate |
createBrowserDelegate(JBossDestination queue,
java.lang.String messageSelector)
|
ConsumerDelegate |
createConsumerDelegate(JBossDestination destination,
java.lang.String selector,
boolean noLocal,
java.lang.String subscriptionName,
boolean connectionConsumer)
|
JBossQueue |
createQueue(java.lang.String queueName)
Creates a queue identity given a Queue name. |
JBossTopic |
createTopic(java.lang.String topicName)
Creates a topic identity given a Queue name. |
void |
deleteTemporaryDestination(JBossDestination destination)
Delete a temporary destination |
java.lang.Object |
getEndpoint()
|
boolean |
isClosed()
|
void |
send(JBossMessage msg)
Send a message |
java.lang.String |
toString()
|
void |
unsubscribe(java.lang.String subscriptionName)
Unsubscribe the client from the durable subscription specified by subscriptionName |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
protected SessionEndpoint endpoint
Constructor Detail |
public SessionAdvised(SessionEndpoint endpoint)
Method Detail |
public void close() throws JMSException
Closeable
close
in interface Closeable
JMSException
public void closing() throws JMSException
Closeable
closing
in interface Closeable
JMSException
public boolean isClosed()
isClosed
in interface Closeable
public void send(JBossMessage msg) throws JMSException
SessionEndpoint
send
in interface SessionEndpoint
msg
- The message to send
JMSException
public ConsumerDelegate createConsumerDelegate(JBossDestination destination, java.lang.String selector, boolean noLocal, java.lang.String subscriptionName, boolean connectionConsumer) throws JMSException
createConsumerDelegate
in interface SessionEndpoint
JMSException
public BrowserDelegate createBrowserDelegate(JBossDestination queue, java.lang.String messageSelector) throws JMSException
createBrowserDelegate
in interface SessionEndpoint
JMSException
public JBossQueue createQueue(java.lang.String queueName) throws JMSException
SessionEndpoint
createQueue
in interface SessionEndpoint
JMSException
public JBossTopic createTopic(java.lang.String topicName) throws JMSException
SessionEndpoint
createTopic
in interface SessionEndpoint
JMSException
public void acknowledgeBatch(java.util.List ackInfos) throws JMSException
SessionEndpoint
acknowledgeBatch
in interface SessionEndpoint
ackInfos
-
JMSException
public void acknowledge(AckInfo ack) throws JMSException
SessionEndpoint
acknowledge
in interface SessionEndpoint
ack
-
JMSException
public void addTemporaryDestination(JBossDestination destination) throws JMSException
SessionEndpoint
addTemporaryDestination
in interface SessionEndpoint
JMSException
public void deleteTemporaryDestination(JBossDestination destination) throws JMSException
SessionEndpoint
deleteTemporaryDestination
in interface SessionEndpoint
JMSException
public void unsubscribe(java.lang.String subscriptionName) throws JMSException
SessionEndpoint
unsubscribe
in interface SessionEndpoint
subscriptionName
- the Name of the durable subscription to unsubscribe from
JMSException
public void cancelDeliveries(java.util.List ackInfos) throws JMSException
SessionEndpoint
cancelDeliveries
in interface SessionEndpoint
ackInfos
-
JMSException
public java.lang.Object getEndpoint()
getEndpoint
in class AdvisedSupport
public java.lang.String toString()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |