dds::pub::PublisherListener Class Reference

Publisher events Listener. More...

#include "PublisherListener.hpp"

Inherits dds::pub::AnyDataWriterListener.

Inherited by dds::domain::DomainParticipantListener [virtual], and dds::pub::NoOpPublisherListener [virtual].

Public Member Functions
virtual void	on_liveliness_lost (dds::pub::AnyDataWriter &writer, const ::dds::core::status::LivelinessLostStatus &status)=0
virtual void	on_offered_deadline_missed (dds::pub::AnyDataWriter &writer, const ::dds::core::status::OfferedDeadlineMissedStatus &status)=0
virtual void	on_offered_incompatible_qos (dds::pub::AnyDataWriter &writer, const ::dds::core::status::OfferedIncompatibleQosStatus &status)=0
virtual void	on_publication_matched (dds::pub::AnyDataWriter &writer, const ::dds::core::status::PublicationMatchedStatus &status)=0

Detailed Description

Publisher events Listener.

Since a Publisher is an Entity, it has the ability to have a Listener associated with it. In this case, the associated Listener should be of type PublisherListener. This interface must be implemented by the application. A user-defined class must be provided by the application which must extend from the PublisherListener class.

All operations for this interface must be implemented in the user-defined class, it is up to the application whether an operation is empty or contains some functionality.

The PublisherListener provides a generic mechanism (actually a callback function) for the Data Distribution Service to notify the application of relevant asynchronous status change events, such as a missed deadline, violation of a QosPolicy setting, etc. The PublisherListener is related to changes in communication status StatusConditions.

// Application example listener
class ExampleListener :
               public virtual dds::pub::PublisherListener
{
public:
    virtual void on_offered_deadline_missed (
        dds::pub::AnyDataWriter& writer,
        const dds::core::status::OfferedDeadlineMissedStatus& status)
    {
        std::cout << "on_offered_deadline_missed" << std::endl;
    }
 
    virtual void on_offered_incompatible_qos (
        dds::pub::AnyDataWriter& writer,
        const dds::core::status::OfferedIncompatibleQosStatus& status)
    {
        std::cout << "on_offered_incompatible_qos" << std::endl;
    }
 
    virtual void on_liveliness_lost (
        dds::pub::AnyDataWriter& writer,
        const dds::core::status::LivelinessLostStatus& status)
    {
        std::cout << "on_liveliness_lost" << std::endl;
    }
 
    virtual void on_publication_matched (
        dds::pub::AnyDataWriter& writer,
        const dds::core::status::PublicationMatchedStatus& status)
    {
        std::cout << "on_publication_matched" << std::endl;
    }
};
 
// Create Publisher with the listener
dds::domain::DomainParticipant participant(org::eclipse::cyclonedds::domain::default_id());
dds::pub::Publisher publisher(participant,
                              participant.default_publisher_qos(),
                              new ExampleListener(),
                              dds::core::status::StatusMask::all());

See also

Publisher

Listener information

Definition at line 103 of file PublisherListener.hpp.

Member Function Documentation

on_liveliness_lost()

virtual void dds::pub::AnyDataWriterListener::on_liveliness_lost ( dds::pub::AnyDataWriter &  writer, const ::dds::core::status::LivelinessLostStatus &  status  )

pure virtualinherited

This operation is called by the Data Distribution Service when the LivelinessLostStatus changes.

This operation will only be called when the relevant DataWriterListener is installed and enabled for the liveliness lost status (StatusMask::liveliness_lost()). The liveliness lost status will change when the liveliness that the DataWriter has committed through its LivelinessQosPolicy was not respected. In other words, the DataWriter failed to actively signal its liveliness within the offered liveliness period. As a result, the DataReader objects will consider the DataWriter as no longer “alive”.

Parameters

writer	contains a pointer to the DataWriter on which the LivelinessLostStatus has changed (this is an input to the application).
status	contains the LivelinessLostStatus object (this is an input to the application).

on_offered_deadline_missed()

virtual void dds::pub::AnyDataWriterListener::on_offered_deadline_missed ( dds::pub::AnyDataWriter &  writer, const ::dds::core::status::OfferedDeadlineMissedStatus &  status  )

pure virtualinherited

This operation is called by the Data Distribution Service when the OfferedDeadlineMissedStatus changes.

This operation will only be called when the relevant DataWriterListener is installed and enabled for the offered deadline missed status (StatusMask::offered_deadline_missed()). The offered deadline missed status will change when the deadline that the DataWriter has committed through its DeadlineQosPolicy was not respected for a specific instance.

Parameters

writer	contain a pointer to the DataWriter on which the OfferedDeadlineMissedStatus has changed (this is an input to the application)
status	contain the OfferedDeadlineMissedStatus object (this is an input to the application).

on_offered_incompatible_qos()

virtual void dds::pub::AnyDataWriterListener::on_offered_incompatible_qos ( dds::pub::AnyDataWriter &  writer, const ::dds::core::status::OfferedIncompatibleQosStatus &  status  )

pure virtualinherited

This operation called by the Data Distribution Service when the OfferedIncompatibleQosStatus changes.

This operation will only be called when the relevant DataWriterListener is installed and enabled for the StatusMask::offered_incompatible_qos(). The incompatible Qos status will change when a DataReader object has been discovered by the DataWriter with the same Topic and a requested DataReaderQos that was incompatible with the one offered by the DataWriter.

Parameters

writer	contain a pointer to the DataWriter on which the OfferedIncompatibleQosStatus has changed (this is an input to the application).
status	contain the OfferedIncompatibleQosStatus object (this is an input to the application).

on_publication_matched()

virtual void dds::pub::AnyDataWriterListener::on_publication_matched ( dds::pub::AnyDataWriter &  writer, const ::dds::core::status::PublicationMatchedStatus &  status  )

pure virtualinherited

This operation is called by the Data Distribution Service when a new match has been discovered for the current publication, or when an existing match has ceased to exist.

Usually this means that a new DataReader that matches the Topic and that has compatible Qos as the current DataWriter has either been discovered, or that a previously discovered DataReader has ceased to be matched to the current DataWriter. A DataReader may cease to match when it gets deleted, when it changes its Qos to a value that is incompatible with the current DataWriter or when either the DataWriter or the DataReader has chosen to put its matching counterpart on its ignore-list using the dds::sub::ignore or dds::pub::ignore operations.

it will only be called when the relevant DataWriterListener is installed and enabled for the StatusMask::publication_matched().

Parameters

writer	contains a pointer to the DataWriter for which a match has been discovered (this is an input to the application provided by the Data Distribution Service).
status	contains the PublicationMatchedStatus object (this is an input to the application provided by the Data Distribution Service).

---

The documentation for this class was generated from the following file:

• dds/pub/PublisherListener.hpp