com.lightstreamer.jms

Class LSQueueConnectionFactory

java.lang.Object

com.lightstreamer.jms.LSConnectionFactory

com.lightstreamer.jms.LSQueueConnectionFactory

All Implemented Interfaces:

ConnectionFactory, QueueConnectionFactory

public class LSQueueConnectionFactory
extends LSConnectionFactory
implements QueueConnectionFactory

A QueueConnectionFactory interface implementation that can be used used to create a queue connection with a JMS broker through an embedded JMS Extender client connection.

Constructor Summary

Constructors

Constructor and Description
LSQueueConnectionFactory() Creates an LSQueueConnectionFactory object that can create new QueueConnection objects.
LSQueueConnectionFactory(java.lang.String serverAddress, java.lang.String jmsConnector) Creates an LSQueueConnectionFactory object that can create new QueueConnection objects.
LSQueueConnectionFactory(java.lang.String serverAddress, java.lang.String adapterSet, java.lang.String jmsConnector) Creates an LSQueueConnectionFactory object that can create new QueueConnection objects.

Method Summary

Modifier and Type	Method and Description
QueueConnection	createQueueConnection() Creates a new QueueConnection with an unspecified user identity.
QueueConnection	createQueueConnection(java.lang.String userName, java.lang.String password) Creates a new QueueConnection using the specified user name and password.

Methods inherited from class com.lightstreamer.jms.LSConnectionFactory

createConnection, createConnection, createContext, createContext, createContext, createContext, getAdapterSet, getConnectionListener, getJmsConnector, getServerAddress, setAdapterSet, setConnectionListener, setJmsConnector, setServerAddress

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface javax.jms.ConnectionFactory

createConnection, createConnection, createContext, createContext, createContext, createContext

Constructor Detail

LSQueueConnectionFactory

public LSQueueConnectionFactory()

Creates an LSQueueConnectionFactory object that can create new QueueConnection objects.

Uses the default adapter set name JMS, but leaves empty both the JMS connector name and the server address (to be specified later).

LSQueueConnectionFactory

public LSQueueConnectionFactory(java.lang.String serverAddress,
                                java.lang.String jmsConnector)

Creates an LSQueueConnectionFactory object that can create new QueueConnection objects.

Uses the default adapter set name JMS and the specified JMS connector name and server address.

Parameters:

serverAddress - the URL of the JMS Extender to connect to

jmsConnector - the name of the JMS connector to use

LSQueueConnectionFactory

public LSQueueConnectionFactory(java.lang.String serverAddress,
                                java.lang.String adapterSet,
                                java.lang.String jmsConnector)

Creates an LSQueueConnectionFactory object that can create new QueueConnection objects.

Uses the specified adapter set name, JMS connector name and server address.

Parameters:

serverAddress - the URL of the JMS Extender to connect to

adapterSet - the name of the adapter set to use

jmsConnector - the name of the JMS connector to use

Method Detail

createQueueConnection

public QueueConnection createQueueConnection()
                                      throws JMSException

Creates a new QueueConnection with an unspecified user identity.

The connection is created in stopped mode. No messages will be delivered until the Connection.start() method is explicitly called on the QueueConnection object.

If a LSConnectionListener implementation has been set, its events will be called during connection creation.

Specified by:

createQueueConnection in interface QueueConnectionFactory

Returns:

the created QueueConnection

Throws:

JMSException - if the connection creation fails for some reason

createQueueConnection

public QueueConnection createQueueConnection(java.lang.String userName,
                                             java.lang.String password)
                                      throws JMSException

Creates a new QueueConnection using the specified user name and password.

The connection is created in stopped mode. No messages will be delivered until the Connection.start() method is explicitly called on the QueueConnection object.

If a LSConnectionListener implementation has been set, its events will be called during connection creation.

Specified by:

createQueueConnection in interface QueueConnectionFactory

Parameters:

userName - the user's name

password - the user's password

Returns:

the created javax.jms.QueueConnection

Throws:

JMSException - if the connection creation fails for some reason