Package com.webmethods.jms.impl

Class WmTopicSubscriberImpl

java.lang.Object

com.webmethods.locks.Node

com.webmethods.jms.impl.WmMessageConsumerImpl

com.webmethods.jms.impl.WmTopicSubscriberImpl

All Implemented Interfaces:

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

public class WmTopicSubscriberImpl
extends WmMessageConsumerImpl
implements WmTopicSubscriber

Field Summary

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

Modifier	Constructor	Description
protected	WmTopicSubscriberImpl(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.impl.WmMessageConsumerImpl

acknowledge, addToPreAckList, autoAcknowledge, available, availableOnServer, cancelRequestEvents, checkState, checkSynchronous, clear, clientAcknowledge, close, close, commit, commit, createFilter, deliver, dupsOkAcknowledge, getClientAcknowledgeList, getDestination, getDurableName, getInputStream, getMaxReceive, getMessageListener, getMessageQueue, getMessageSelector, getSession, getTransactionAckCount, isNoLocal, onMessage, onMessage, onReply, preAckClientList, preAcknowledge, receive, receive, receiveNoWait, removeMessage, removeMessageNoWait, removeMessageWithWait, requestEvents, requestEvents, requestEvents, rollback, setFilter, setMaxReceive, setMessageListener, setMessageListener, setMessageQueue, setTransactionID, setTransactionID, setTransactionTimeout, start, startLocalTransaction, stop, stopAutoAcknowledger, toString, 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

WmTopicSubscriberImpl

protected WmTopicSubscriberImpl(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.