org.jboss.messaging.jms.client
Class JBossConnectionFactory

java.lang.Object
  extended by org.jboss.messaging.jms.client.JBossConnectionFactory
All Implemented Interfaces:
java.io.Serializable, javax.jms.ConnectionFactory, javax.jms.QueueConnectionFactory, javax.jms.TopicConnectionFactory, javax.jms.XAConnectionFactory, javax.jms.XAQueueConnectionFactory, javax.jms.XATopicConnectionFactory

public class JBossConnectionFactory
extends java.lang.Object
implements javax.jms.ConnectionFactory, javax.jms.QueueConnectionFactory, javax.jms.TopicConnectionFactory, javax.jms.XAConnectionFactory, javax.jms.XAQueueConnectionFactory, javax.jms.XATopicConnectionFactory, java.io.Serializable

Version:
$Revision: 4334 $ $Id: JBossConnectionFactory.java 4334 2008-05-29 09:43:53Z timfox $
Author:
Ovidiu Feodorov, Tim Fox
See Also:
Serialized Form

Constructor Summary
JBossConnectionFactory(java.lang.String clientID, int dupsOKBatchSize, Location location, ConnectionParams connectionParams, int defaultConsumerWindowSize, int defaultConsumerMaxRate, int defaultProducerWindowSize, int defaultProducerMaxRate, boolean defaultBlockOnAcknowledge, boolean defaultSendNonPersistentMessagesBlocking, boolean defaultSendPersistentMessagesBlocking)
           
 
Method Summary
 javax.jms.Connection createConnection()
           
 javax.jms.Connection createConnection(java.lang.String username, java.lang.String password)
           
protected  JBossConnection createConnectionInternal(java.lang.String username, java.lang.String password, boolean isXA, int type)
           
 javax.jms.QueueConnection createQueueConnection()
           
 javax.jms.QueueConnection createQueueConnection(java.lang.String username, java.lang.String password)
           
 javax.jms.TopicConnection createTopicConnection()
           
 javax.jms.TopicConnection createTopicConnection(java.lang.String username, java.lang.String password)
           
 javax.jms.XAConnection createXAConnection()
           
 javax.jms.XAConnection createXAConnection(java.lang.String username, java.lang.String password)
           
 javax.jms.XAQueueConnection createXAQueueConnection()
           
 javax.jms.XAQueueConnection createXAQueueConnection(java.lang.String username, java.lang.String password)
           
 javax.jms.XATopicConnection createXATopicConnection()
           
 javax.jms.XATopicConnection createXATopicConnection(java.lang.String username, java.lang.String password)
           
 ClientConnectionFactory getDelegate()
           
 javax.naming.Reference getReference()
           
 java.lang.String toString()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

JBossConnectionFactory

public JBossConnectionFactory(java.lang.String clientID,
                              int dupsOKBatchSize,
                              Location location,
                              ConnectionParams connectionParams,
                              int defaultConsumerWindowSize,
                              int defaultConsumerMaxRate,
                              int defaultProducerWindowSize,
                              int defaultProducerMaxRate,
                              boolean defaultBlockOnAcknowledge,
                              boolean defaultSendNonPersistentMessagesBlocking,
                              boolean defaultSendPersistentMessagesBlocking)
Method Detail

createConnection

public javax.jms.Connection createConnection()
                                      throws javax.jms.JMSException
Specified by:
createConnection in interface javax.jms.ConnectionFactory
Throws:
javax.jms.JMSException

createConnection

public javax.jms.Connection createConnection(java.lang.String username,
                                             java.lang.String password)
                                      throws javax.jms.JMSException
Specified by:
createConnection in interface javax.jms.ConnectionFactory
Throws:
javax.jms.JMSException

createQueueConnection

public javax.jms.QueueConnection createQueueConnection()
                                                throws javax.jms.JMSException
Specified by:
createQueueConnection in interface javax.jms.QueueConnectionFactory
Throws:
javax.jms.JMSException

createQueueConnection

public javax.jms.QueueConnection createQueueConnection(java.lang.String username,
                                                       java.lang.String password)
                                                throws javax.jms.JMSException
Specified by:
createQueueConnection in interface javax.jms.QueueConnectionFactory
Throws:
javax.jms.JMSException

createTopicConnection

public javax.jms.TopicConnection createTopicConnection()
                                                throws javax.jms.JMSException
Specified by:
createTopicConnection in interface javax.jms.TopicConnectionFactory
Throws:
javax.jms.JMSException

createTopicConnection

public javax.jms.TopicConnection createTopicConnection(java.lang.String username,
                                                       java.lang.String password)
                                                throws javax.jms.JMSException
Specified by:
createTopicConnection in interface javax.jms.TopicConnectionFactory
Throws:
javax.jms.JMSException

createXAConnection

public javax.jms.XAConnection createXAConnection()
                                          throws javax.jms.JMSException
Specified by:
createXAConnection in interface javax.jms.XAConnectionFactory
Throws:
javax.jms.JMSException

createXAConnection

public javax.jms.XAConnection createXAConnection(java.lang.String username,
                                                 java.lang.String password)
                                          throws javax.jms.JMSException
Specified by:
createXAConnection in interface javax.jms.XAConnectionFactory
Throws:
javax.jms.JMSException

createXAQueueConnection

public javax.jms.XAQueueConnection createXAQueueConnection()
                                                    throws javax.jms.JMSException
Specified by:
createXAQueueConnection in interface javax.jms.XAQueueConnectionFactory
Throws:
javax.jms.JMSException

createXAQueueConnection

public javax.jms.XAQueueConnection createXAQueueConnection(java.lang.String username,
                                                           java.lang.String password)
                                                    throws javax.jms.JMSException
Specified by:
createXAQueueConnection in interface javax.jms.XAQueueConnectionFactory
Throws:
javax.jms.JMSException

createXATopicConnection

public javax.jms.XATopicConnection createXATopicConnection()
                                                    throws javax.jms.JMSException
Specified by:
createXATopicConnection in interface javax.jms.XATopicConnectionFactory
Throws:
javax.jms.JMSException

createXATopicConnection

public javax.jms.XATopicConnection createXATopicConnection(java.lang.String username,
                                                           java.lang.String password)
                                                    throws javax.jms.JMSException
Specified by:
createXATopicConnection in interface javax.jms.XATopicConnectionFactory
Throws:
javax.jms.JMSException

getReference

public javax.naming.Reference getReference()
                                    throws javax.naming.NamingException
Throws:
javax.naming.NamingException

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object

getDelegate

public ClientConnectionFactory getDelegate()

createConnectionInternal

protected JBossConnection createConnectionInternal(java.lang.String username,
                                                   java.lang.String password,
                                                   boolean isXA,
                                                   int type)
                                            throws javax.jms.JMSException
Throws:
javax.jms.JMSException


Copyright © 2006 JBoss Inc. All Rights Reserved.