org.apache.qpid.example.publisher
Class MonitorPublisher

java.lang.Object
  extended by org.apache.qpid.example.publisher.Publisher
      extended by 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
           
 
Fields inherited from class org.apache.qpid.example.publisher.Publisher
_connection, _contextHelper, _defaultDestinationDir, _destination, _destinationDir, _name, _session
 
Constructor Summary
MonitorPublisher()
           
 
Method Summary
 boolean sendImmediateMessage(Message message)
           
 boolean sendMessage(Session session, Message message, int deliveryMode, boolean immediate, boolean commit)
           
 
Methods inherited from class org.apache.qpid.example.publisher.Publisher
cleanup, getDestinationDir, getName, getSession, sendMessage, sendMessage, setDestinationDir, setName
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

_producer

org.apache.qpid.client.BasicMessageProducer _producer
Constructor Detail

MonitorPublisher

public MonitorPublisher()
Method Detail

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