|
||||||||||
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
public class 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 |
boolean |
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(long sequence)
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,
boolean autoFlowControl)
|
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,
java.lang.String oldSessionID)
Send delivery info to the server so the delivery lists can be repopulated. |
void |
send(JBossMessage msg,
boolean checkForDuplicates)
Send a message |
void |
send(JBossMessage msg,
boolean checkForDuplicates,
long sequence)
|
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 javax.jms.JMSException
Closeable
close
in interface Closeable
javax.jms.JMSException
public long closing(long sequence) throws javax.jms.JMSException
Closeable
closing
in interface Closeable
javax.jms.JMSException
public void send(JBossMessage msg, boolean checkForDuplicates) throws javax.jms.JMSException
SessionEndpoint
send
in interface SessionEndpoint
msg
- The message to send
javax.jms.JMSException
public void send(JBossMessage msg, boolean checkForDuplicates, long sequence) throws javax.jms.JMSException
send
in interface SessionInternalEndpoint
javax.jms.JMSException
public ConsumerDelegate createConsumerDelegate(JBossDestination destination, java.lang.String selector, boolean noLocal, java.lang.String subscriptionName, boolean connectionConsumer, boolean autoFlowControl) throws javax.jms.JMSException
createConsumerDelegate
in interface SessionEndpoint
javax.jms.JMSException
public BrowserDelegate createBrowserDelegate(JBossDestination queue, java.lang.String messageSelector) throws javax.jms.JMSException
createBrowserDelegate
in interface SessionEndpoint
javax.jms.JMSException
public JBossQueue createQueue(java.lang.String queueName) throws javax.jms.JMSException
SessionEndpoint
createQueue
in interface SessionEndpoint
javax.jms.JMSException
public JBossTopic createTopic(java.lang.String topicName) throws javax.jms.JMSException
SessionEndpoint
createTopic
in interface SessionEndpoint
javax.jms.JMSException
public void acknowledgeDeliveries(java.util.List acks) throws javax.jms.JMSException
SessionEndpoint
acknowledgeDeliveries
in interface SessionEndpoint
javax.jms.JMSException
public boolean acknowledgeDelivery(Ack ack) throws javax.jms.JMSException
SessionEndpoint
acknowledgeDelivery
in interface SessionEndpoint
javax.jms.JMSException
public void addTemporaryDestination(JBossDestination destination) throws javax.jms.JMSException
SessionEndpoint
addTemporaryDestination
in interface SessionEndpoint
javax.jms.JMSException
public void deleteTemporaryDestination(JBossDestination destination) throws javax.jms.JMSException
SessionEndpoint
deleteTemporaryDestination
in interface SessionEndpoint
javax.jms.JMSException
public void unsubscribe(java.lang.String subscriptionName) throws javax.jms.JMSException
SessionEndpoint
unsubscribe
in interface SessionEndpoint
subscriptionName
- the Name of the durable subscription to unsubscribe from
javax.jms.JMSException
- if the unsubscribe failspublic void cancelDeliveries(java.util.List ackInfos) throws javax.jms.JMSException
SessionEndpoint
cancelDeliveries
in interface SessionEndpoint
javax.jms.JMSException
public void cancelDelivery(Cancel cancel) throws javax.jms.JMSException
SessionEndpoint
cancelDelivery
in interface SessionEndpoint
javax.jms.JMSException
public void recoverDeliveries(java.util.List ackInfos, java.lang.String oldSessionID) throws javax.jms.JMSException
SessionEndpoint
recoverDeliveries
in interface SessionEndpoint
javax.jms.JMSException
public java.lang.Object getEndpoint()
getEndpoint
in class AdvisedSupport
public java.lang.String toString()
toString
in class java.lang.Object
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |