Overview  Package   Class  Use  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

org.fusesource.stompjms
Class StompJmsSession

java.lang.Object
  extended by org.fusesource.stompjms.StompJmsSession
All Implemented Interfaces:
java.lang.Runnable, javax.jms.QueueSession, javax.jms.Session, javax.jms.TopicSession, StompJmsMessageListener
Direct Known Subclasses:
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
protected StompJmsSession(StompJmsConnection connection, StompChannel channel, int acknowledgementMode)
          Constructor
 
Method Summary
protected  void add(javax.jms.MessageProducer producer)
           
protected  void add(StompJmsMessageConsumer consumer, boolean persistent, boolean browser)
           
protected  void checkClosed()
           
 void close()
           
 void commit()
           
 javax.jms.QueueBrowser createBrowser(javax.jms.Queue destination)
           
 javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue, 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()
           
protected  StompJmsConnection getConnection()
           
 javax.jms.MessageListener getMessageListener()
           
 boolean getTransacted()
           
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)
           
 void setMessageListener(javax.jms.MessageListener listener)
           
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,
                          StompChannel channel,
                          int acknowledgementMode)
Constructor

Parameters:
connection -
acknowledgementMode -
Method Detail

close

public void close()
           throws javax.jms.JMSException
Specified by:
close in interface javax.jms.Session
Throws:
javax.jms.JMSException
See Also:
Session.close()

commit

public void commit()
            throws javax.jms.JMSException
Specified by:
commit in interface javax.jms.Session
Throws:
javax.jms.JMSException
See Also:
Session.commit()

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 queue,
                                            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:
queue -
messageSelector -
Returns:
QueueBrowser
Throws:
javax.jms.JMSException
See Also:
Session.createBrowser(javax.jms.Queue, java.lang.String)

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

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)

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)

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)

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)

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)

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

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

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)

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)

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

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

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

recover

public void recover()
             throws javax.jms.JMSException
Specified by:
recover in interface javax.jms.Session
Throws:
javax.jms.JMSException
See Also:
Session.recover()

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

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)

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)

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)

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)

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)

add

protected void add(StompJmsMessageConsumer consumer,
                   boolean persistent,
                   boolean browser)
            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)
             throws javax.jms.JMSException
Throws:
javax.jms.JMSException

checkClosed

protected void checkClosed()
                    throws javax.jms.IllegalStateException
Throws:
javax.jms.IllegalStateException

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

stop

protected void stop()
             throws javax.jms.JMSException
Throws:
javax.jms.JMSException

isStarted

protected boolean isStarted()

getChannel

protected StompChannel getChannel()

getConnection

protected StompJmsConnection getConnection()
Overview  Package   Class  Use  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD
Copyright © 2010-2011 FuseSource, Corp.. All Rights Reserved.