org.apache.qpid.example.subscriber
Class MonitoredSubscriber

java.lang.Object
  extended by org.apache.qpid.example.subscriber.Subscriber
      extended by org.apache.qpid.example.subscriber.MonitoredSubscriber

public class MonitoredSubscriber
extends Subscriber

Subclass of Subscriber which consumes a heartbeat message


Nested Class Summary
static class MonitoredSubscriber.MonitorMessageListener
          MessageListener implementation for this subscriber
 
Nested classes/interfaces inherited from class org.apache.qpid.example.subscriber.Subscriber
Subscriber.ExampleMessageListener
 
Field Summary
protected  String _monitorDestinationName
           
 
Fields inherited from class org.apache.qpid.example.subscriber.Subscriber
_connection, _connectionFactory, _consumer, _contextHelper, _destination
 
Constructor Summary
MonitoredSubscriber()
           
 
Method Summary
 void stopMonitor()
          Stop consuming
 void subscribeAndMonitor()
          Subscribes to Queue and attaches additional monitor listener
 
Methods inherited from class org.apache.qpid.example.subscriber.Subscriber
stop, subscribe
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

_monitorDestinationName

protected String _monitorDestinationName
Constructor Detail

MonitoredSubscriber

public MonitoredSubscriber()
Method Detail

subscribeAndMonitor

public void subscribeAndMonitor()
Subscribes to Queue and attaches additional monitor listener


stopMonitor

public void stopMonitor()
Stop consuming



Licensed to the Apache Software Foundation