org.apache.qpid.example.publisher
Class MonitorMessageDispatcher

java.lang.Object
  extended by org.apache.qpid.example.publisher.MonitorMessageDispatcher

public class MonitorMessageDispatcher
extends Object

Class that sends heartbeat messages to allow monitoring of message consumption Sends regular (currently 20 seconds apart) heartbeat message


Field Summary
protected static MonitorPublisher _monitorPublisher
           
protected static String DEFAULT_MONITOR_PUB_NAME
           
 
Constructor Summary
MonitorMessageDispatcher()
           
 
Method Summary
static void cleanup()
          Cleanup publishers
static void main(String[] args)
          Easy entry point for running a message dispatcher for monitoring consumption Sends 1000 messages with no delay
static void publish()
          Publish heartbeat message
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

_monitorPublisher

protected static MonitorPublisher _monitorPublisher

DEFAULT_MONITOR_PUB_NAME

protected static final String DEFAULT_MONITOR_PUB_NAME
See Also:
Constant Field Values
Constructor Detail

MonitorMessageDispatcher

public MonitorMessageDispatcher()
Method Detail

main

public static void main(String[] args)
Easy entry point for running a message dispatcher for monitoring consumption Sends 1000 messages with no delay

Parameters:
args -

publish

public static void publish()
                    throws JMSException,
                           UndeliveredMessageException
Publish heartbeat message

Throws:
JMSException
UndeliveredMessageException

cleanup

public static void cleanup()
Cleanup publishers



Licensed to the Apache Software Foundation