org.jboss.messaging.jms.client
Class JBossMessageConsumer

java.lang.Object
  extended by org.jboss.messaging.jms.client.JBossMessageConsumer
All Implemented Interfaces:
javax.jms.MessageConsumer, javax.jms.QueueReceiver, javax.jms.TopicSubscriber

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

Version:
$Revision: 4163 $ $Id: JBossMessageConsumer.java 4163 2008-05-08 11:20:19Z timfox $
Author:
Ovidiu Feodorov

Constructor Summary
JBossMessageConsumer(JBossSession session, ClientConsumer consumer, boolean noLocal, javax.jms.Destination destination, java.lang.String selector, boolean deleteQueueOnClose)
           
 
Method Summary
 void close()
           
 ClientConsumer getConsumer()
           
 javax.jms.MessageListener getMessageListener()
           
 java.lang.String getMessageSelector()
           
 boolean getNoLocal()
           
 javax.jms.Queue getQueue()
           
 javax.jms.Topic getTopic()
           
 javax.jms.Message receive()
           
 javax.jms.Message receive(long timeout)
           
 javax.jms.Message receiveNoWait()
           
 void setMessageListener(javax.jms.MessageListener listener)
           
 java.lang.String toString()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

JBossMessageConsumer

public JBossMessageConsumer(JBossSession session,
                            ClientConsumer consumer,
                            boolean noLocal,
                            javax.jms.Destination destination,
                            java.lang.String selector,
                            boolean deleteQueueOnClose)
                     throws javax.jms.JMSException
Throws:
javax.jms.JMSException
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

getConsumer

public ClientConsumer getConsumer()

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object


Copyright © 2006 JBoss Inc. All Rights Reserved.