MessageQueueCore.h

Go to the documentation of this file.

#ifndef LINTEL_MESSAGEQUEUECORE_H
#define LINTEL_MESSAGEQUEUECORE_H
 
#include <chrono>
#include <cstddef>
#include <cstdint>
#include <memory>
#include <string>
 
namespace lintel {
class MessageQueueCore
{
private:
  struct Impl;
  std::unique_ptr<Impl> m_impl;
 
public:
  MessageQueueCore(std::string name, int32_t msgCount, std::size_t msgSize);
 
  ~MessageQueueCore();
 
  MessageQueueCore(const MessageQueueCore &) = delete;
 
  MessageQueueCore &operator=(const MessageQueueCore &) = delete;
 
  static void removeOf(const std::string &messageQueueName);
 
  static int32_t numberMessagesOfIfExistsOf(const std::string &messageQueueName);
 
  [[nodiscard]] int32_t numberMessagesOf() const;
 
  void sendOf(const void *message, std::size_t size);
 
  bool trySendOf(const void *message, std::size_t size);
 
  bool sendOfWithTimeout(const void *message, std::size_t size, const std::chrono::milliseconds &timeout);
 
  void receiveOf(void *message, std::size_t size);
 
  bool tryReceiveOf(void *message, std::size_t size);
};
 
}// namespace lintel
#endif// LINTEL_MESSAGEQUEUECORE_H