org.stringtree.jms
Class InMemoryConsumer

java.lang.Object
  extended by org.stringtree.jms.InMemoryConsumer
All Implemented Interfaces:
javax.jms.MessageConsumer, javax.jms.MessageListener, javax.jms.QueueReceiver, javax.jms.TopicSubscriber

public class InMemoryConsumer
extends java.lang.Object
implements javax.jms.MessageConsumer, javax.jms.QueueReceiver, javax.jms.TopicSubscriber, javax.jms.MessageListener


Field Summary
protected  javax.jms.Destination destination
           
private  javax.jms.MessageListener listener
           
 
Constructor Summary
InMemoryConsumer(javax.jms.Destination destination)
           
 
Method Summary
 void close()
           
 javax.jms.MessageListener getMessageListener()
           
 java.lang.String getMessageSelector()
           
 boolean getNoLocal()
           
 javax.jms.Queue getQueue()
           
 javax.jms.Topic getTopic()
           
 void onMessage(javax.jms.Message message)
           
 javax.jms.Message receive()
           
 javax.jms.Message receive(long timeout)
           
 javax.jms.Message receiveNoWait()
           
 void setMessageListener(javax.jms.MessageListener listener)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

destination

protected javax.jms.Destination destination

listener

private javax.jms.MessageListener listener
Constructor Detail

InMemoryConsumer

public InMemoryConsumer(javax.jms.Destination destination)
Method Detail

getMessageSelector

public java.lang.String getMessageSelector()
                                    throws javax.jms.JMSException
Specified by:
getMessageSelector in interface javax.jms.MessageConsumer
Throws:
javax.jms.JMSException

getMessageListener

public javax.jms.MessageListener getMessageListener()
                                             throws javax.jms.JMSException
Specified by:
getMessageListener in interface javax.jms.MessageConsumer
Throws:
javax.jms.JMSException

setMessageListener

public void setMessageListener(javax.jms.MessageListener listener)
                        throws javax.jms.JMSException
Specified by:
setMessageListener in interface javax.jms.MessageConsumer
Throws:
javax.jms.JMSException

receive

public javax.jms.Message receive()
                          throws javax.jms.JMSException
Specified by:
receive in interface javax.jms.MessageConsumer
Throws:
javax.jms.JMSException

receive

public javax.jms.Message receive(long timeout)
                          throws javax.jms.JMSException
Specified by:
receive in interface javax.jms.MessageConsumer
Throws:
javax.jms.JMSException

receiveNoWait

public javax.jms.Message receiveNoWait()
                                throws javax.jms.JMSException
Specified by:
receiveNoWait in interface javax.jms.MessageConsumer
Throws:
javax.jms.JMSException

close

public void close()
           throws javax.jms.JMSException
Specified by:
close in interface javax.jms.MessageConsumer
Throws:
javax.jms.JMSException

getQueue

public javax.jms.Queue getQueue()
                         throws javax.jms.JMSException
Specified by:
getQueue in interface javax.jms.QueueReceiver
Throws:
javax.jms.JMSException

getTopic

public javax.jms.Topic getTopic()
                         throws javax.jms.JMSException
Specified by:
getTopic in interface javax.jms.TopicSubscriber
Throws:
javax.jms.JMSException

getNoLocal

public boolean getNoLocal()
                   throws javax.jms.JMSException
Specified by:
getNoLocal in interface javax.jms.TopicSubscriber
Throws:
javax.jms.JMSException

onMessage

public void onMessage(javax.jms.Message message)
Specified by:
onMessage in interface javax.jms.MessageListener