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