File content as of revision 0:3b4906b8a747:

#ifndef _COMMUNICATION_H_
#define _COMMUNICATION_H_

#include "mbed.h"
#include "MQTTNetwork.h"
#include "MQTTClient.h"
#include "MQTTmbed.h"


typedef struct {
    int    speed; // speed for AccCar, -1 for Road
    int    position; // position for AccCar, update number for Road
    char*  topic;
} message_t;

class Communication {
public:
    static EventFlags control_flags; // For cars waiting on speed control
    static EventFlags sync_flags;
    static int speeds[5];
    static int sync;
    static int flags[5];
    
    // Singleton
    static Communication *getInstance();
    
    // MQTT Setup
    void setup_wifi();
    void setup_mqtt(MQTTNetwork &network);
    static void message_arrived(MQTT::MessageData& md);
    static void control_arrived(MQTT::MessageData& md);
    static void sync_arrived(MQTT::MessageData& md);
    int send_message(char* topic);
    int subscribe_to_topic_position(char* topic);
    int subscribe_to_topic_control(char* topic);
    int subscribe_to_topic_sync(char* topic);
    void publish_car(char* topic, int speed, int position);
    void publish_road(char* topic, int num);
    void start(); // function for serving requests (single thread)
    void reset(); // function to create and start the singleton thread
    void stop();
    
private:
    static Communication *singleton;
    
    WiFiInterface *wifi;
    MQTT::Client<MQTTNetwork, Countdown> *client;
    Thread* thread;
    
    MemoryPool<message_t, 10> mpool;
    Queue<message_t, 10> q_car;
    
    Communication();
    
};

#endif