org.activemq.usecases
Class AvailableConsumerTest.BlockingConsumer

java.lang.Object
org.activemq.usecases.AvailableConsumerTest.BlockingConsumer
- All Implemented Interfaces:
- javax.jms.MessageListener
- Enclosing class:
- AvailableConsumerTest
- private static final class AvailableConsumerTest.BlockingConsumer
- extends java.lang.Object
- implements javax.jms.MessageListener
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
m_url
private final java.lang.String m_url
m_connection
private final javax.jms.Connection m_connection
m_session
private final javax.jms.Session m_session
m_queue
private final javax.jms.Queue m_queue
m_consumer
private final javax.jms.MessageConsumer m_consumer
m_blocked
private boolean m_blocked
AvailableConsumerTest.BlockingConsumer
public AvailableConsumerTest.BlockingConsumer(java.lang.String url,
java.lang.String queue)
throws javax.jms.JMSException
isBlocked
public boolean isBlocked()
done
public void done()
onMessage
public void onMessage(javax.jms.Message message)
- Specified by:
onMessage in interface javax.jms.MessageListener