org.apache.qpid.example.publisher
Class MonitorPublisher
java.lang.Object
org.apache.qpid.example.publisher.Publisher
org.apache.qpid.example.publisher.MonitorPublisher
public class MonitorPublisher
- extends Publisher
Subclass of Publisher which uses QPID functionality to send a heartbeat message Note immediate flag not available via
JMS MessageProducer
Field Summary |
(package private) org.apache.qpid.client.BasicMessageProducer |
_producer
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
_producer
org.apache.qpid.client.BasicMessageProducer _producer
MonitorPublisher
public MonitorPublisher()
sendMessage
public boolean sendMessage(Session session,
Message message,
int deliveryMode,
boolean immediate,
boolean commit)
throws UndeliveredMessageException
- Throws:
UndeliveredMessageException
sendImmediateMessage
public boolean sendImmediateMessage(Message message)
throws UndeliveredMessageException
- Throws:
UndeliveredMessageException
Licensed to the Apache Software Foundation