Public Member Functions | |
String | getConnectId () |
boolean | isConnected () |
void | setExceptionListener (ExceptionListener listener) throws ConnectionException |
String | getUsername () |
void | close () |
void | connect (boolean retry) throws ConnectionException |
TopicSession | createTopicSession () throws ConnectionException |
void | disconnect () |
void | start () throws ConnectionException |
void | stop () throws ConnectionException |
Static Public Member Functions | |
static DefaultJMSTopicConnectionImpl | instance (String username, String password, String brokerList, Boolean loadBalancing, Boolean sequential, Boolean selectorAtBroker) throws ConnectionException |
Protected Member Functions | |
DefaultJMSTopicConnectionImpl (String username, String password, String brokerList, Boolean loadBalancing, Boolean sequential, Boolean selectorAtBroker) throws JMSException | |
void | finalize () throws Throwable |
Static Package Attributes | |
static Category | cat = Category.getInstance(DefaultJMSTopicConnectionImpl.class.getName()) |
Implementation class.
cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.DefaultJMSTopicConnectionImpl | ( | String | username, | |
String | password, | |||
String | brokerList, | |||
Boolean | loadBalancing, | |||
Boolean | sequential, | |||
Boolean | selectorAtBroker | |||
) | throws JMSException [protected] |
Constructor DefaultJMSTopicConnectionImpl
JMSException |
References com.cosylab.acs.jms.ACSJMSTopicConnectionFactory.ACSJMSTopicConnectionFactory(), and cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.cat.
Referenced by cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.instance().
void cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.close | ( | ) |
Method close
Implements cern.cmw.mom.pubsub.impl.JMSConnection.
References cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.cat, and cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.disconnect().
Referenced by cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.finalize().
void cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.connect | ( | boolean | retry | ) | throws ConnectionException |
Method connect
retry |
ConnectionException |
Implements cern.cmw.mom.pubsub.impl.JMSConnection.
References cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.cat, and com.cosylab.acs.jms.ACSJMSTopicConnectionFactory.createTopicConnection().
TopicSession cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.createTopicSession | ( | ) | throws ConnectionException |
Method createTopicSession
ConnectionException |
Implements cern.cmw.mom.pubsub.impl.JMSTopicConnection.
References cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.cat, and cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.isConnected().
void cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.disconnect | ( | ) |
Method disconnect
Implements cern.cmw.mom.pubsub.impl.JMSConnection.
References cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.cat, and cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.isConnected().
Referenced by cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.close().
void cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.finalize | ( | ) | throws Throwable [protected] |
Method finalize
Throwable |
References cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.cat, and cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.close().
String cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.getConnectId | ( | ) |
Method getConnectId
Implements cern.cmw.mom.pubsub.impl.JMSConnection.
References cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.cat, and cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.isConnected().
String cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.getUsername | ( | ) |
static DefaultJMSTopicConnectionImpl cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.instance | ( | String | username, | |
String | password, | |||
String | brokerList, | |||
Boolean | loadBalancing, | |||
Boolean | sequential, | |||
Boolean | selectorAtBroker | |||
) | throws ConnectionException [static] |
Method instance
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 |
ConnectionException |
References cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.cat, and cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.DefaultJMSTopicConnectionImpl().
boolean cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.isConnected | ( | ) |
Method isConnected
Implements cern.cmw.mom.pubsub.impl.JMSConnection.
Referenced by cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.createTopicSession(), cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.disconnect(), cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.getConnectId(), cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.setExceptionListener(), cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.start(), and cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.stop().
void cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.setExceptionListener | ( | ExceptionListener | listener | ) | throws ConnectionException |
Method setExceptionListener
listener |
ConnectionException |
Implements cern.cmw.mom.pubsub.impl.JMSConnection.
References cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.cat, and cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.isConnected().
void cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.start | ( | ) | throws ConnectionException |
Method start
ConnectionException |
Implements cern.cmw.mom.pubsub.impl.JMSConnection.
References cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.cat, and cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.isConnected().
void cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.stop | ( | ) | throws ConnectionException |
Method stop
ConnectionException |
Implements cern.cmw.mom.pubsub.impl.JMSConnection.
References cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.cat, and cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.isConnected().
Category cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.cat = Category.getInstance(DefaultJMSTopicConnectionImpl.class.getName()) [static, package] |
Referenced by cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.close(), cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.connect(), cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.createTopicSession(), cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.DefaultJMSTopicConnectionImpl(), cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.disconnect(), cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.finalize(), cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.getConnectId(), cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.instance(), cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.setExceptionListener(), cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.start(), and cern.cmw.mom.pubsub.impl.DefaultJMSTopicConnectionImpl.stop().