Publisher Use Cases

The following #includes are needed for the examples on this page

#include <dds/pub/ddspub.hpp>
#include <dds/domain/ddsdomain.hpp>
#include <dds/core/ddscore.hpp>

Setting up a publisher

• Set up participant

• Create a Publisher with each of the available constructors

      // Create the participant
      dds::domain::DomainParticipant participant(0);
  
      // When not explicitly provided to the constructor, the 
      // created publisher's QoS is default, has a NULL listener, and a status mask
      // dds::core::status::StatusMask::all()
  
      // Creating a publisher
      dds::pub::Publisher publisher1(participant);
  
      // Creating a publisher with modified QoS
      dds::pub::qos::PublisherQos qos;
      qos << rti::core::policy::EntityName("PublisherName");
      dds::pub::Publisher publisher2(participant, qos);
  
      // Creating a publisher with modified QoS and a listener
      ExamplePublisherListener *listener = new ExamplePublisherListener;
      dds::pub::Publisher publisher3(participant, qos, listener);
  
      // Creating a publisher with modified QoS, a listener, and a sample_rejected() 
      // status mask
      dds::pub::Publisher publisher4(
         participant, qos, listener, dds::core::status::StatusMask::offered_deadline_missed());
  
      // Creating an entity with a listener automatically retains the entity, so 
      // we must either explicitly close the Publihser...
      publisher3.close();
      
      // ... or set the listener to null
      publisher4.listener(NULL, dds::core::status::StatusMask::none());

Looking up Publishers

• Lookup Publishers

  void howto_lookup_publishers()
  {
      dds::domain::DomainParticipant participant(0);
  
      // Create three Publishers and retain them
      create_and_retain_publisher(participant);
      create_and_retain_publisher(participant);
      create_and_retain_publisher(participant);
  
      // We don't have any references to the created Publishers but we can look 
      // them up using the participant that they were created with
      std::vector<dds::pub::Publisher> publishers1;
  
      // publisher_count will equal 3 and publishers1 will hold a reference to 
      // each of the three publishers that were created
      int publisher_count = 
          rti::pub::find_publishers(participant, std::back_inserter(publishers1));
  
      // rti::pub::publishers also takes a forward iterator and a max number of
      // publishers to look up
      std::vector<dds::pub::Publisher> publishers2(2, dds::pub::Publisher(dds::core::null));
  
      // publisher_count will equal 2 because we're only asking for 2
      publisher_count = 
          rti::pub::find_publishers(participant, publishers2.begin(), 2);
  
      // We retained the publishers so we must close them now
      for (std::vector<dds::pub::Publisher>::iterator it = publishers1.begin();
            it != publishers1.end(); 
            it++) {
          (*it).close();
      }
  }
  
  void create_and_retain_publisher(dds::domain::DomainParticipant &participant)
  {
      dds::pub::Publisher publisher(participant);
      publisher.retain();
  }

Tearing down a publisher

• See Tearing Down An Entity for eamples of the various ways to teardown a Publisher