progress.message.jclient.mp
Class TopicConnectionFactory

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

All Implemented Interfaces:

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

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

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

Description: An implementation of a Managed JMS TopicConnectionFactory. A client uses a TopicConnectionFactory object to create TopicConnections objects with a JMS Pub/Sub provider. TopicConnectionFactory can be used to create a TopicConnection, from which specialized topic-related objects can be created. A more general, and recommended, approach is to use the ConnectionFactory The TopicConnectionFactory 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

TopicConnectionFactory()

TopicConnectionFactory(java.lang.String brokerURL)

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

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

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

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

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

Method Summary

TopicConnection	createTopicConnection() The method creates a new Topic Connection with default user identity.
TopicConnection	createTopicConnection(java.lang.String userid, java.lang.String password) The method creates a new Topic 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

TopicConnectionFactory

public TopicConnectionFactory()
                       throws JMSException

Throws:

JMSException

TopicConnectionFactory

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

Throws:

JMSException

TopicConnectionFactory

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

Throws:

JMSException

TopicConnectionFactory

public TopicConnectionFactory(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

TopicConnectionFactory

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

Throws:

JMSException

TopicConnectionFactory

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

Throws:

JMSException

TopicConnectionFactory

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

Throws:

JMSException

Method Detail

createTopicConnection

public TopicConnection createTopicConnection()
                                      throws JMSException

The method creates a new Topic 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 JMS reasons of failure.

Specified by:

createTopicConnection in interface TopicConnectionFactory

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.

createTopicConnection

public TopicConnection createTopicConnection(java.lang.String userid,
                                             java.lang.String password)
                                      throws JMSException

The method creates a new Topic 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 JMS reasons of failure.

Specified by:

createTopicConnection in interface TopicConnectionFactory

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