xmlBlaster 2.1.0 API

org.xmlBlaster.jms
Class XBConnectionFactory

java.lang.Object
  extended by org.xmlBlaster.jms.XBConnectionFactory
All Implemented Interfaces:
java.io.Externalizable, java.io.Serializable, javax.jms.ConnectionFactory, javax.jms.QueueConnectionFactory, javax.jms.TopicConnectionFactory, javax.naming.Referenceable

public class XBConnectionFactory
extends java.lang.Object
implements javax.jms.TopicConnectionFactory, java.io.Externalizable, javax.naming.Referenceable, javax.jms.QueueConnectionFactory

XBConnectionFactory

Author:
Michele Laghi
See Also:
Serialized Form

Field Summary
(package private)  java.lang.String[] args
          the arguments passed on construction: they should never be null
(package private)  ConnectQos connectQos
           
private  javax.jms.ExceptionListener exceptionListener
           
(package private)  boolean forQueues
           
private  Global global
           
private static java.lang.String ME
           
private  javax.jms.ConnectionMetaData metaData
           
private static long SER_VERSION
           
 
Constructor Summary
XBConnectionFactory()
           
XBConnectionFactory(java.lang.String connectQosLitteral, java.lang.String[] args, boolean forQueues)
          Creates a factory for creating connections
 
Method Summary
 javax.jms.Connection createConnection()
           
 javax.jms.Connection createConnection(java.lang.String userName, java.lang.String password)
           
 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)
           
 ConnectQos getConnectQos()
           
private  ConnectQos getConnectQos(java.lang.String user, java.lang.String password)
          Takes a clone of the connectQos and fills it with the security data if necessary
 javax.naming.Reference getReference()
           
private  ConnectQos parseConnectQos(java.lang.String qosLitteral)
           
 void readExternal(java.io.ObjectInput oi)
           
 void writeExternal(java.io.ObjectOutput oo)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

ME

private static final java.lang.String ME
See Also:
Constant Field Values

SER_VERSION

private static final long SER_VERSION
See Also:
Constant Field Values

global

private Global global

metaData

private javax.jms.ConnectionMetaData metaData

exceptionListener

private javax.jms.ExceptionListener exceptionListener

args

java.lang.String[] args
the arguments passed on construction: they should never be null


connectQos

ConnectQos connectQos

forQueues

boolean forQueues
Constructor Detail

XBConnectionFactory

public XBConnectionFactory(java.lang.String connectQosLitteral,
                           java.lang.String[] args,
                           boolean forQueues)
                    throws XmlBlasterException
Creates a factory for creating connections

Parameters:
connectQosLitteral - the string qos to use for creation of sessions it can be null. If it is set, then the arguments passed are overwritten when it comes to the creation of the connectQos.
args - the arguments to pass to construct the global object.
Throws:
XmlBlasterException

XBConnectionFactory

public XBConnectionFactory()
                    throws XmlBlasterException
Throws:
XmlBlasterException
Method Detail

parseConnectQos

private ConnectQos parseConnectQos(java.lang.String qosLitteral)
                            throws XmlBlasterException
Throws:
XmlBlasterException

getConnectQos

public ConnectQos getConnectQos()

getConnectQos

private final ConnectQos getConnectQos(java.lang.String user,
                                       java.lang.String password)
                                throws XmlBlasterException
Takes a clone of the connectQos and fills it with the security data if necessary

Parameters:
user -
password -
Returns:
Throws:
XmlBlasterException

createConnection

public javax.jms.Connection createConnection()
                                      throws javax.jms.JMSException
Specified by:
createConnection in interface javax.jms.ConnectionFactory
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

createQueueConnection

public javax.jms.QueueConnection createQueueConnection()
                                                throws javax.jms.JMSException
Specified by:
createQueueConnection in interface javax.jms.QueueConnectionFactory
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

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

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

getReference

public javax.naming.Reference getReference()
Specified by:
getReference in interface javax.naming.Referenceable

readExternal

public void readExternal(java.io.ObjectInput oi)
                  throws java.io.IOException,
                         java.lang.ClassNotFoundException
Specified by:
readExternal in interface java.io.Externalizable
Throws:
java.io.IOException
java.lang.ClassNotFoundException

writeExternal

public void writeExternal(java.io.ObjectOutput oo)
                   throws java.io.IOException
Specified by:
writeExternal in interface java.io.Externalizable
Throws:
java.io.IOException

xmlBlaster 2.1.0 API

Copyright © 1999-2011 The xmlBlaster.org contributers.