cern.cmw.mom.pubsub.impl

Class DefaultSubscriberImpl

java.lang.Object

cern.cmw.mom.pubsub.impl.DefaultSubscriberImpl

All Implemented Interfaces:

Subscriber

public class DefaultSubscriberImpl
extends java.lang.Object
implements Subscriber

Implementation class.

Author:

Controls Middleware Project

See Also:

Subscriber

Constructor Summary

Constructors

Constructor and Description
DefaultSubscriberImpl() Constructor DefaultSubscriberImpl
DefaultSubscriberImpl(java.lang.String username, java.lang.String password, java.lang.String brokerList, java.lang.Boolean loadBalancing, java.lang.Boolean sequential, java.lang.Boolean selectorAtBroker) Constructor DefaultSubscriberImpl

Method Summary

Modifier and Type	Method and Description
void	close() Method close
protected Topic	createTopic(java.lang.String topic) Method createTopic
protected void	finalize() Method finalize
boolean	isClosed() Method isClosed
void	onException(JMSException ex) Method onException
void	open() Method open
protected void	recoverSubscriptions() Method recoverSubscriptions
void	setExceptionListener(ExceptionListener listener) Method setExceptionListener
long	subscribe(java.lang.String topic, SubscriptionListener listener, java.lang.String selector) Method subscribe
void	unSubscribe(long token) Method unSubscribe
void	unSubscribeAll() Close all the opened subscriptions.

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultSubscriberImpl

public DefaultSubscriberImpl()
                      throws MOMException

Constructor DefaultSubscriberImpl

Throws:

MOMException

DefaultSubscriberImpl

public DefaultSubscriberImpl(java.lang.String username,
                             java.lang.String password,
                             java.lang.String brokerList,
                             java.lang.Boolean loadBalancing,
                             java.lang.Boolean sequential,
                             java.lang.Boolean selectorAtBroker)
                      throws MOMException

Constructor DefaultSubscriberImpl

Throws:

MOMException

Method Detail

isClosed

public boolean isClosed()

Method isClosed

Returns:

boolean true iff the subscriber instance has been closed

setExceptionListener

public void setExceptionListener(ExceptionListener listener)

Method setExceptionListener

Specified by:

setExceptionListener in interface Subscriber

Parameters:

listener -

close

public void close()

Method close

Specified by:

close in interface Subscriber

onException

public void onException(JMSException ex)

Method onException

Parameters:

ex -

open

public void open()
          throws MOMException

Method open

Throws:

MOMException

subscribe

public long subscribe(java.lang.String topic,
                      SubscriptionListener listener,
                      java.lang.String selector)
               throws JMSException,
                      javax.naming.NamingException

Method subscribe

Specified by:

subscribe in interface Subscriber

Parameters:

topic -

listener -

selector -

Returns:

long the subscription handle identifier

Throws:

JMSException

javax.naming.NamingException

unSubscribe

public void unSubscribe(long token)
                 throws JMSException

Method unSubscribe

Specified by:

unSubscribe in interface Subscriber

Parameters:

token -

Throws:

JMSException

unSubscribeAll

public void unSubscribeAll()
                    throws JMSException

Close all the opened subscriptions.

Specified by:

unSubscribeAll in interface Subscriber

Throws:

JMSException - if JMS fails to unsubscribe due to some internal JMS error.

createTopic

protected Topic createTopic(java.lang.String topic)
                     throws JMSException,
                            javax.naming.NamingException

Method createTopic

Parameters:

topic -

Returns:

Topic the topic

Throws:

JMSException

javax.naming.NamingException

finalize

protected void finalize()
                 throws java.lang.Throwable

Method finalize

Overrides:

finalize in class java.lang.Object

Throws:

java.lang.Throwable

recoverSubscriptions

protected void recoverSubscriptions()

Method recoverSubscriptions