org.fusesource.stomp.jms

Class StompJmsSession

java.lang.Object

org.fusesource.stomp.jms.StompJmsSession

All Implemented Interfaces:

java.lang.Runnable, javax.jms.QueueSession, javax.jms.Session, javax.jms.TopicSession, StompJmsMessageListener

Direct Known Subclasses:

StompJmsQueueSession, StompJmsTopicSession

public class StompJmsSession
extends java.lang.Object
implements javax.jms.Session, javax.jms.QueueSession, javax.jms.TopicSession, StompJmsMessageListener

JMS Session implementation

Field Summary

Fields inherited from interface javax.jms.Session

AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	StompJmsSession(StompJmsConnection connection, int acknowledgementMode, boolean forceAsyncSend) Constructor

Method Summary

Methods

Modifier and Type	Method and Description
protected void	add(javax.jms.MessageProducer producer)
protected void	add(StompJmsMessageConsumer consumer)
protected void	checkClosed()
static void	checkDestination(javax.jms.Destination dest)
static java.lang.String	checkSelector(java.lang.String selector)
void	close()
void	commit()
javax.jms.QueueBrowser	createBrowser(javax.jms.Queue destination)
javax.jms.QueueBrowser	createBrowser(javax.jms.Queue destination, java.lang.String messageSelector)
javax.jms.BytesMessage	createBytesMessage()
javax.jms.MessageConsumer	createConsumer(javax.jms.Destination destination)
javax.jms.MessageConsumer	createConsumer(javax.jms.Destination destination, java.lang.String messageSelector)
javax.jms.MessageConsumer	createConsumer(javax.jms.Destination destination, java.lang.String messageSelector, boolean NoLocal)
javax.jms.TopicSubscriber	createDurableSubscriber(javax.jms.Topic topic, java.lang.String name)
javax.jms.TopicSubscriber	createDurableSubscriber(javax.jms.Topic topic, java.lang.String name, java.lang.String messageSelector, boolean noLocal)
javax.jms.MapMessage	createMapMessage()
javax.jms.Message	createMessage()
javax.jms.ObjectMessage	createObjectMessage()
javax.jms.ObjectMessage	createObjectMessage(java.io.Serializable object)
javax.jms.MessageProducer	createProducer(javax.jms.Destination destination)
javax.jms.TopicPublisher	createPublisher(javax.jms.Topic topic)
javax.jms.Queue	createQueue(java.lang.String queueName)
javax.jms.QueueReceiver	createReceiver(javax.jms.Queue queue)
javax.jms.QueueReceiver	createReceiver(javax.jms.Queue queue, java.lang.String messageSelector)
javax.jms.QueueSender	createSender(javax.jms.Queue queue)
javax.jms.StreamMessage	createStreamMessage()
javax.jms.TopicSubscriber	createSubscriber(javax.jms.Topic topic)
javax.jms.TopicSubscriber	createSubscriber(javax.jms.Topic topic, java.lang.String messageSelector, boolean noLocal)
javax.jms.TemporaryQueue	createTemporaryQueue()
javax.jms.TemporaryTopic	createTemporaryTopic()
javax.jms.TextMessage	createTextMessage()
javax.jms.TextMessage	createTextMessage(java.lang.String text)
javax.jms.Topic	createTopic(java.lang.String topicName)
int	getAcknowledgeMode()
protected StompChannel	getChannel()
StompJmsConnection	getConnection()
javax.jms.MessageListener	getMessageListener()
StompJmsPrefetch	getPrefetch()
boolean	getTransacted()
boolean	isForceAsyncSend()
protected boolean	isStarted()
protected void	onException(java.lang.Exception ex)
protected void	onException(javax.jms.JMSException ex)
void	onMessage(StompJmsMessage message) Called when a Message is available to be processes
void	recover()
protected void	remove(javax.jms.MessageProducer producer)
protected void	remove(StompJmsMessageConsumer consumer)
void	rollback()
void	run()
protected void	send(javax.jms.Destination dest, javax.jms.Message msg, int deliveryMode, int priority, long timeToLive, boolean disableMsgId)
void	setForceAsyncSend(boolean forceAsyncSend)
void	setMessageListener(javax.jms.MessageListener listener)
void	setPrefetch(StompJmsPrefetch prefetch)
protected void	start()
protected void	stop()
void	unsubscribe(java.lang.String name)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StompJmsSession

protected StompJmsSession(StompJmsConnection connection,
               int acknowledgementMode,
               boolean forceAsyncSend)

Constructor

Parameters:

connection -

acknowledgementMode -

Method Detail

getAcknowledgeMode

public int getAcknowledgeMode()
                       throws javax.jms.JMSException

Specified by:

getAcknowledgeMode in interface javax.jms.Session

Returns:

acknowledgeMode

Throws:

javax.jms.JMSException

See Also:

Session.getAcknowledgeMode()

getTransacted

public boolean getTransacted()
                      throws javax.jms.JMSException

Specified by:

getTransacted in interface javax.jms.Session

Returns:

true if transacted

Throws:

javax.jms.JMSException

See Also:

Session.getTransacted()

getMessageListener

public javax.jms.MessageListener getMessageListener()
                                             throws javax.jms.JMSException

Specified by:

getMessageListener in interface javax.jms.Session

Returns:

the Sesion messageListener

Throws:

javax.jms.JMSException

See Also:

Session.getMessageListener()

setMessageListener

public void setMessageListener(javax.jms.MessageListener listener)
                        throws javax.jms.JMSException

Specified by:

setMessageListener in interface javax.jms.Session

Parameters:

listener -

Throws:

javax.jms.JMSException

See Also:

Session.setMessageListener(javax.jms.MessageListener)

recover

public void recover()
             throws javax.jms.JMSException

Specified by:

recover in interface javax.jms.Session

Throws:

javax.jms.JMSException

See Also:

Session.recover()

commit

public void commit()
            throws javax.jms.JMSException

Specified by:

commit in interface javax.jms.Session

Throws:

javax.jms.JMSException

See Also:

Session.commit()

rollback

public void rollback()
              throws javax.jms.JMSException

Specified by:

rollback in interface javax.jms.Session

Throws:

javax.jms.JMSException

See Also:

Session.rollback()

run

public void run()

Specified by:

run in interface java.lang.Runnable

Specified by:

run in interface javax.jms.Session

See Also:

Session.run()

close

public void close()
           throws javax.jms.JMSException

Specified by:

close in interface javax.jms.Session

Throws:

javax.jms.JMSException

See Also:

Session.close()

createConsumer

public javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination)
                                         throws javax.jms.JMSException

Specified by:

createConsumer in interface javax.jms.Session

Parameters:

destination -

Returns:

a MessageConsumer

Throws:

javax.jms.JMSException

See Also:

Session.createConsumer(javax.jms.Destination)

createConsumer

public javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination,
                                       java.lang.String messageSelector)
                                         throws javax.jms.JMSException

Specified by:

createConsumer in interface javax.jms.Session

Parameters:

destination -

messageSelector -

Returns:

MessageConsumer

Throws:

javax.jms.JMSException

See Also:

Session.createConsumer(javax.jms.Destination, java.lang.String)

createConsumer

public javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination,
                                       java.lang.String messageSelector,
                                       boolean NoLocal)
                                         throws javax.jms.JMSException

Specified by:

createConsumer in interface javax.jms.Session

Parameters:

destination -

messageSelector -

NoLocal -

Returns:

the MessageConsumer

Throws:

javax.jms.JMSException

See Also:

Session.createConsumer(javax.jms.Destination, java.lang.String, boolean)

createReceiver

public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue)
                                       throws javax.jms.JMSException

Specified by:

createReceiver in interface javax.jms.QueueSession

Parameters:

queue -

Returns:

QueueRecevier

Throws:

javax.jms.JMSException

See Also:

QueueSession.createReceiver(javax.jms.Queue)

createReceiver

public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue,
                                     java.lang.String messageSelector)
                                       throws javax.jms.JMSException

Specified by:

createReceiver in interface javax.jms.QueueSession

Parameters:

queue -

messageSelector -

Returns:

QueueReceiver

Throws:

javax.jms.JMSException

See Also:

QueueSession.createReceiver(javax.jms.Queue, java.lang.String)

createBrowser

public javax.jms.QueueBrowser createBrowser(javax.jms.Queue destination)
                                     throws javax.jms.JMSException

Specified by:

createBrowser in interface javax.jms.QueueSession

Specified by:

createBrowser in interface javax.jms.Session

Parameters:

destination -

Returns:

QueueBrowser

Throws:

javax.jms.JMSException

See Also:

Session.createBrowser(javax.jms.Queue)

createBrowser

public javax.jms.QueueBrowser createBrowser(javax.jms.Queue destination,
                                   java.lang.String messageSelector)
                                     throws javax.jms.JMSException

Specified by:

createBrowser in interface javax.jms.QueueSession

Specified by:

createBrowser in interface javax.jms.Session

Parameters:

destination -

messageSelector -

Returns:

QueueBrowser

Throws:

javax.jms.JMSException

See Also:

Session.createBrowser(javax.jms.Queue, java.lang.String)

createSubscriber

public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic)
                                           throws javax.jms.JMSException

Specified by:

createSubscriber in interface javax.jms.TopicSession

Parameters:

topic -

Returns:

TopicSubscriber

Throws:

javax.jms.JMSException

See Also:

TopicSession.createSubscriber(javax.jms.Topic)

createSubscriber

public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic,
                                         java.lang.String messageSelector,
                                         boolean noLocal)
                                           throws javax.jms.JMSException

Specified by:

createSubscriber in interface javax.jms.TopicSession

Parameters:

topic -

messageSelector -

noLocal -

Returns:

TopicSubscriber

Throws:

javax.jms.JMSException

See Also:

TopicSession.createSubscriber(javax.jms.Topic, java.lang.String, boolean)

createDurableSubscriber

public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic,
                                                java.lang.String name)
                                                  throws javax.jms.JMSException

Specified by:

createDurableSubscriber in interface javax.jms.Session

Specified by:

createDurableSubscriber in interface javax.jms.TopicSession

Parameters:

topic -

name -

Returns:

a TopicSubscriber

Throws:

javax.jms.JMSException

See Also:

Session.createDurableSubscriber(javax.jms.Topic, java.lang.String)

createDurableSubscriber

public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic,
                                                java.lang.String name,
                                                java.lang.String messageSelector,
                                                boolean noLocal)
                                                  throws javax.jms.JMSException

Specified by:

createDurableSubscriber in interface javax.jms.Session

Specified by:

createDurableSubscriber in interface javax.jms.TopicSession

Parameters:

topic -

name -

messageSelector -

noLocal -

Returns:

TopicSubscriber

Throws:

javax.jms.JMSException

See Also:

Session.createDurableSubscriber(javax.jms.Topic, java.lang.String, java.lang.String, boolean)

unsubscribe

public void unsubscribe(java.lang.String name)
                 throws javax.jms.JMSException

Specified by:

unsubscribe in interface javax.jms.Session

Specified by:

unsubscribe in interface javax.jms.TopicSession

Parameters:

name -

Throws:

javax.jms.JMSException

See Also:

Session.unsubscribe(java.lang.String)

createProducer

public javax.jms.MessageProducer createProducer(javax.jms.Destination destination)
                                         throws javax.jms.JMSException

Specified by:

createProducer in interface javax.jms.Session

Parameters:

destination -

Returns:

MessageProducer

Throws:

javax.jms.JMSException

See Also:

Session.createProducer(javax.jms.Destination)

createSender

public javax.jms.QueueSender createSender(javax.jms.Queue queue)
                                   throws javax.jms.JMSException

Specified by:

createSender in interface javax.jms.QueueSession

Parameters:

queue -

Returns:

QueueSender

Throws:

javax.jms.JMSException

See Also:

QueueSession.createSender(javax.jms.Queue)

createPublisher

public javax.jms.TopicPublisher createPublisher(javax.jms.Topic topic)
                                         throws javax.jms.JMSException

Specified by:

createPublisher in interface javax.jms.TopicSession

Parameters:

topic -

Returns:

TopicPublisher

Throws:

javax.jms.JMSException

See Also:

TopicSession.createPublisher(javax.jms.Topic)

createBytesMessage

public javax.jms.BytesMessage createBytesMessage()
                                          throws javax.jms.IllegalStateException

Specified by:

createBytesMessage in interface javax.jms.Session

Returns:

BytesMessage

Throws:

javax.jms.IllegalStateException

See Also:

Session.createBytesMessage()

createMapMessage

public javax.jms.MapMessage createMapMessage()
                                      throws javax.jms.IllegalStateException

Specified by:

createMapMessage in interface javax.jms.Session

Returns:

MapMessage

Throws:

javax.jms.IllegalStateException

See Also:

Session.createMapMessage()

createMessage

public javax.jms.Message createMessage()
                                throws javax.jms.IllegalStateException

Specified by:

createMessage in interface javax.jms.Session

Returns:

Message

Throws:

javax.jms.IllegalStateException

See Also:

Session.createMessage()

createObjectMessage

public javax.jms.ObjectMessage createObjectMessage()
                                            throws javax.jms.IllegalStateException

Specified by:

createObjectMessage in interface javax.jms.Session

Returns:

ObjectMessage

Throws:

javax.jms.IllegalStateException

See Also:

Session.createObjectMessage()

createObjectMessage

public javax.jms.ObjectMessage createObjectMessage(java.io.Serializable object)
                                            throws javax.jms.JMSException

Specified by:

createObjectMessage in interface javax.jms.Session

Parameters:

object -

Returns:

ObjectMessage

Throws:

javax.jms.JMSException

See Also:

Session.createObjectMessage(java.io.Serializable)

createStreamMessage

public javax.jms.StreamMessage createStreamMessage()
                                            throws javax.jms.JMSException

Specified by:

createStreamMessage in interface javax.jms.Session

Returns:

StreamMessage

Throws:

javax.jms.JMSException

See Also:

Session.createStreamMessage()

createTextMessage

public javax.jms.TextMessage createTextMessage()
                                        throws javax.jms.JMSException

Specified by:

createTextMessage in interface javax.jms.Session

Returns:

TextMessage

Throws:

javax.jms.JMSException

See Also:

Session.createTextMessage()

createTextMessage

public javax.jms.TextMessage createTextMessage(java.lang.String text)
                                        throws javax.jms.JMSException

Specified by:

createTextMessage in interface javax.jms.Session

Parameters:

text -

Returns:

TextMessage

Throws:

javax.jms.JMSException

See Also:

Session.createTextMessage(java.lang.String)

createQueue

public javax.jms.Queue createQueue(java.lang.String queueName)
                            throws javax.jms.JMSException

Specified by:

createQueue in interface javax.jms.QueueSession

Specified by:

createQueue in interface javax.jms.Session

Parameters:

queueName -

Returns:

Queue

Throws:

javax.jms.JMSException

See Also:

Session.createQueue(java.lang.String)

createTemporaryQueue

public javax.jms.TemporaryQueue createTemporaryQueue()
                                              throws javax.jms.JMSException

Specified by:

createTemporaryQueue in interface javax.jms.QueueSession

Specified by:

createTemporaryQueue in interface javax.jms.Session

Returns:

TemporaryQueue

Throws:

javax.jms.JMSException

See Also:

Session.createTemporaryQueue()

createTemporaryTopic

public javax.jms.TemporaryTopic createTemporaryTopic()
                                              throws javax.jms.JMSException

Specified by:

createTemporaryTopic in interface javax.jms.Session

Specified by:

createTemporaryTopic in interface javax.jms.TopicSession

Returns:

TemporaryTopic

Throws:

javax.jms.JMSException

See Also:

Session.createTemporaryTopic()

createTopic

public javax.jms.Topic createTopic(java.lang.String topicName)
                            throws javax.jms.JMSException

Specified by:

createTopic in interface javax.jms.Session

Specified by:

createTopic in interface javax.jms.TopicSession

Parameters:

topicName -

Returns:

Topic

Throws:

javax.jms.JMSException

See Also:

Session.createTopic(java.lang.String)

add

protected void add(StompJmsMessageConsumer consumer)
            throws javax.jms.JMSException

Throws:

javax.jms.JMSException

remove

protected void remove(StompJmsMessageConsumer consumer)
               throws javax.jms.JMSException

Throws:

javax.jms.JMSException

add

protected void add(javax.jms.MessageProducer producer)

remove

protected void remove(javax.jms.MessageProducer producer)

onException

protected void onException(java.lang.Exception ex)

onException

protected void onException(javax.jms.JMSException ex)

send

protected void send(javax.jms.Destination dest,
        javax.jms.Message msg,
        int deliveryMode,
        int priority,
        long timeToLive,
        boolean disableMsgId)
             throws javax.jms.JMSException

Throws:

javax.jms.JMSException

checkClosed

protected void checkClosed()
                    throws javax.jms.IllegalStateException

Throws:

javax.jms.IllegalStateException

checkSelector

public static java.lang.String checkSelector(java.lang.String selector)
                                      throws javax.jms.InvalidSelectorException

Throws:

javax.jms.InvalidSelectorException

checkDestination

public static void checkDestination(javax.jms.Destination dest)
                             throws javax.jms.InvalidDestinationException

Throws:

javax.jms.InvalidDestinationException

onMessage

public void onMessage(StompJmsMessage message)

Description copied from interface: StompJmsMessageListener

Called when a Message is available to be processes

Specified by:

onMessage in interface StompJmsMessageListener

start

protected void start()
              throws javax.jms.JMSException

Throws:

javax.jms.JMSException

getChannel

protected StompChannel getChannel()
                           throws javax.jms.JMSException

Throws:

javax.jms.JMSException

isForceAsyncSend

public boolean isForceAsyncSend()

setForceAsyncSend

public void setForceAsyncSend(boolean forceAsyncSend)

stop

protected void stop()
             throws javax.jms.JMSException

Throws:

javax.jms.JMSException

isStarted

protected boolean isStarted()

getConnection

public StompJmsConnection getConnection()

getPrefetch

public StompJmsPrefetch getPrefetch()

setPrefetch

public void setPrefetch(StompJmsPrefetch prefetch)