progress.message.jclient.mp
Class QueueConnectionFactory

java.lang.Object
  progress.message.jclient.mp.ConnectionFactory
      progress.message.jclient.mp.QueueConnectionFactory

All Implemented Interfaces:

java.io.Serializable, ConnectionFactory, QueueConnectionFactory, javax.naming.Referenceable, javax.naming.spi.ObjectFactory

public class QueueConnectionFactory
extends ConnectionFactory
implements QueueConnectionFactory, java.io.Serializable, javax.naming.Referenceable, javax.naming.spi.ObjectFactory

Title: SonicMQ Adaptive Pacing (Managed Client Queue Connection Factory)

Description: An implementation of a Managed JMS QueueConnectionFactory. A client uses a QueueConnectionFactory object to create QueueConnection objects with a point-to-point JMS provider. QueueConnectionFactory can be used to create a QueueConnection, from which specialized queue-related objects can be created. A more general, and recommended, approach is to use the ConnectionFactory The QueueConnectionFactory object can be used to support existing code that already uses it.

See ConnectionFactory class documentation for additional functionality details and specific behavior of Managed Client Adaptive Pacing.

Copyright: Copyright (c) 2006

Company: Progress Software

Version:

2.2

Author:

Dmitry Lelchuk

See Also:

Serialized Form

Constructor Summary

QueueConnectionFactory()

QueueConnectionFactory(java.lang.String brokerURL)

QueueConnectionFactory(java.lang.String brokerHostName, int brokerPort, java.lang.String brokerProtocol, java.lang.String defaultUserName, java.lang.String defaultPassword)

QueueConnectionFactory(java.lang.String brokerHostName, int brokerPort, java.lang.String brokerProtocol, java.lang.String connectID, java.lang.String defaultUserName, java.lang.String defaultPassword)

QueueConnectionFactory(java.lang.String brokerURL, java.lang.String connectID)

QueueConnectionFactory(java.lang.String brokerURL, java.lang.String defaultUserName, java.lang.String defaultPassword)

QueueConnectionFactory(java.lang.String brokerURL, java.lang.String connectID, java.lang.String defaultUserName, java.lang.String defaultPassword)

Method Summary

QueueConnection	createQueueConnection() The method creates a new Queue Connection with default user identity.
QueueConnection	createQueueConnection(java.lang.String userid, java.lang.String password) The method creates a new Queue Connection with the specified user identity.
javax.naming.Reference	getReference()

Methods inherited from class progress.message.jclient.mp.ConnectionFactory

createConnection, createConnection, getAdaptivePacing, getAdaptivePacingBatchSize, getAdaptivePacingBatchSizeInteger, getAdaptivePacingBoolean, getAdaptivePacingTimer, getAdaptivePacingTimerInteger, getApplet, getBrokerHostName, getBrokerPort, getBrokerProtocol, getBrokerURL, getClientID, getClientTransactionBufferSize, getConnectID, getConnectionURLs, getDefaultPassword, getDefaultTxnBatchSize, getDefaultTxnBatchSizeInteger, getDefaultUser, getDurableMessageOrder, getFaultTolerant, getFaultTolerantReconnectTimeout, getFlowToDisk, getInitialConnectTimeout, getLoadBalancing, getLoadBalancingBoolean, getLocalStoreDirectory, getLocalStoreSize, getLocalStoreSizeLong, getLocalStoreWaitTime, getLoginSPI, getMaxDeliveryCount, getMonitorInterval, getObjectInstance, getPersistentDelivery, getPersistentDeliveryBoolean, getPingInterval, getPingIntervalLong, getPrefetchCount, getPrefetchCountInteger, getPrefetchThreshold, getPrefetchThresholdInteger, getQopCacheSize, getReconnectInterval, getReconnectIntervalInteger, getReconnectTimeout, getReconnectTimeoutInteger, getSelectorAtBroker, getSequential, getSequentialBoolean, getSocketConnectTimeout, getSplitMultiTopicDelivery, getUrlsOrUrl, isEnableLocalStore, isEnableLocalStoreBoolean, setAdaptivePacing, setAdaptivePacingBatchSize, setAdaptivePacingTimer, setApplet, setBrokerHostName, setBrokerPort, setBrokerProtocol, setBrokerURL, setClientID, setClientTransactionBufferSize, setConnectID, setConnectionURLs, setDefaultPassword, setDefaultTxnBatchSize, setDefaultTxnBatchSizeInteger, setDefaultUser, setDurableMessageOrder, setEnableLocalStore, setEnableLocalStoreBoolean, setFaultTolerant, setFaultTolerantReconnectTimeout, setFlowToDisk, setInitialConnectTimeout, setLoadBalancing, setLoadBalancingBoolean, setLocalStoreDirectory, setLocalStoreSize, setLocalStoreSizeLong, setLocalStoreWaitTime, setLoginSPI, setMaxDeliveryCount, setMonitorInterval, setPersistentDelivery, setPersistentDeliveryBoolean, setPingInterval, setPingIntervalLong, setPrefetchCount, setPrefetchCountInteger, setPrefetchThreshold, setPrefetchThresholdInteger, setQopCacheSize, setReconnectInterval, setReconnectIntervalInteger, setReconnectTimeout, setReconnectTimeoutInteger, setSelectorAtBroker, setSequential, setSequentialBoolean, setSocketConnectTimeout, setSplitMultiTopicDelivery

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.jms.ConnectionFactory

createConnection, createConnection

Methods inherited from interface javax.naming.spi.ObjectFactory

getObjectInstance

Constructor Detail

QueueConnectionFactory

public QueueConnectionFactory()
                       throws JMSException

Throws:

JMSException

QueueConnectionFactory

public QueueConnectionFactory(java.lang.String brokerURL)
                       throws JMSException

Throws:

JMSException

QueueConnectionFactory

public QueueConnectionFactory(java.lang.String brokerHostName,
                              int brokerPort,
                              java.lang.String brokerProtocol,
                              java.lang.String defaultUserName,
                              java.lang.String defaultPassword)
                       throws JMSException

Throws:

JMSException

QueueConnectionFactory

public QueueConnectionFactory(java.lang.String brokerHostName,
                              int brokerPort,
                              java.lang.String brokerProtocol,
                              java.lang.String connectID,
                              java.lang.String defaultUserName,
                              java.lang.String defaultPassword)
                       throws JMSException

Throws:

JMSException

QueueConnectionFactory

public QueueConnectionFactory(java.lang.String brokerURL,
                              java.lang.String connectID)
                       throws JMSException

Throws:

JMSException

QueueConnectionFactory

public QueueConnectionFactory(java.lang.String brokerURL,
                              java.lang.String defaultUserName,
                              java.lang.String defaultPassword)
                       throws JMSException

Throws:

JMSException

QueueConnectionFactory

public QueueConnectionFactory(java.lang.String brokerURL,
                              java.lang.String connectID,
                              java.lang.String defaultUserName,
                              java.lang.String defaultPassword)
                       throws JMSException

Throws:

JMSException

Method Detail

createQueueConnection

public QueueConnection createQueueConnection()
                                      throws JMSException

The method creates a new Queue Connection with default user identity.

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

If Adaptive Pacing is enabled the Connection inherits these properties from the factory. Specific session level behavior can be overriden at Session creation time. Users should check the Linked Exception for additional reasons of failure.

Specified by:

createQueueConnection in interface QueueConnectionFactory

Returns:

A newly created connection.

Throws:

JMSException - If the JMS provider fails to create the connection due to some internal error.

JMSSecurityException - If client authentication fails due to an invalid user name or password.

createQueueConnection

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

The method creates a new Queue Connection with the specified user identity.

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

If Adaptive Pacing is enabled the Connection inherits these properties from the factory. Specific session level behavior can be overriden at Session creation time. Users should check the Linked Exception for additional reasons of failure.

Specified by:

createQueueConnection in interface QueueConnectionFactory

Parameters:

userid - The caller's user name.

password - The caller's password.

Returns:

A newly created connection.

Throws:

JMSException - If the JMS provider fails to create the connection due to some internal error.

JMSSecurityException - If client authentication fails due to an invalid user name or password.

getReference

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

Specified by:

getReference in interface javax.naming.Referenceable

Overrides:

getReference in class ConnectionFactory

Throws:

javax.naming.NamingException