org.fusesource.stomp.jms

Class StompJmsQueueReceiver

java.lang.Object

org.fusesource.stomp.jms.StompJmsMessageConsumer

org.fusesource.stomp.jms.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

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
javax.jms.Queue	getQueue()

Methods inherited from class org.fusesource.stomp.jms.StompJmsMessageConsumer

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

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)
                         throws javax.jms.JMSException

Constructor

Parameters:

s -

Throws:

javax.jms.JMSException

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()