org.apache.qpid.example.publisher
Class MonitorMessageDispatcher
java.lang.Object
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
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 |
_monitorPublisher
protected static MonitorPublisher _monitorPublisher
DEFAULT_MONITOR_PUB_NAME
protected static final String DEFAULT_MONITOR_PUB_NAME
- See Also:
- Constant Field Values
MonitorMessageDispatcher
public MonitorMessageDispatcher()
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