Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

org.activemq.usecases
Class AvailableConsumerTest.BlockingConsumer  view AvailableConsumerTest.BlockingConsumer download AvailableConsumerTest.BlockingConsumer.java

java.lang.Object
  extended byorg.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


Field Summary
private  boolean m_blocked
           
private  javax.jms.Connection m_connection
           
private  javax.jms.MessageConsumer m_consumer
           
private  javax.jms.Queue m_queue
           
private  javax.jms.Session m_session
           
private  java.lang.String m_url
           
 
Constructor Summary
AvailableConsumerTest.BlockingConsumer(java.lang.String url, java.lang.String queue)
           
 
Method Summary
 void done()
           
 boolean isBlocked()
           
 void onMessage(javax.jms.Message message)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

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
Constructor Detail

AvailableConsumerTest.BlockingConsumer

public AvailableConsumerTest.BlockingConsumer(java.lang.String url,
                                              java.lang.String queue)
                                       throws javax.jms.JMSException
Method Detail

isBlocked

public boolean isBlocked()

done

public void done()

onMessage

public void onMessage(javax.jms.Message message)
Specified by:
onMessage in interface javax.jms.MessageListener