Package com.webmethods.jms.impl

Class WmQueueBrowserImpl

java.lang.Object

com.webmethods.locks.Node

com.webmethods.jms.impl.WmMessageConsumerImpl

com.webmethods.jms.impl.WmQueueReceiverImpl

com.webmethods.jms.impl.WmQueueBrowserImpl

All Implemented Interfaces:

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

Direct Known Subclasses:

WmClusterQueueBrowserImpl

public class WmQueueBrowserImpl
extends WmQueueReceiverImpl
implements WmQueueBrowser

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

Method Summary

Modifier and Type	Method	Description
int	begin()
WmMessageImpl	browse(int browseID)
void	end(int browseID)
java.util.Enumeration<WmMessageImpl>	getEnumeration()	Gets an enumeration for browsing the current queue messages in the order they would be received.
java.lang.String	getMessageSelector()	Gets this queue browser's message selector expression.
javax.jms.Queue	getQueue()	Gets the queue associated with this queue browser.
boolean	isClosed()

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, 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, receive, receive, receiveNoWait, setMessageListener

Methods inherited from interface javax.jms.QueueBrowser

close

Methods inherited from interface com.webmethods.jms.WmMessageConsumer

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

Methods inherited from interface com.webmethods.jms.WmQueueBrowser

available

Constructor Detail

WmQueueBrowserImpl

protected WmQueueBrowserImpl(WmSessionImpl session,
                             WmQueueImpl queue)
                      throws javax.jms.JMSException

Throws:

javax.jms.JMSException

WmQueueBrowserImpl

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

Throws:

javax.jms.JMSException

WmQueueBrowserImpl

protected WmQueueBrowserImpl(WmSessionImpl session)

Method Detail

getQueue

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

Gets the queue associated with this queue browser.

Specified by:

getQueue in interface javax.jms.QueueBrowser

Specified by:

getQueue in interface javax.jms.QueueReceiver

Overrides:

getQueue in class WmQueueReceiverImpl

Returns:

the queue

Throws:

javax.jms.JMSException - if the JMS provider fails to get the queue associated with this browser due to some internal error.

getMessageSelector

public java.lang.String getMessageSelector()
                                    throws javax.jms.JMSException

Gets this queue browser's message selector expression.

Specified by:

getMessageSelector in interface javax.jms.MessageConsumer

Specified by:

getMessageSelector in interface javax.jms.QueueBrowser

Overrides:

getMessageSelector in class WmMessageConsumerImpl

Returns:

this queue browser's message selector, or null if no message selector exists for the message consumer (that is, if the message selector was not set or was set to null or the empty string)

Throws:

javax.jms.JMSException - if the JMS provider fails to get the message selector for this browser due to some internal error.

getEnumeration

public java.util.Enumeration<WmMessageImpl> getEnumeration()
                                                    throws javax.jms.JMSException

Gets an enumeration for browsing the current queue messages in the order they would be received.

Specified by:

getEnumeration in interface javax.jms.QueueBrowser

Returns:

an enumeration for browsing the messages

Throws:

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

begin

public int begin()
          throws javax.jms.JMSException

Throws:

javax.jms.JMSException

end

public void end(int browseID)
         throws javax.jms.JMSException

Throws:

javax.jms.JMSException

browse

public WmMessageImpl browse(int browseID)
                     throws javax.jms.JMSException

Throws:

javax.jms.JMSException

isClosed

public boolean isClosed()