Package com.webmethods.jms.loadbalance.connection

Class WmClusterTopicSubscriberImpl

java.lang.Object

com.webmethods.locks.Node

com.webmethods.jms.impl.WmMessageConsumerImpl

com.webmethods.jms.loadbalance.connection.WmClusterMessageConsumerImpl

com.webmethods.jms.loadbalance.connection.WmClusterTopicSubscriberImpl

All Implemented Interfaces:

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

public class WmClusterTopicSubscriberImpl
extends WmClusterMessageConsumerImpl
implements WmTopicSubscriber

This cluster topic subscriber is parallel to WmTopicSubscriberImpl and the only difference between these two are in the super classes they inherited from.

Field Summary

Fields inherited from class com.webmethods.jms.loadbalance.connection.WmClusterMessageConsumerImpl

_activeSessions, _clusterConn, _consumers, _factory, sharedQueue, sharedReadWriteLock

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

_closed, _destination, _durableName, _filter, _logApi, _maxReceive, _messageListener, _messageQueue, _noLocal, _protocolHandler, _selector, _session, _sessionID, _suspendedTransactions

Fields inherited from class com.webmethods.locks.Node

_lockManager

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
boolean	getNoLocal()	Gets the NoLocal attribute for this subscriber.
javax.jms.Topic	getTopic()	Gets the Topic associated with this subscriber.

Methods inherited from class com.webmethods.jms.loadbalance.connection.WmClusterMessageConsumerImpl

acknowledge, addActiveConsumerSession, available, cancelRequestEvents, checkState, checkSynchronous, clear, clearActiveConsumerSessions, close, commit, createConsumer, getActiveConsumerSessions, getConsumers, getMessageListener, getTransactedSessions, logClusterConsumers, messageAcknowledge, receive, receive, receiveNoWait, requestEvents, requestEvents, setActiveConsumerSessions, setMessageListener, setMessageListener, setMessageQueue, setTransactionID, start, startLocalTransaction, startLocalTransaction, stop, toString

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

addToPreAckList, autoAcknowledge, availableOnServer, clientAcknowledge, close, commit, createFilter, deliver, dupsOkAcknowledge, getClientAcknowledgeList, getDestination, getDurableName, getInputStream, getMaxReceive, getMessageQueue, getMessageSelector, getSession, getTransactionAckCount, isNoLocal, onMessage, onMessage, onReply, preAckClientList, preAcknowledge, removeMessage, removeMessageNoWait, removeMessageWithWait, requestEvents, requestEvents, rollback, setFilter, setMaxReceive, setTransactionID, setTransactionTimeout, stopAutoAcknowledger, transactedAcknowledge, transactionComplete

Methods inherited from class com.webmethods.locks.Node

getLockManager, getParent

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.jms.MessageConsumer

getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener

Methods inherited from interface com.webmethods.jms.WmMessageConsumer

available, clear, close, getDestination, getInputStream, getMaxReceive, setMaxReceive

Constructor Detail

WmClusterTopicSubscriberImpl

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

Throws:

javax.jms.JMSException

Method Detail

getTopic

public javax.jms.Topic getTopic()
                         throws javax.jms.JMSException

Gets the Topic associated with this subscriber.

Specified by:

getTopic in interface javax.jms.TopicSubscriber

Returns:

this subscriber's Topic

Throws:

javax.jms.JMSException - if the JMS provider fails to get the topic for this topic subscriber due to some internal error.

getNoLocal

public boolean getNoLocal()
                   throws javax.jms.JMSException

Gets the NoLocal attribute for this subscriber. The default value for this attribute is false.

Specified by:

getNoLocal in interface javax.jms.TopicSubscriber

Returns:

true if locally published messages are being inhibited

Throws:

javax.jms.JMSException - if the JMS provider fails to get the NoLocal attribute for this topic subscriber due to some internal error.