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.ConnectionImpl JAVADOC | Sourc code of org.mom4j.jms.ConnectionImpl SOURCE | Download org.mom4j.jms.ConnectionImpl DOWNLOAD | NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

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

java.lang.Object
  extended byorg.mom4j.jms.ConnectionImpl
All Implemented Interfaces:
javax.jms.Connection, javax.jms.QueueConnection, javax.jms.TopicConnection
public class ConnectionImpl
extends java.lang.Object
implements javax.jms.Connection, javax.jms.TopicConnection, javax.jms.QueueConnection

Field Summary
private  java.lang.String clientId
           
private  boolean closed
           
private static long connectionCount
           
private  javax.jms.ExceptionListener exceptionListener
           
private  java.lang.String hostname
           
private static java.lang.String ID_SUFFIX
           
private static javax.jms.ConnectionMetaData metaData
           
private  long msgCount
           
private  long pollAsync
           
private  long pollSync
           
private  int port
           
private static java.util.Random random
           
protected  org.mom4j.xcp.XcpSender sender
           
private  long sessionCount
           
protected  java.util.Map sessions
           
private  boolean started
           
 
Constructor Summary
ConnectionImpl(java.lang.String hostname, int port, java.lang.String username, java.lang.String password, long pollSync, long pollAsync)
           
 
Method Summary
 void close()
           
(package private)  void closeSession(SessionImpl session)
           
(package private)  void commit(SessionImpl session)
           
 javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Destination dest, java.lang.String messageSelector, javax.jms.ServerSessionPool pool, int maxMessages)
           
 javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Queue queue, java.lang.String messageSelector, javax.jms.ServerSessionPool pool, int maxMessages)
           
 javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Topic topic, java.lang.String messageSelector, javax.jms.ServerSessionPool pool, int maxMessages)
           
(package private)  void createDestination(SessionImpl session, boolean queue, java.lang.String name)
           
 javax.jms.ConnectionConsumer createDurableConnectionConsumer(javax.jms.Topic topic, java.lang.String messageSelector, java.lang.String subscriptionName, javax.jms.ServerSessionPool pool, int maxMessages)
           
 javax.jms.QueueSession createQueueSession(boolean transacted, int acknowledgeMode)
           
 javax.jms.Session createSession(boolean transacted, int acknowledgeMode)
           
private  SessionImpl createSessionInternal(boolean transacted, int acknowledgeMode)
           
 javax.jms.TopicSession createTopicSession(boolean transacted, int acknowledgeMode)
           
 java.lang.String getClientID()
           
 javax.jms.ExceptionListener getExceptionListener()
           
 javax.jms.ConnectionMetaData getMetaData()
           
(package private)  long getPollAsync()
           
(package private)  long getPollSync()
           
private  java.lang.String nextMsgId()
           
(package private)  javax.jms.Message receive(SessionImpl session, java.lang.String destinationName, java.lang.String consumerId)
           
(package private)  void register(DestinationImpl dest, java.lang.String consumerId, java.lang.String messageSelector)
           
(package private)  java.lang.String registerDur(DestinationImpl dest, java.lang.String name, java.lang.String consumerId, java.lang.String messageSelector)
           
(package private)  void rollback(SessionImpl session)
           
(package private)  void send(SessionImpl session, MessageImpl msg, boolean disableMessageId)
           
 void setClientID(java.lang.String id)
           
 void setExceptionListener(javax.jms.ExceptionListener listener)
           
 void start()
           
 void stop()
           
(package private)  void unregister(DestinationImpl dest, java.lang.String consumerId)
           
(package private)  void unregisterDur(java.lang.String sessionId, java.lang.String name)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

metaData

private static javax.jms.ConnectionMetaData metaData

ID_SUFFIX

private static java.lang.String ID_SUFFIX

connectionCount

private static long connectionCount

random

private static java.util.Random random

exceptionListener

private javax.jms.ExceptionListener exceptionListener

hostname

private java.lang.String hostname

clientId

private java.lang.String clientId

started

private boolean started

closed

private boolean closed

port

private int port

sessionCount

private long sessionCount

msgCount

private long msgCount

pollSync

private long pollSync

pollAsync

private long pollAsync

sessions

protected java.util.Map sessions

sender

protected org.mom4j.xcp.XcpSender sender
Constructor Detail

ConnectionImpl

public ConnectionImpl(java.lang.String hostname,
                      int port,
                      java.lang.String username,
                      java.lang.String password,
                      long pollSync,
                      long pollAsync)
               throws javax.jms.JMSException
Method Detail

getClientID

public java.lang.String getClientID()
                             throws javax.jms.JMSException
Specified by:
getClientID in interface javax.jms.Connection

start

public void start()
           throws javax.jms.JMSException
Specified by:
start in interface javax.jms.Connection

stop

public void stop()
          throws javax.jms.JMSException
Specified by:
stop in interface javax.jms.Connection

setExceptionListener

public void setExceptionListener(javax.jms.ExceptionListener listener)
                          throws javax.jms.JMSException
Specified by:
setExceptionListener in interface javax.jms.Connection

setClientID

public void setClientID(java.lang.String id)
                 throws javax.jms.JMSException
Specified by:
setClientID in interface javax.jms.Connection

close

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

getMetaData

public javax.jms.ConnectionMetaData getMetaData()
                                         throws javax.jms.JMSException
Specified by:
getMetaData in interface javax.jms.Connection

getExceptionListener

public javax.jms.ExceptionListener getExceptionListener()
                                                 throws javax.jms.JMSException
Specified by:
getExceptionListener in interface javax.jms.Connection

createConnectionConsumer

public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Destination dest,
                                                             java.lang.String messageSelector,
                                                             javax.jms.ServerSessionPool pool,
                                                             int maxMessages)
                                                      throws javax.jms.JMSException
Specified by:
createConnectionConsumer in interface javax.jms.Connection

createSession

public javax.jms.Session createSession(boolean transacted,
                                       int acknowledgeMode)
                                throws javax.jms.JMSException
Specified by:
createSession in interface javax.jms.Connection

createSessionInternal

private SessionImpl createSessionInternal(boolean transacted,
                                          int acknowledgeMode)
                                   throws javax.jms.JMSException

createTopicSession

public javax.jms.TopicSession createTopicSession(boolean transacted,
                                                 int acknowledgeMode)
                                          throws javax.jms.JMSException
Specified by:
createTopicSession in interface javax.jms.TopicConnection

createConnectionConsumer

public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Topic topic,
                                                             java.lang.String messageSelector,
                                                             javax.jms.ServerSessionPool pool,
                                                             int maxMessages)
                                                      throws javax.jms.JMSException
Specified by:
createConnectionConsumer in interface javax.jms.TopicConnection

createDurableConnectionConsumer

public javax.jms.ConnectionConsumer createDurableConnectionConsumer(javax.jms.Topic topic,
                                                                    java.lang.String messageSelector,
                                                                    java.lang.String subscriptionName,
                                                                    javax.jms.ServerSessionPool pool,
                                                                    int maxMessages)
                                                             throws javax.jms.JMSException
Specified by:
createDurableConnectionConsumer in interface javax.jms.Connection

createQueueSession

public javax.jms.QueueSession createQueueSession(boolean transacted,
                                                 int acknowledgeMode)
                                          throws javax.jms.JMSException
Specified by:
createQueueSession in interface javax.jms.QueueConnection

createConnectionConsumer

public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Queue queue,
                                                             java.lang.String messageSelector,
                                                             javax.jms.ServerSessionPool pool,
                                                             int maxMessages)
                                                      throws javax.jms.JMSException
Specified by:
createConnectionConsumer in interface javax.jms.QueueConnection

nextMsgId

private java.lang.String nextMsgId()

getPollSync

long getPollSync()

getPollAsync

long getPollAsync()

register

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

registerDur

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

unregister

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

unregisterDur

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

createDestination

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

send

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

receive

javax.jms.Message receive(SessionImpl session,
                          java.lang.String destinationName,
                          java.lang.String consumerId)
                    throws javax.jms.JMSException

commit

void commit(SessionImpl session)
      throws javax.jms.JMSException

rollback

void rollback(SessionImpl session)
        throws javax.jms.JMSException

closeSession

void closeSession(SessionImpl session)
            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.ConnectionImpl JAVADOC | Sourc code of org.mom4j.jms.ConnectionImpl SOURCE | Download org.mom4j.jms.ConnectionImpl DOWNLOAD | NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD