org.jboss.jms.client.p2p
Class P2PConsumerDelegate

java.lang.Object
  extended byorg.jboss.jms.client.p2p.P2PConsumerDelegate
All Implemented Interfaces:
ConsumerDelegate (src) , Lifecycle (src)

public class P2PConsumerDelegate
extends java.lang.Object
implements ConsumerDelegate (src)

The p2p consumer


Constructor Summary
P2PConsumerDelegate(P2PSessionDelegate (src)  session, Destination (src)  destination, java.lang.String selector, boolean noLocal)
           
 
Method Summary
 void close()
          Close the delegate
 void closing()
          Notify about to close
 Message (src) receive(long timeout)
          Receive a message
 void setMessageListener(MessageListener (src)  listener)
          Set the message listener
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

P2PConsumerDelegate

public P2PConsumerDelegate(P2PSessionDelegate (src)  session,
                           Destination (src)  destination,
                           java.lang.String selector,
                           boolean noLocal)
                    throws JMSException (src) 
Method Detail

close

public void close()
           throws JMSException (src) 
Description copied from interface: Lifecycle (src)
Close the delegate

Specified by:
close in interface Lifecycle (src)
Throws:
JMSException (src) - for any error

closing

public void closing()
             throws JMSException (src) 
Description copied from interface: Lifecycle (src)
Notify about to close

Specified by:
closing in interface Lifecycle (src)
Throws:
JMSException (src) - for any error

receive

public Message (src)  receive(long timeout)
                throws JMSException (src) 
Description copied from interface: ConsumerDelegate (src)
Receive a message

Specified by:
receive in interface ConsumerDelegate (src)
Parameters:
timeout - the timeout
Returns:
the message
Throws:
JMSException (src) - for any error

setMessageListener

public void setMessageListener(MessageListener (src)  listener)
                        throws JMSException (src) 
Description copied from interface: ConsumerDelegate (src)
Set the message listener

Specified by:
setMessageListener in interface ConsumerDelegate (src)
Throws:
JMSException (src) - for any error