startProducers.cpp

#include <thread>
#include <iostream>
#include <unistd.h>

#include "RESTManager.h"
#include "Producer.h"


using namespace std;

/*
 * 
 */
int main(int argc, char** argv) {
    
    mosquitto_lib_init();
    RESTManager manager(NULL, 0);
    manager.initStructure();
    
    const char* brokerIp = manager.getConfig("BrokerIp").c_str();
    const char* farmProducts[] = {"Milk", "Cheese"};
    const char* marketProducts[] = {"Bread", "Juice"};
    
    char* addr = strdup(brokerIp);
    
    Producer farm1("farm1", addr, farmProducts, 2);
    Producer farm2("farm2", addr, farmProducts, 2);
    Producer market1("markt1", addr, marketProducts, 2);
    Producer market2("markt2", addr, marketProducts, 2);
    
    
    thread tFarm1(&Producer::start, &farm1);
    thread tFarm2(&Producer::start, &farm2);
    thread tMarket1(&Producer::start, &market1);
    thread tMarket2(&Producer::start, &market2);
    
    tFarm1.join();
    tFarm2.join();
    tMarket1.join();
    tMarket2.join();
    
    
    //farm1.start();
    //farm2.start();
    //market1.start();
    //market2.start();
    
    sleep(2);
    
    free(addr);
    mosquitto_lib_cleanup();
    printf("End\n");
    
    return 0;
}