Participant Use Cases

Working with domain partcipants. More...

Working with domain partcipants.

Working with domain participants.

Turning off auto-enable of newly created participant(s)

• Get the factory

• Change the value of the ENTITY_FACTORY for the DDS::DomainParticipantFactory

  
              DomainParticipantFactoryQos factory_qos =
                  new DomainParticipantFactoryQos();
              try {
                  factory.get_qos(factory_qos);
              } catch (DDS.Exception) {
                  Console.WriteLine(
                      "***Error: failed to get domain participant factory qos");
              }
  
              // Change the QosPolicy to create disabled participants
              factory_qos.entity_factory.autoenable_created_entities = false;
  
              try {
                  factory.set_qos(factory_qos);
              } catch (DDS.Exception) {
                  Console.WriteLine(
                      "***Error: failed to set domain participant factory qos");
              }

Getting the factory

• Get the DomainParticipantFactory instance:

  DomainParticipantFactory factory =
      DomainParticipantFactory.get_instance();
  
  if (factory == null) { 
      Console.WriteLine(
          "***Error: failed to get domain participant factory");
  }

Setting up a participant

• Get the factory

• Create DomainParticipant:

  DomainParticipantQos participant_qos = new DomainParticipantQos();
  DomainParticipantListener participant_listener = null;
  
  /* Set the initial peers. These list all the computers the
     application may communicate with along with the maximum number
     of RTI Data Distribution Service participants that can
     concurrently run on that computer. This list only needs to be
     a superset of the actual list of computers and participants
     that will be running at any time. 
   */
  String[] NDDS_DISCOVERY_INITIAL_PEERS = {
      "host1",
      "10.10.30.192",
      "1@localhost",        
      "2@host2",
      "my://", // all unicast addresses on transport plugins with alias "my"
      "2@shmem://", // shared memory
      "FF00:ABCD::0",
      "sf://0/0/R", // StarFabric transport plugin
      "1@FF00:0:1234::0",
      "225.1.2.3",
      "3@225.1.0.55",
      "FAA0::0#0/0/R",        
  };
  
  // initialize participant_qos with default values
  try {
      factory.get_default_participant_qos(participant_qos);
  } catch (DDS.Exception) {
      Console.WriteLine(
          "***Error: failed to get default participant qos");
  }
  
  participant_qos.discovery.initial_peers.from_array(
          NDDS_DISCOVERY_INITIAL_PEERS);
  
  // Create the participant
  DomainParticipant participant = factory.create_participant(
      domain_id,
      participant_qos,
      participant_listener,
      StatusMask.STATUS_MASK_NONE);
  if (participant == null) {
      Console.WriteLine(
          "***Error: failed to create domain participant");
  }

Tearing down a participant

• Get the factory

• Delete DomainParticipant:

  try {
      factory.delete_participant(ref participant);
  } catch (DDS.Exception) {
      Console.WriteLine(
          "***Error: failed to delete domain participant");
  }