org.jboss.jms.client
Class JBossMessageConsumer

java.lang.Object
  extended by org.jboss.jms.client.JBossMessageConsumer
All Implemented Interfaces:
java.io.Serializable, 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, java.io.Serializable

Version:
$Revision: 3174 $ $Id: JBossMessageConsumer.java 3174 2007-10-05 15:14:57Z timfox $
Author:
Ovidiu Feodorov
See Also:
Serialized Form

Field Summary
protected  ConsumerDelegate delegate
           
 
Constructor Summary
JBossMessageConsumer(ConsumerDelegate delegate)
           
 
Method Summary
 void close()
           
 ConsumerDelegate getDelegate()
           
 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
 

Field Detail

delegate

protected ConsumerDelegate delegate
Constructor Detail

JBossMessageConsumer

public JBossMessageConsumer(ConsumerDelegate delegate)
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

getDelegate

public ConsumerDelegate getDelegate()

toString

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


Copyright © 2006 JBoss Inc. All Rights Reserved.