org.fusesource.stompjms
Class StompJmsMessageConsumer

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

All Implemented Interfaces:

javax.jms.MessageConsumer, StompJmsMessageListener

Direct Known Subclasses:

StompJmsQueueReceiver, StompJmsTopicSubscriber

public class StompJmsMessageConsumer
extends java.lang.Object
implements javax.jms.MessageConsumer, StompJmsMessageListener

implementation of a Jms Message Consumer

Constructor Summary

protected

StompJmsMessageConsumer(org.fusesource.hawtbuf.AsciiBuffer id, StompJmsSession s, StompJmsDestination destination, java.lang.String selector)

Method Summary

protected void	checkClosed()
void	close()
StompJmsDestination	getDestination()
org.fusesource.hawtbuf.AsciiBuffer	getId()
javax.jms.MessageListener	getMessageListener()
protected int	getMessageQueueSize()
java.lang.String	getMessageSelector()
void	init()
boolean	isBrowser()
boolean	isDurableSubscription()
void	onMessage(StompJmsMessage message) Called when a Message is available to be processes
javax.jms.Message	receive()
javax.jms.Message	receive(long timeout)
javax.jms.Message	receiveNoWait()
protected void	rollback(org.fusesource.hawtbuf.AsciiBuffer transactionId)
void	setMessageListener(javax.jms.MessageListener listener)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

StompJmsMessageConsumer

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

Method Detail

init

public void init()
          throws javax.jms.JMSException

Throws:

javax.jms.JMSException

isDurableSubscription

public boolean isDurableSubscription()

isBrowser

public boolean isBrowser()

close

public void close()
           throws javax.jms.JMSException

Specified by:

close in interface javax.jms.MessageConsumer

Throws:

javax.jms.JMSException

See Also:

MessageConsumer.close()

getMessageListener

public javax.jms.MessageListener getMessageListener()
                                             throws javax.jms.JMSException

Specified by:

getMessageListener in interface javax.jms.MessageConsumer

Throws:

javax.jms.JMSException

getMessageSelector

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

Specified by:

getMessageSelector in interface javax.jms.MessageConsumer

Returns:

the Message Selector

Throws:

javax.jms.JMSException

See Also:

MessageConsumer.getMessageSelector()

receive

public javax.jms.Message receive()
                          throws javax.jms.JMSException

Specified by:

receive in interface javax.jms.MessageConsumer

Returns:

a Message or null if closed during the operation

Throws:

javax.jms.JMSException

See Also:

MessageConsumer.receive()

receive

public javax.jms.Message receive(long timeout)
                          throws javax.jms.JMSException

Specified by:

receive in interface javax.jms.MessageConsumer

Parameters:

timeout -

Returns:

a MEssage or null

Throws:

javax.jms.JMSException

See Also:

MessageConsumer.receive(long)

receiveNoWait

public javax.jms.Message receiveNoWait()
                                throws javax.jms.JMSException

Specified by:

receiveNoWait in interface javax.jms.MessageConsumer

Returns:

a Message or null

Throws:

javax.jms.JMSException

See Also:

MessageConsumer.receiveNoWait()

setMessageListener

public void setMessageListener(javax.jms.MessageListener listener)
                        throws javax.jms.JMSException

Specified by:

setMessageListener in interface javax.jms.MessageConsumer

Parameters:

listener -

Throws:

javax.jms.JMSException

See Also:

MessageConsumer.setMessageListener(javax.jms.MessageListener)

checkClosed

protected void checkClosed()
                    throws javax.jms.IllegalStateException

Throws:

javax.jms.IllegalStateException

onMessage

public void onMessage(StompJmsMessage message)

Description copied from interface: StompJmsMessageListener

Called when a Message is available to be processes

Specified by:

onMessage in interface StompJmsMessageListener

Parameters:

message -

getId

public org.fusesource.hawtbuf.AsciiBuffer getId()

Returns:

the id

getDestination

public StompJmsDestination getDestination()

Returns:

the Destination

start

public void start()

stop

public void stop()

rollback

protected void rollback(org.fusesource.hawtbuf.AsciiBuffer transactionId)

getMessageQueueSize

protected int getMessageQueueSize()