org.directwebremoting.jms
Class DwrMessageConsumer

java.lang.Object
  extended by org.directwebremoting.jms.DwrMessageConsumer
All Implemented Interfaces:
javax.jms.MessageConsumer

public class DwrMessageConsumer
extends java.lang.Object
implements javax.jms.MessageConsumer

A MessageConsumer for DWR

Author:
Joe Walker [joe at getahead dot ltd dot uk]

Nested Class Summary
 class DwrMessageConsumer.MessageListenerMessageListener
           
 
Constructor Summary
DwrMessageConsumer(DwrConnection connection, javax.jms.Destination destination)
           
DwrMessageConsumer(DwrConnection connection, javax.jms.Destination destination, java.lang.String messageSelector)
           
DwrMessageConsumer(DwrConnection connection, javax.jms.Destination destination, java.lang.String messageSelector, boolean noLocal)
           
 
Method Summary
 void close()
           
 javax.jms.MessageListener getMessageListener()
           
 java.lang.String getMessageSelector()
           
 javax.jms.Message receive()
           
 javax.jms.Message receive(long timeout)
           
 javax.jms.Message receiveNoWait()
           
 void setMessageListener(javax.jms.MessageListener messageListener)
           
 void setMessageSelector(java.lang.String messageSelector)
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DwrMessageConsumer

public DwrMessageConsumer(DwrConnection connection,
                          javax.jms.Destination destination)
                   throws javax.jms.JMSException
Throws:
javax.jms.JMSException
See Also:
Session.createConsumer(Destination)

DwrMessageConsumer

public DwrMessageConsumer(DwrConnection connection,
                          javax.jms.Destination destination,
                          java.lang.String messageSelector)
                   throws javax.jms.JMSException
Throws:
javax.jms.JMSException
See Also:
Session.createConsumer(Destination, String)

DwrMessageConsumer

public DwrMessageConsumer(DwrConnection connection,
                          javax.jms.Destination destination,
                          java.lang.String messageSelector,
                          boolean noLocal)
                   throws javax.jms.JMSException
Throws:
javax.jms.JMSException
See Also:
Session.createConsumer(Destination, String, boolean)
Method Detail

close

public void close()
           throws javax.jms.JMSException
Specified by:
close 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 messageListener)
                        throws javax.jms.JMSException
Specified by:
setMessageListener in interface javax.jms.MessageConsumer
Throws:
javax.jms.JMSException

setMessageSelector

public void setMessageSelector(java.lang.String messageSelector)
Parameters:
messageSelector - the messageSelector to set

getMessageSelector

public java.lang.String getMessageSelector()
                                    throws javax.jms.JMSException
Specified by:
getMessageSelector 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

Copyright 2008