org.jboss.mq
Class SpyQueueReceiver

java.lang.Object
  org.jboss.mq.SpyMessageConsumer
      org.jboss.mq.SpyQueueReceiver

All Implemented Interfaces:

Runnable, javax.jms.MessageConsumer, javax.jms.QueueReceiver, SpyConsumer

public class SpyQueueReceiver
extends SpyMessageConsumer
implements javax.jms.QueueReceiver

This class implements javax.jms.QueueReceiver

Version:

$Revision: 57198 $

Author:

Norbert Lataille (Norbert.Lataille@m4x.org), Hiram Chirino (Cojonudo14@hotmail.com), Adrian Brock

Field Summary

Fields inherited from class org.jboss.mq.SpyMessageConsumer

listenerThread, listening, receiving, session, stateLock, subscription, waitingForMessage

Method Summary

javax.jms.Queue

getQueue()

Methods inherited from class org.jboss.mq.SpyMessageConsumer

addMessage, close, getDestination, getMessageListener, getMessageSelector, getNoLocal, getSubscription, isListening, receive, receive, receiveNoWait, restartProcessing, run, sessionConsumerProcessMessage, setMessageListener, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.jms.MessageConsumer

close, getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener

Method Detail

getQueue

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

Specified by:

getQueue in interface javax.jms.QueueReceiver

Throws:

javax.jms.JMSException