org.xmlBlaster.jms
Class XBConnectionFactory

java.lang.Object
  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