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 >> mom4j >> [ jms overview ]  PREV CLASS  NEXT CLASS
SUMMARY: JavaDoc of org.mom4j.jms.SessionImpl JAVADOC | Sourc code of org.mom4j.jms.SessionImpl SOURCE | Download org.mom4j.jms.SessionImpl DOWNLOAD | NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

org.mom4j.jms
Class SessionImpl  view SessionImpl download SessionImpl.java

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

Field Summary
protected  int ackMode
           
protected  ConnectionImpl connection
           
private  java.util.ArrayList consumers
           
protected  boolean isTransacted
           
private  java.util.ArrayList producers
           
private  java.util.WeakHashMap redelivered
           
protected  java.lang.String sessionId
           
private  long tmpCount
           
 
Fields inherited from interface javax.jms.Session
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
 
Constructor Summary
SessionImpl(java.lang.String sessionId, boolean tx, int ackMode, ConnectionImpl c)
          Creates new SessionImpl
 
Method Summary
(package private)  void acknowledge()
           
 void close()
           
(package private)  void closeConsumer(MessageConsumerImpl consumer)
           
(package private)  void closeProducer(javax.jms.MessageProducer producer)
           
 void commit()
           
 javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue)
           
 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)
           
private  MessageConsumerImpl createConsumerInternal(javax.jms.Destination destination, java.lang.String messageSelector, boolean noLocal)
           
(package private)  void createDestination(SessionImpl session, boolean queue, java.lang.String name)
           
 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 selector, boolean noLocal)
           
 javax.jms.MapMessage createMapMessage()
           
 javax.jms.Message createMessage()
           
 javax.jms.ObjectMessage createObjectMessage()
           
 javax.jms.ObjectMessage createObjectMessage(java.io.Serializable s)
           
 javax.jms.MessageProducer createProducer(javax.jms.Destination destination)
           
private  MessageProducerImpl createProducerInternal(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 selector, 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 name)
           
private  void doCommit()
           
 int getAcknowledgeMode()
           
 javax.jms.MessageListener getMessageListener()
           
(package private)  long getPollAsync()
           
(package private)  long getPollSync()
           
 java.lang.String getSessionId()
           
 boolean getTransacted()
           
(package private)  javax.jms.Message receive(java.lang.String destinationName, java.lang.String consumerId)
           
 void recover()
           
(package private)  void register(DestinationImpl dest, java.lang.String consumerId, java.lang.String selector)
           
(package private)  java.lang.String registerDur(DestinationImpl dest, java.lang.String name, java.lang.String consumerId, java.lang.String selector)
           
 void rollback()
           
 void run()
          This method will be called by whoever wishes to run your class implementing Runnable.
(package private)  void send(MessageImpl msg, boolean disableMessageId)
           
 void setMessageListener(javax.jms.MessageListener listener)
           
(package private)  void unregister(DestinationImpl dest, java.lang.String consumerId)
           
(package private)  void unregisterDur(java.lang.String name)
           
 void unsubscribe(java.lang.String name)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

isTransacted

protected boolean isTransacted

ackMode

protected int ackMode

connection

protected ConnectionImpl connection

sessionId

protected java.lang.String sessionId

consumers

private java.util.ArrayList consumers

producers

private java.util.ArrayList producers

redelivered

private java.util.WeakHashMap redelivered

tmpCount

private long tmpCount
Constructor Detail

SessionImpl

public SessionImpl(java.lang.String sessionId,
                   boolean tx,
                   int ackMode,
                   ConnectionImpl c)
Creates new SessionImpl

Method Detail

getSessionId

public java.lang.String getSessionId()

recover

public void recover()
             throws javax.jms.JMSException
Specified by:
recover 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 messageSelector)
                                     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 messageSelector)
                                         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 messageSelector,
                                                boolean noLocal)
                                         throws javax.jms.JMSException
Specified by:
createConsumer in interface javax.jms.Session

createConsumerInternal

private MessageConsumerImpl createConsumerInternal(javax.jms.Destination destination,
                                                   java.lang.String messageSelector,
                                                   boolean noLocal)
                                            throws javax.jms.JMSException

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

createReceiver

public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue)
                                       throws javax.jms.JMSException
Specified by:
createReceiver 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 selector,
                                                  boolean noLocal)
                                           throws javax.jms.JMSException
Specified by:
createSubscriber in interface javax.jms.TopicSession

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

createDurableSubscriber

public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic,
                                                         java.lang.String name,
                                                         java.lang.String selector,
                                                         boolean noLocal)
                                                  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

createProducer

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

createProducerInternal

private MessageProducerImpl createProducerInternal(javax.jms.Destination destination)
                                            throws javax.jms.JMSException

createSender

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

createPublisher

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

createQueue

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

createTemporaryTopic

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

createTemporaryQueue

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

createTopic

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

getMessageListener

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

commit

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

doCommit

private void doCommit()
               throws javax.jms.JMSException

acknowledge

void acknowledge()
           throws javax.jms.JMSException

rollback

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

createObjectMessage

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

createTextMessage

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

createObjectMessage

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

close

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

closeConsumer

void closeConsumer(MessageConsumerImpl consumer)
             throws javax.jms.JMSException

closeProducer

void closeProducer(javax.jms.MessageProducer producer)

createTextMessage

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

setMessageListener

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

createStreamMessage

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

createMessage

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

getTransacted

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

getAcknowledgeMode

public int getAcknowledgeMode()
                       throws javax.jms.JMSException
Specified by:
getAcknowledgeMode 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

unsubscribe

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

getPollSync

long getPollSync()

getPollAsync

long getPollAsync()

register

void register(DestinationImpl dest,
              java.lang.String consumerId,
              java.lang.String selector)
        throws javax.jms.JMSException

registerDur

java.lang.String registerDur(DestinationImpl dest,
                             java.lang.String name,
                             java.lang.String consumerId,
                             java.lang.String selector)
                       throws javax.jms.JMSException

unregister

void unregister(DestinationImpl dest,
                java.lang.String consumerId)
          throws javax.jms.JMSException

unregisterDur

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

send

void send(MessageImpl msg,
          boolean disableMessageId)
    throws javax.jms.JMSException

createDestination

void createDestination(SessionImpl session,
                       boolean queue,
                       java.lang.String name)
                 throws javax.jms.JMSException

receive

javax.jms.Message receive(java.lang.String destinationName,
                          java.lang.String consumerId)
                    throws javax.jms.JMSException
Overview  Package   Class  Use  Deprecated  Index 
Home >> All >> org >> mom4j >> [ jms overview ]  PREV CLASS  NEXT CLASS
SUMMARY: JavaDoc of org.mom4j.jms.SessionImpl JAVADOC | Sourc code of org.mom4j.jms.SessionImpl SOURCE | Download org.mom4j.jms.SessionImpl DOWNLOAD | NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD