Public Member Functions | Protected Member Functions | Static Package Attributes

cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl Class Reference

Inheritance diagram for cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl:
cern.cmw.mom.pubsub.Subscriber

List of all members.

Public Member Functions

 DefaultSubscriberImpl () throws MOMException
 DefaultSubscriberImpl (String username, String password, String brokerList, Boolean loadBalancing, Boolean sequential, Boolean selectorAtBroker) throws MOMException
boolean isClosed ()
void setExceptionListener (cern.cmw.mom.pubsub.ExceptionListener listener)
void close ()
void onException (JMSException ex)
void open () throws MOMException
long subscribe (String topic, SubscriptionListener listener, String selector) throws JMSException, NamingException
void unSubscribe (long token) throws JMSException
void unSubscribeAll () throws JMSException

Protected Member Functions

Topic createTopic (String topic) throws JMSException, NamingException
void finalize () throws Throwable
void recoverSubscriptions ()

Static Package Attributes

static Category cat = Category.getInstance(DefaultSubscriberImpl.class.getName())

Detailed Description

Implementation class.

Version:
1.0 23 Jan 2001
Author:
Controls Middleware Project
See also:
Subscriber

Constructor & Destructor Documentation

cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.DefaultSubscriberImpl (  )  throws MOMException

Constructor DefaultSubscriberImpl

Exceptions:
MOMException 

References cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.open().

cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.DefaultSubscriberImpl ( String  username,
String  password,
String  brokerList,
Boolean  loadBalancing,
Boolean  sequential,
Boolean  selectorAtBroker 
) throws MOMException

Constructor DefaultSubscriberImpl

Exceptions:
MOMException 

References cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.open().

Member Function Documentation

void cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.close (  ) 

Method close

References cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.cat, cern.cmw.mom.pubsub.impl.JMSConnection.close(), cern.cmw.mom.pubsub.impl.SubscriptionHandle.getSession(), cern.cmw.mom.pubsub.impl.SubscriptionHandle.getSubscriber(), cern.cmw.mom.pubsub.impl.SubscriptionHandle.getSubscriptionTopic(), and cern.cmw.mom.pubsub.impl.JMSConnection.stop().

Referenced by cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.finalize().

Topic cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.createTopic ( String  topic  )  throws JMSException, NamingException [protected]

Method createTopic

Parameters:
topic 
Returns:
Topic the topic
Exceptions:
JMSException 
NamingException 

References cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.cat, and cern.cmw.mom.pubsub.impl.JMSConnection.getUsername().

Referenced by cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.recoverSubscriptions(), and cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.subscribe().

void cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.finalize (  )  throws Throwable [protected]

Method finalize

Exceptions:
Throwable 

References cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.cat, and cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.close().

boolean cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.isClosed (  ) 

Method isClosed

Returns:
boolean true iff the subscriber instance has been closed
void cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.onException ( JMSException  ex  ) 

Method onException

Parameters:
ex 

References cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.cat.

void cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.open (  )  throws MOMException

Method open

Exceptions:
MOMException 

References cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.cat.

Referenced by cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.DefaultSubscriberImpl().

void cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.recoverSubscriptions (  )  [protected]

Method recoverSubscriptions

References cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.cat, cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.createTopic(), cern.cmw.mom.pubsub.impl.JMSTopicConnection.createTopicSession(), cern.cmw.mom.pubsub.impl.SubscriptionHandle.getSubscriptionListener(), cern.cmw.mom.pubsub.impl.SubscriptionHandle.getSubscriptionSelector(), cern.cmw.mom.pubsub.impl.SubscriptionHandle.getSubscriptionTopic(), cern.cmw.mom.pubsub.impl.SubscriptionHandle.setSession(), and cern.cmw.mom.pubsub.impl.SubscriptionHandle.setSubscriber().

void cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.setExceptionListener ( cern.cmw.mom.pubsub.ExceptionListener  listener  ) 

Method setExceptionListener

Parameters:
listener 
long cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.subscribe ( String  topic,
SubscriptionListener  listener,
String  selector 
) throws JMSException, NamingException

Method subscribe

Parameters:
topic 
listener 
selector 
Returns:
long the subscription handle identifier
Exceptions:
JMSException 
NamingException 

References cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.cat, cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.createTopic(), cern.cmw.mom.pubsub.impl.JMSTopicConnection.createTopicSession(), cern.cmw.mom.pubsub.impl.SubscriptionHandle.getSubscriptionToken(), cern.cmw.mom.pubsub.impl.SubscriptionHandle.setSession(), cern.cmw.mom.pubsub.impl.SubscriptionHandle.setSubscriber(), cern.cmw.mom.pubsub.impl.SubscriptionHandle.setSubscriptionListener(), cern.cmw.mom.pubsub.impl.SubscriptionHandle.setSubscriptionSelector(), and cern.cmw.mom.pubsub.impl.SubscriptionHandle.setSubscriptionTopic().

void cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.unSubscribe ( long  token  )  throws JMSException

Method unSubscribe

Parameters:
token 
Exceptions:
JMSException 

References cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.cat, cern.cmw.mom.pubsub.impl.SubscriptionHandle.getSession(), cern.cmw.mom.pubsub.impl.SubscriptionHandle.getSubscriber(), and cern.cmw.mom.pubsub.impl.SubscriptionHandle.getSubscriptionTopic().

void cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.unSubscribeAll (  )  throws JMSException

Close all the opened subscriptions.

Exceptions:
JMSException if JMS fails to unsubscribe due to some internal JMS error.

References cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.cat, cern.cmw.mom.pubsub.impl.SubscriptionHandle.getSession(), cern.cmw.mom.pubsub.impl.SubscriptionHandle.getSubscriber(), and cern.cmw.mom.pubsub.impl.SubscriptionHandle.getSubscriptionTopic().

Member Data Documentation

Category cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.cat = Category.getInstance(DefaultSubscriberImpl.class.getName()) [static, package]

Referenced by cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.close(), cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.createTopic(), cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.finalize(), cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.onException(), cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.open(), cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.recoverSubscriptions(), cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.subscribe(), cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.unSubscribe(), and cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl.unSubscribeAll().

The documentation for this class was generated from the following file:
 All Classes Namespaces Files Functions Variables Enumerations Properties
Generated on Thu Jan 12 2012 23:15:27 for ACS-10.0 Java API by  doxygen 1.7.0