Package com.webmethods.jms.loadbalance.connection

Class WmClusterQueueReceiverImpl

java.lang.Object

com.webmethods.locks.Node

com.webmethods.jms.impl.WmMessageConsumerImpl

com.webmethods.jms.loadbalance.connection.WmClusterMessageConsumerImpl

com.webmethods.jms.loadbalance.connection.WmClusterQueueReceiverImpl

All Implemented Interfaces:

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

public class WmClusterQueueReceiverImpl
extends WmClusterMessageConsumerImpl
implements WmQueueReceiver

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
WmClusterQueueReceiverImpl(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.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

WmClusterQueueReceiverImpl

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

Throws:

javax.jms.JMSException

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.