|
|||||||||||
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 |
acknowledgeDeliveries(java.util.List acks)
Acknowledge a list of deliveries |
void |
acknowledgeDelivery(Ack ack)
Acknowledge a delivery |
void |
addTemporaryDestination(JBossDestination destination)
Add a temporary destination. |
void |
cancelDeliveries(java.util.List ackInfos)
Cancel a list of deliveries. |
void |
cancelDelivery(Cancel cancel)
Cancel a delivery |
void |
close()
Close the instance |
long |
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()
|
void |
recoverDeliveries(java.util.List ackInfos)
Send delivery info to the server so the delivery lists can be repopulated. |
void |
send(JBossMessage msg,
boolean checkForDuplicates)
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 long closing() throws JMSException
Closeable
closing
in interface Closeable
JMSException
public void send(JBossMessage msg, boolean checkForDuplicates) 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 acknowledgeDeliveries(java.util.List acks) throws JMSException
SessionEndpoint
acknowledgeDeliveries
in interface SessionEndpoint
JMSException
public void acknowledgeDelivery(Ack ack) throws JMSException
SessionEndpoint
acknowledgeDelivery
in interface SessionEndpoint
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
JMSException
public void cancelDelivery(Cancel cancel) throws JMSException
SessionEndpoint
cancelDelivery
in interface SessionEndpoint
cancel
-
JMSException
public void recoverDeliveries(java.util.List ackInfos) throws JMSException
SessionEndpoint
recoverDeliveries
in interface SessionEndpoint
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 |