Package com.webmethods.jms.loadbalance.connection

Class WmClusterSessionSubscriber

java.lang.Object

com.webmethods.locks.Node

com.webmethods.jms.impl.WmSessionSubscriber

com.webmethods.jms.loadbalance.connection.WmClusterSessionSubscriber

All Implemented Interfaces:

WmMessageConsumer, WmTopicSubscriber, javax.jms.MessageConsumer, javax.jms.TopicSubscriber

public class WmClusterSessionSubscriber
extends WmSessionSubscriber

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.concurrent.CopyOnWriteArrayList<javax.jms.TopicSubscriber>	subscribers

Fields inherited from class com.webmethods.jms.impl.WmSessionSubscriber

_subscriberClosed, _subscriberDurableName, _subscriberNoLocal, _subscriberSelector, _subscriberSession, _subscriberTopic

Fields inherited from class com.webmethods.locks.Node

_lockManager

Constructor Summary

Constructors

Constructor	Description
WmClusterSessionSubscriber(WmSessionImpl session, WmTopicImpl topic, java.lang.String durableName, java.lang.String selector, boolean noLocal)

Method Summary

Modifier and Type	Method	Description
long	available()	Gets the number of messages on the Broker available to the consumer.
void	clear()	Clears all available messages to the consumer from the Broker.
void	close()
javax.jms.Message	receive()
javax.jms.Message	receive(long timeout)
javax.jms.Message	receiveNoWait()
void	setMessageListener(javax.jms.MessageListener listener)	Assign the listener to the session subscriber
protected void	waitFinished(WmSessionSubscriber subscriber)	Marks the subscriber that contains a message.

Methods inherited from class com.webmethods.jms.impl.WmSessionSubscriber

create, getAndAckMessage, getDestination, getInputStream, getMaxReceive, getMessageListener, getMessageSelector, getNoLocal, getTopic, setMaxReceive, waitForMessages

Methods inherited from class com.webmethods.locks.Node

getLockManager, getParent

Methods inherited from class java.lang.Object

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

Field Detail

subscribers

protected java.util.concurrent.CopyOnWriteArrayList<javax.jms.TopicSubscriber> subscribers

Constructor Detail

WmClusterSessionSubscriber

public WmClusterSessionSubscriber(WmSessionImpl session,
                                  WmTopicImpl topic,
                                  java.lang.String durableName,
                                  java.lang.String selector,
                                  boolean noLocal)
                           throws javax.jms.JMSException

Throws:

javax.jms.JMSException

Method Detail

setMessageListener

public void setMessageListener(javax.jms.MessageListener listener)
                        throws javax.jms.JMSException

Assign the listener to the session subscriber

Specified by:

setMessageListener in interface javax.jms.MessageConsumer

Overrides:

setMessageListener in class WmSessionSubscriber

Parameters:

listener -

Throws:

javax.jms.JMSException

waitFinished

protected void waitFinished(WmSessionSubscriber subscriber)

Marks the subscriber that contains a message.

Parameters:

subscriber -

receive

public javax.jms.Message receive()
                          throws javax.jms.JMSException

Specified by:

receive in interface javax.jms.MessageConsumer

Overrides:

receive in class WmSessionSubscriber

Throws:

javax.jms.JMSException

receive

public javax.jms.Message receive(long timeout)
                          throws javax.jms.JMSException

Specified by:

receive in interface javax.jms.MessageConsumer

Overrides:

receive in class WmSessionSubscriber

Throws:

javax.jms.JMSException

receiveNoWait

public javax.jms.Message receiveNoWait()
                                throws javax.jms.JMSException

Specified by:

receiveNoWait in interface javax.jms.MessageConsumer

Overrides:

receiveNoWait in class WmSessionSubscriber

Throws:

javax.jms.JMSException

close

public void close()
           throws javax.jms.JMSException

Specified by:

close in interface javax.jms.MessageConsumer

Specified by:

close in interface WmMessageConsumer

Overrides:

close in class WmSessionSubscriber

Throws:

javax.jms.JMSException

available

public long available()

Description copied from interface: WmMessageConsumer

Gets the number of messages on the Broker available to the consumer. This is an approximate number in that some of the messages may be expired or don't match the consumer's message selector.

Specified by:

available in interface WmMessageConsumer

Overrides:

available in class WmSessionSubscriber

Returns:

the number of messages available to the consumer

clear

public void clear()

Description copied from interface: WmMessageConsumer

Clears all available messages to the consumer from the Broker.

Specified by:

clear in interface WmMessageConsumer

Overrides:

clear in class WmSessionSubscriber