IPAACA

#include <sstream>

#include <iostream>

#include <fstream>

#include <ipaaca/ipaaca.h>

void initialize_ipaaca(std::string host, std::string port) {

        std::ofstream configFile;

        configFile.open("rsb.conf");

        configFile << "# (file auto-generated by EyeX component)\n";

        configFile << "[plugins.cpp]\n";

        configFile << "load = rsbspread\n";

        configFile << "path = C:\\\\Users\\\\KOMPASS\\\\repo\\\\rsb-win-scs\\\\bin\n";

        configFile << "\n";

        configFile << "[transport.socket]\n";

        configFile << "host = " << host << "\n";

        configFile << "port = " << port << "\n";

        configFile << "server = 0\n";

        configFile << "enabled = 0\n";

        configFile << "\n";

        configFile << "[transport.spread]\n";

        configFile << "host = " << host << "\n";

        configFile << "port = " << port << "\n";

        configFile << "enabled = 1\n";

        configFile.close();

        ipaaca::Initializer::initialize_backend();

}

int main()

{

        initialize_ipaaca("localhost", "4803");

        ipaaca::OutputBuffer::ptr ob = ipaaca::OutputBuffer::create("testbuf");

        ipaaca::IU::ptr iu = ipaaca::IU::create("testcategory");

        iu->payload()["hello"] = std::map<std:string, std::string>{{"1", "hello"}, {"2", "world"}, {"3", "!"}};

        ob->add(iu);

        {

                ipaaca::Locker mylocker(iu->payload());

                iu->payload()["hello"]["1"] = "hallo";

                iu->payload()["hello"]["2"] = "welt"; // Only this update will be send

        }

        return 0;

}