|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||
java.lang.Objectorg.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 CloseableJMSException
public long closing()
throws JMSException
Closeable
closing in interface CloseableJMSException
public void send(JBossMessage msg,
boolean checkForDuplicates)
throws JMSException
SessionEndpoint
send in interface SessionEndpointmsg - 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 SessionEndpointJMSException
public BrowserDelegate createBrowserDelegate(JBossDestination queue,
java.lang.String messageSelector)
throws JMSException
createBrowserDelegate in interface SessionEndpointJMSException
public JBossQueue createQueue(java.lang.String queueName)
throws JMSException
SessionEndpoint
createQueue in interface SessionEndpointJMSException
public JBossTopic createTopic(java.lang.String topicName)
throws JMSException
SessionEndpoint
createTopic in interface SessionEndpointJMSException
public void acknowledgeDeliveries(java.util.List acks)
throws JMSException
SessionEndpoint
acknowledgeDeliveries in interface SessionEndpointJMSException
public void acknowledgeDelivery(Ack ack)
throws JMSException
SessionEndpoint
acknowledgeDelivery in interface SessionEndpointJMSException
public void addTemporaryDestination(JBossDestination destination)
throws JMSException
SessionEndpoint
addTemporaryDestination in interface SessionEndpointJMSException
public void deleteTemporaryDestination(JBossDestination destination)
throws JMSException
SessionEndpoint
deleteTemporaryDestination in interface SessionEndpointJMSException
public void unsubscribe(java.lang.String subscriptionName)
throws JMSException
SessionEndpoint
unsubscribe in interface SessionEndpointsubscriptionName - the Name of the durable subscription to unsubscribe from
JMSException
public void cancelDeliveries(java.util.List ackInfos)
throws JMSException
SessionEndpoint
cancelDeliveries in interface SessionEndpointJMSException
public void cancelDelivery(Cancel cancel)
throws JMSException
SessionEndpoint
cancelDelivery in interface SessionEndpointcancel -
JMSException
public void recoverDeliveries(java.util.List ackInfos)
throws JMSException
SessionEndpoint
recoverDeliveries in interface SessionEndpointJMSExceptionpublic java.lang.Object getEndpoint()
getEndpoint in class AdvisedSupportpublic java.lang.String toString()
|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||