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