messageQueue.h 316 B

1234567891011121314
  1. #ifndef OBOO_MESSAGE_QUEUE_H
  2. #define OBOO_MESSAGE_QUEUE_H
  3. #include "config.h"
  4. int initMessageQueue (char* host, int port);
  5. void destroyMessageQueue ();
  6. int sendMessage (char* topic, char* payload);
  7. int messageQueueSubscribe (char* topic);
  8. #endif // OBOO_MESSAGE_QUEUE_H