Virtual-Device-Simulator

Example Usages of Process Communication Interface with Publisher and Subscriber Classes

Python

This example demonstrates how to use the Publisher and Subscriber classes from the comm_interface module in a Python script.

from comm_interface import Publisher, Subscriber
import time

Subscriber

# Initialize the subscriber
local_address = "tcp://localhost:5555"
subscriber = Subscriber(local_address)
counter = 0

# Receive 5 messages from the publisher
while counter < 5:
    subscriber.receive()
    counter += 1

Publisher

# Initialize the publisher
local_address = "tcp://localhost:5555"
publisher = Publisher(local_address, "example_process")
counter = 0

# Publish 5 messages
while counter < 5:
    time.sleep(2)
    message = "Example message"
    publisher.publish(message)
    counter += 1

C++

This example demonstrates how to use the Publisher and Subscriber classes from the CommInterface.hpp in a C++ program.

#include "CommInterface.hpp"
#include <string>
#include <unistd.h>

Subscriber

int main() {
    // Initialize the subscriber
    std::string localAddress = "tcp://localhost:5555";
    Subscriber subscriber(localAddress);
    counter = 0;

    // Receive 5 messages from the publisher
    while (counter < 5) {
        subscriber.receive();
        ++counter;
    }

    return 0;
}

Publisher

int main() {
    // Initialize the publisher
    std::string localAddress = "tcp://localhost:5555";
    Publisher publisher(localAddress, "example_process");
    int counter = 0;

    // Publish 5 messages
    while (counter < 5) {
        sleep(2);
        publisher.publish("Example message" + std::to_string(counter));
        ++counter;
    }
}

This site is open source. Improve this page.