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().
1.7.0