cern.cmw.mom.pubsub.impl

Class ACSJMSTopicConnectionImpl

java.lang.Object

cern.cmw.mom.pubsub.impl.ACSJMSTopicConnectionImpl

All Implemented Interfaces:

JMSConnection, JMSTopicConnection

public class ACSJMSTopicConnectionImpl
extends java.lang.Object
implements JMSTopicConnection

Implementation class.

Author:

Controls Middleware Project

See Also:

JMSTopicConnection

Field Summary

Fields

Modifier and Type	Field and Description
static ContainerServicesBase	containerServices

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ACSJMSTopicConnectionImpl(java.lang.String username, java.lang.String password, java.lang.String brokerList, java.lang.Boolean loadBalancing, java.lang.Boolean sequential, java.lang.Boolean selectorAtBroker) Constructor DefaultJMSTopicConnectionImpl

Method Summary

Modifier and Type	Method and Description
void	close() Method close
void	connect(boolean retry) Method connect
TopicSession	createTopicSession() Method createTopicSession
void	disconnect() Method disconnect
protected void	finalize() Method finalize
java.lang.String	getConnectId() Method getConnectId
java.lang.String	getUsername() Method getUsername
static ACSJMSTopicConnectionImpl	instance(java.lang.String username, java.lang.String password, java.lang.String brokerList, java.lang.Boolean loadBalancing, java.lang.Boolean sequential, java.lang.Boolean selectorAtBroker) Method instance
boolean	isConnected() Method isConnected
void	setExceptionListener(ExceptionListener listener) Method setExceptionListener
void	start() Method start
void	stop() Method stop

Methods inherited from class java.lang.Object

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

Field Detail

containerServices

public static ContainerServicesBase containerServices

Constructor Detail

ACSJMSTopicConnectionImpl

protected ACSJMSTopicConnectionImpl(java.lang.String username,
                                    java.lang.String password,
                                    java.lang.String brokerList,
                                    java.lang.Boolean loadBalancing,
                                    java.lang.Boolean sequential,
                                    java.lang.Boolean selectorAtBroker)
                             throws JMSException

Constructor DefaultJMSTopicConnectionImpl

Throws:

JMSException

Method Detail

instance

public static ACSJMSTopicConnectionImpl instance(java.lang.String username,
                                                 java.lang.String password,
                                                 java.lang.String brokerList,
                                                 java.lang.Boolean loadBalancing,
                                                 java.lang.Boolean sequential,
                                                 java.lang.Boolean selectorAtBroker)
                                          throws ConnectionException

Method instance

Parameters:

username - the user name

password - the password

brokerList - the coma separated broker URLs list (in the form [protocol://]hostname[:port])

loadBalancing - if true, indicates that the client is willing to have a connect request re-directed to another broker within a cluster

sequential - if true, the broker list will be scanned sequentially

selectorAtBroker - if true, selectors will be evaluated on the broker side

Returns:

DefaultJMSTopicConnectionImpl

Throws:

ConnectionException

getConnectId

public java.lang.String getConnectId()

Method getConnectId

Specified by:

getConnectId in interface JMSConnection

Returns:

String

isConnected

public boolean isConnected()

Method isConnected

Specified by:

isConnected in interface JMSConnection

Returns:

boolean

setExceptionListener

public void setExceptionListener(ExceptionListener listener)
                          throws ConnectionException

Method setExceptionListener

Specified by:

setExceptionListener in interface JMSConnection

Parameters:

listener -

Throws:

ConnectionException

getUsername

public java.lang.String getUsername()

Method getUsername

Specified by:

getUsername in interface JMSConnection

Returns:

String

close

public void close()

Method close

Specified by:

close in interface JMSConnection

connect

public void connect(boolean retry)
             throws ConnectionException

Method connect

Specified by:

connect in interface JMSConnection

Parameters:

retry -

Throws:

ConnectionException

createTopicSession

public TopicSession createTopicSession()
                                throws ConnectionException

Method createTopicSession

Specified by:

createTopicSession in interface JMSTopicConnection

Returns:

TopicSession

Throws:

ConnectionException

disconnect

public void disconnect()

Method disconnect

Specified by:

disconnect in interface JMSConnection

start

public void start()
           throws ConnectionException

Method start

Specified by:

start in interface JMSConnection

Throws:

ConnectionException

stop

public void stop()
          throws ConnectionException

Method stop

Specified by:

stop in interface JMSConnection

Throws:

ConnectionException

finalize

protected void finalize()
                 throws java.lang.Throwable

Method finalize

Overrides:

finalize in class java.lang.Object

Throws:

java.lang.Throwable