Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep
Overview  Package   Class  Use  Deprecated  Index 
Home >> All >> org >> activemq >> ra >> [ jms overview ]  PREV CLASS  NEXT CLASS
SUMMARY: JavaDoc of org.activemq.ra.jms.SessionProxy JAVADOC | Sourc code of org.activemq.ra.jms.SessionProxy SOURCE | Download org.activemq.ra.jms.SessionProxy DOWNLOAD | NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

org.activemq.ra.jms
Class SessionProxy  view SessionProxy download SessionProxy.java

java.lang.Object
  extended byorg.activemq.ra.jms.SessionProxy
All Implemented Interfaces:
javax.jms.QueueSession, java.lang.Runnable, javax.jms.Session, javax.jms.TopicSession
public class SessionProxy
extends java.lang.Object
implements javax.jms.Session, javax.jms.QueueSession, javax.jms.TopicSession

A javax.jms.Session implementation which can be used with the ActiveMQ JCA Resource Adapter to publish messages using the same JMS session that is used to dispatch messages.

Version:
$Revision: 1.1.1.1 $

Field Summary
private  org.activemq.ra.SessionAndProducer sessionAndProducer
           
 
Fields inherited from interface javax.jms.Session
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
 
Constructor Summary
SessionProxy()
           
 
Method Summary
 void close()
           
 void commit()
           
 javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue)
           
 javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue, java.lang.String s)
           
 javax.jms.BytesMessage createBytesMessage()
           
 javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination)
           
 javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination, java.lang.String s)
           
 javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination, java.lang.String s, boolean b)
           
 javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic, java.lang.String s)
           
 javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic, java.lang.String s, java.lang.String s1, boolean b)
           
 javax.jms.MapMessage createMapMessage()
           
 javax.jms.Message createMessage()
           
 javax.jms.ObjectMessage createObjectMessage()
           
 javax.jms.ObjectMessage createObjectMessage(java.io.Serializable serializable)
           
 javax.jms.MessageProducer createProducer(javax.jms.Destination destination)
           
 javax.jms.TopicPublisher createPublisher(javax.jms.Topic topic)
           
 javax.jms.Queue createQueue(java.lang.String s)
           
 javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue)
           
 javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue, java.lang.String s)
           
 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 s, boolean b)
           
 javax.jms.TemporaryQueue createTemporaryQueue()
           
 javax.jms.TemporaryTopic createTemporaryTopic()
           
 javax.jms.TextMessage createTextMessage()
           
 javax.jms.TextMessage createTextMessage(java.lang.String s)
           
 javax.jms.Topic createTopic(java.lang.String s)
           
 int getAcknowledgeMode()
           
 javax.jms.MessageListener getMessageListener()
           
 javax.jms.QueueSession getQueueSession()
           
 javax.jms.Session getSession()
           
 org.activemq.ra.SessionAndProducer getSessionAndProducer()
           
 javax.jms.TopicSession getTopicSession()
           
 boolean getTransacted()
           
 void recover()
           
 void rollback()
           
 void run()
          This method will be called by whoever wishes to run your class implementing Runnable.
 void setMessageListener(javax.jms.MessageListener messageListener)
           
 void unsubscribe(java.lang.String s)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

sessionAndProducer

private org.activemq.ra.SessionAndProducer sessionAndProducer
Constructor Detail

SessionProxy

public SessionProxy()
Method Detail

getSession

public javax.jms.Session getSession()
                             throws javax.jms.JMSException

getQueueSession

public javax.jms.QueueSession getQueueSession()
                                       throws javax.jms.JMSException

getTopicSession

public javax.jms.TopicSession getTopicSession()
                                       throws javax.jms.JMSException

getSessionAndProducer

public org.activemq.ra.SessionAndProducer getSessionAndProducer()
                                                         throws javax.jms.JMSException

createProducer

public javax.jms.MessageProducer createProducer(javax.jms.Destination destination)
                                         throws javax.jms.JMSException
Specified by:
createProducer in interface javax.jms.Session

close

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

commit

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

rollback

public void rollback()
              throws javax.jms.JMSException
Specified by:
rollback in interface javax.jms.Session

recover

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

run

public void run()
Description copied from interface: java.lang.Runnable
This method will be called by whoever wishes to run your class implementing Runnable. Note that there are no restrictions on what you are allowed to do in the run method, except that you cannot throw a checked exception.

Specified by:
run in interface javax.jms.Session

createBrowser

public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue)
                                     throws javax.jms.JMSException
Specified by:
createBrowser in interface javax.jms.Session

createBrowser

public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue,
                                            java.lang.String s)
                                     throws javax.jms.JMSException
Specified by:
createBrowser in interface javax.jms.Session

createBytesMessage

public javax.jms.BytesMessage createBytesMessage()
                                          throws javax.jms.JMSException
Specified by:
createBytesMessage in interface javax.jms.Session

createConsumer

public javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination)
                                         throws javax.jms.JMSException
Specified by:
createConsumer in interface javax.jms.Session

createConsumer

public javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination,
                                                java.lang.String s)
                                         throws javax.jms.JMSException
Specified by:
createConsumer in interface javax.jms.Session

createConsumer

public javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination,
                                                java.lang.String s,
                                                boolean b)
                                         throws javax.jms.JMSException
Specified by:
createConsumer in interface javax.jms.Session

createDurableSubscriber

public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic,
                                                         java.lang.String s)
                                                  throws javax.jms.JMSException
Specified by:
createDurableSubscriber in interface javax.jms.Session

createDurableSubscriber

public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic,
                                                         java.lang.String s,
                                                         java.lang.String s1,
                                                         boolean b)
                                                  throws javax.jms.JMSException
Specified by:
createDurableSubscriber in interface javax.jms.Session

createMapMessage

public javax.jms.MapMessage createMapMessage()
                                      throws javax.jms.JMSException
Specified by:
createMapMessage in interface javax.jms.Session

createMessage

public javax.jms.Message createMessage()
                                throws javax.jms.JMSException
Specified by:
createMessage in interface javax.jms.Session

createObjectMessage

public javax.jms.ObjectMessage createObjectMessage()
                                            throws javax.jms.JMSException
Specified by:
createObjectMessage in interface javax.jms.Session

createObjectMessage

public javax.jms.ObjectMessage createObjectMessage(java.io.Serializable serializable)
                                            throws javax.jms.JMSException
Specified by:
createObjectMessage in interface javax.jms.Session

createQueue

public javax.jms.Queue createQueue(java.lang.String s)
                            throws javax.jms.JMSException
Specified by:
createQueue in interface javax.jms.Session

createStreamMessage

public javax.jms.StreamMessage createStreamMessage()
                                            throws javax.jms.JMSException
Specified by:
createStreamMessage in interface javax.jms.Session

createTemporaryQueue

public javax.jms.TemporaryQueue createTemporaryQueue()
                                              throws javax.jms.JMSException
Specified by:
createTemporaryQueue in interface javax.jms.Session

createTemporaryTopic

public javax.jms.TemporaryTopic createTemporaryTopic()
                                              throws javax.jms.JMSException
Specified by:
createTemporaryTopic in interface javax.jms.Session

createTextMessage

public javax.jms.TextMessage createTextMessage()
                                        throws javax.jms.JMSException
Specified by:
createTextMessage in interface javax.jms.Session

createTextMessage

public javax.jms.TextMessage createTextMessage(java.lang.String s)
                                        throws javax.jms.JMSException
Specified by:
createTextMessage in interface javax.jms.Session

createTopic

public javax.jms.Topic createTopic(java.lang.String s)
                            throws javax.jms.JMSException
Specified by:
createTopic in interface javax.jms.Session

getAcknowledgeMode

public int getAcknowledgeMode()
                       throws javax.jms.JMSException
Specified by:
getAcknowledgeMode in interface javax.jms.Session

getMessageListener

public javax.jms.MessageListener getMessageListener()
                                             throws javax.jms.JMSException
Specified by:
getMessageListener in interface javax.jms.Session

getTransacted

public boolean getTransacted()
                      throws javax.jms.JMSException
Specified by:
getTransacted in interface javax.jms.Session

setMessageListener

public void setMessageListener(javax.jms.MessageListener messageListener)
                        throws javax.jms.JMSException
Specified by:
setMessageListener in interface javax.jms.Session

unsubscribe

public void unsubscribe(java.lang.String s)
                 throws javax.jms.JMSException
Specified by:
unsubscribe in interface javax.jms.Session

createReceiver

public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue)
                                       throws javax.jms.JMSException
Specified by:
createReceiver in interface javax.jms.QueueSession

createReceiver

public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue,
                                              java.lang.String s)
                                       throws javax.jms.JMSException
Specified by:
createReceiver in interface javax.jms.QueueSession

createSender

public javax.jms.QueueSender createSender(javax.jms.Queue queue)
                                   throws javax.jms.JMSException
Specified by:
createSender in interface javax.jms.QueueSession

createSubscriber

public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic)
                                           throws javax.jms.JMSException
Specified by:
createSubscriber in interface javax.jms.TopicSession

createSubscriber

public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic,
                                                  java.lang.String s,
                                                  boolean b)
                                           throws javax.jms.JMSException
Specified by:
createSubscriber in interface javax.jms.TopicSession

createPublisher

public javax.jms.TopicPublisher createPublisher(javax.jms.Topic topic)
                                         throws javax.jms.JMSException
Specified by:
createPublisher in interface javax.jms.TopicSession
Overview  Package   Class  Use  Deprecated  Index 
Home >> All >> org >> activemq >> ra >> [ jms overview ]  PREV CLASS  NEXT CLASS
SUMMARY: JavaDoc of org.activemq.ra.jms.SessionProxy JAVADOC | Sourc code of org.activemq.ra.jms.SessionProxy SOURCE | Download org.activemq.ra.jms.SessionProxy DOWNLOAD | NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD