org.apache.activemq.pool
Class PooledMessageConsumer
java.lang.Object
org.apache.activemq.pool.PooledMessageConsumer
- All Implemented Interfaces:
- javax.jms.MessageConsumer
public class PooledMessageConsumer
- extends java.lang.Object
- implements javax.jms.MessageConsumer
A MessageConsumer
which was created by PooledSession
.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
PooledMessageConsumer
public PooledMessageConsumer(PooledSession session,
javax.jms.MessageConsumer delegate)
- Wraps the message consumer.
- Parameters:
session
- the pooled sessiondelegate
- the created consumer to wrap
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
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
setMessageListener
public void setMessageListener(javax.jms.MessageListener listener)
throws javax.jms.JMSException
- Specified by:
setMessageListener
in interface javax.jms.MessageConsumer
- Throws:
javax.jms.JMSException
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object
Copyright © 2005-2015. All Rights Reserved.