org.fusesource.stompjms
Class StompJmsQueueReceiver

java.lang.Object
  org.fusesource.stompjms.StompJmsMessageConsumer
      org.fusesource.stompjms.StompJmsQueueReceiver

All Implemented Interfaces:

javax.jms.MessageConsumer, javax.jms.QueueReceiver, StompJmsMessageListener

public class StompJmsQueueReceiver
extends StompJmsMessageConsumer
implements javax.jms.QueueReceiver

Implementation of a Jms QueueReceiver

Constructor Summary

protected

StompJmsQueueReceiver(org.fusesource.hawtbuf.AsciiBuffer id, StompJmsSession s, StompJmsDestination d, java.lang.String selector) Constructor

Method Summary

javax.jms.Queue

getQueue()

Methods inherited from class org.fusesource.stompjms.StompJmsMessageConsumer

checkClosed, close, getDestination, getId, getMessageListener, getMessageQueueSize, getMessageSelector, init, isBrowser, isDurableSubscription, onMessage, receive, receive, receiveNoWait, rollback, setMessageListener, start, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.jms.MessageConsumer

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

Constructor Detail

StompJmsQueueReceiver

protected StompJmsQueueReceiver(org.fusesource.hawtbuf.AsciiBuffer id,
                                StompJmsSession s,
                                StompJmsDestination d,
                                java.lang.String selector)

Constructor

Parameters:

s -

Method Detail

getQueue

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

Specified by:

getQueue in interface javax.jms.QueueReceiver

Returns:

the Queue

Throws:

javax.jms.IllegalStateException

See Also:

QueueReceiver.getQueue()