Package com.webmethods.jms.impl

Class WmQueueReceiverImpl

java.lang.Object

com.webmethods.locks.Node

com.webmethods.jms.impl.WmMessageConsumerImpl

com.webmethods.jms.impl.WmQueueReceiverImpl

All Implemented Interfaces:

ReplyCb, WmMessageConsumer, WmQueueReceiver, javax.jms.MessageConsumer, javax.jms.QueueReceiver

Direct Known Subclasses:

WmQueueBrowserImpl

public class WmQueueReceiverImpl
extends WmMessageConsumerImpl
implements WmQueueReceiver

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	WmQueueReceiverImpl(WmSessionImpl session)
protected	WmQueueReceiverImpl(WmSessionImpl session, WmQueueImpl queue, java.lang.String selector)

Method Summary

Modifier and Type	Method	Description
javax.jms.Queue	getQueue()	Gets the Queue associated with this queue receiver.

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

WmQueueReceiverImpl

protected WmQueueReceiverImpl(WmSessionImpl session,
                              WmQueueImpl queue,
                              java.lang.String selector)
                       throws javax.jms.JMSException

Throws:

javax.jms.JMSException

WmQueueReceiverImpl

protected WmQueueReceiverImpl(WmSessionImpl session)

Method Detail

getQueue

public javax.jms.Queue getQueue()
                         throws javax.jms.JMSException

Gets the Queue associated with this queue receiver.

Specified by:

getQueue in interface javax.jms.QueueReceiver

Returns:

this receiver's Queue

Throws:

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