org.jboss.jms.server.endpoint.advised
Class SessionAdvised

java.lang.Object
  org.jboss.jms.server.endpoint.advised.AdvisedSupport
      org.jboss.jms.server.endpoint.advised.SessionAdvised

All Implemented Interfaces:

Closeable, SessionEndpoint, SessionInternalEndpoint

public class SessionAdvised
extends AdvisedSupport
implements SessionInternalEndpoint

The server-side advised instance corresponding to a Session. It is bound to the AOP Dispatcher's map.

Version:

$Revision: 3238 $ $Id: SessionAdvised.java 3238 2007-10-21 23:29:00Z timfox $

Author:

Tim Fox, Ovidiu Feodorov, Clebert Suconic

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 seq)
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

endpoint

protected SessionEndpoint endpoint

Constructor Detail

SessionAdvised

public SessionAdvised(SessionEndpoint endpoint)

Method Detail

close

public void close()
           throws JMSException

Description copied from interface: Closeable

Close the instance

Specified by:

close in interface Closeable

Throws:

JMSException

closing

public long closing(long sequence)
             throws JMSException

Description copied from interface: Closeable

Tell the instance to prepare to close

Specified by:

closing in interface Closeable

Throws:

JMSException

send

public void send(JBossMessage msg,
                 boolean checkForDuplicates)
          throws JMSException

Description copied from interface: SessionEndpoint

Send a message

Specified by:

send in interface SessionEndpoint

Parameters:

msg - The message to send

Throws:

JMSException

send

public void send(JBossMessage msg,
                 boolean checkForDuplicates,
                 long seq)
          throws JMSException

Specified by:

send in interface SessionInternalEndpoint

Throws:

JMSException

createConsumerDelegate

public ConsumerDelegate createConsumerDelegate(JBossDestination destination,
                                               java.lang.String selector,
                                               boolean noLocal,
                                               java.lang.String subscriptionName,
                                               boolean connectionConsumer,
                                               boolean autoFlowControl)
                                        throws JMSException

Specified by:

createConsumerDelegate in interface SessionEndpoint

Throws:

JMSException

createBrowserDelegate

public BrowserDelegate createBrowserDelegate(JBossDestination queue,
                                             java.lang.String messageSelector)
                                      throws JMSException

Specified by:

createBrowserDelegate in interface SessionEndpoint

Throws:

JMSException

createQueue

public JBossQueue createQueue(java.lang.String queueName)
                       throws JMSException

Description copied from interface: SessionEndpoint

Creates a queue identity given a Queue name. Does NOT create the physical queue. The physical creation of queues is an administrative task and is not to be initiated by the JMS API, with the exception of temporary queues.

Specified by:

createQueue in interface SessionEndpoint

Throws:

JMSException

createTopic

public JBossTopic createTopic(java.lang.String topicName)
                       throws JMSException

Description copied from interface: SessionEndpoint

Creates a topic identity given a Queue name. Does NOT create the physical topic. The physical creation of topics is an administrative task and is not to be initiated by the JMS API, with the exception of temporary topics.

Specified by:

createTopic in interface SessionEndpoint

Throws:

JMSException

acknowledgeDeliveries

public void acknowledgeDeliveries(java.util.List acks)
                           throws JMSException

Description copied from interface: SessionEndpoint

Acknowledge a list of deliveries

Specified by:

acknowledgeDeliveries in interface SessionEndpoint

Throws:

JMSException

acknowledgeDelivery

public boolean acknowledgeDelivery(Ack ack)
                            throws JMSException

Description copied from interface: SessionEndpoint

Acknowledge a delivery

Specified by:

acknowledgeDelivery in interface SessionEndpoint

Throws:

JMSException

addTemporaryDestination

public void addTemporaryDestination(JBossDestination destination)
                             throws JMSException

Description copied from interface: SessionEndpoint

Add a temporary destination.

Specified by:

addTemporaryDestination in interface SessionEndpoint

Throws:

JMSException

deleteTemporaryDestination

public void deleteTemporaryDestination(JBossDestination destination)
                                throws JMSException

Description copied from interface: SessionEndpoint

Delete a temporary destination

Specified by:

deleteTemporaryDestination in interface SessionEndpoint

Throws:

JMSException

unsubscribe

public void unsubscribe(java.lang.String subscriptionName)
                 throws JMSException

Description copied from interface: SessionEndpoint

Unsubscribe the client from the durable subscription specified by subscriptionName

Specified by:

unsubscribe in interface SessionEndpoint

Parameters:

subscriptionName - the Name of the durable subscription to unsubscribe from

Throws:

JMSException - if the unsubscribe fails

cancelDeliveries

public void cancelDeliveries(java.util.List ackInfos)
                      throws JMSException

Description copied from interface: SessionEndpoint

Cancel a list of deliveries.

Specified by:

cancelDeliveries in interface SessionEndpoint

Throws:

JMSException

cancelDelivery

public void cancelDelivery(Cancel cancel)
                    throws JMSException

Description copied from interface: SessionEndpoint

Cancel a delivery

Specified by:

cancelDelivery in interface SessionEndpoint

Throws:

JMSException

recoverDeliveries

public void recoverDeliveries(java.util.List ackInfos,
                              java.lang.String oldSessionID)
                       throws JMSException

Description copied from interface: SessionEndpoint

Send delivery info to the server so the delivery lists can be repopulated. Used only in failover.

Specified by:

recoverDeliveries in interface SessionEndpoint

Throws:

JMSException

getEndpoint

public java.lang.Object getEndpoint()

Specified by:

getEndpoint in class AdvisedSupport

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object