CoSSB.h

#ifndef COSSB_H_INCLUDED
#define COSSB_H_INCLUDED
 
#include <time.h>
#include "./Queue.h"
#include "./CoSGC.h"
 
/*Type for function pointer to callback */
typedef void (* func)(char *);
 
 
/* Struct for Topics */
 
typedef struct SubscribtionList 
 {
    const char* topic; 
    size_t numberOfSubscribers;     
    func* callBackList; 
} SubscribtionList;
 
typedef struct TopicList 
{
    SubscribtionList* list; 
    size_t numberOfTopics;
} TopicList;
 
 
extern Queue* queue;
 
TopicList topicList;
// ---------------------------------------------- Functions ----------------------------------------------------
void initCoSSB();
 
void deleteCoSSB();
 
 
void publish(char* rdfG);
 
void addSubscribtion(char* topic, func callback);
 
#endif /* COSSB_H_INCLUDED */