org.jboss.messaging.jms.client
Class JBossMessageConsumer
java.lang.Object
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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
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
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.