removed serializable since I won't write serialization

Took 12 minutes

include/KawaiiMQ/Consumer.h

@@ -27,6 +27,8 @@ namespace KawaiiMQ {
 
  explicit Consumer(std::vector<Topic> topics);
 
+ explicit Consumer(const std::string& name);
+
  /**
  * subscribe a topic
  * @param topic given topic
@@ -54,6 +56,7 @@ namespace KawaiiMQ {
 
  private:
  std::mutex mtx;
+ std::string name;
  std::vector<Topic> subscribed;
  };
 

include/KawaiiMQ/Message.h

@@ -13,31 +13,13 @@
 
 namespace KawaiiMQ {
 
- class ISerializable {
- public:
- virtual ~ISerializable() = default;
-
- /**
- * serialize the object
- * @return serialized string
- */
- virtual std::string serialize() const = 0;
-
- /**
- * deserialize the object
- * @param data serialized data
- */
- virtual void deserialize(const std::string &data) = 0;
- };
-
  class MessageData {
  public:
  MessageData() = default;
  virtual ~MessageData() = default;
  };
 
  template<typename T>
- requires std::is_base_of_v<ISerializable, T> || std::is_fundamental_v<T>
  class Message : public MessageData {
  public:
  explicit Message(T content) : content(std::move(content)) {}
@@ -47,15 +29,13 @@ namespace KawaiiMQ {
  }
 
  template<typename U>
- requires std::is_base_of_v<ISerializable, U> || std::is_fundamental_v<U>
  friend U getMessage(std::shared_ptr<MessageData> in);
 
  private:
  T content;
  };
 
  template<typename T>
- requires std::is_base_of_v<ISerializable, T> || std::is_fundamental_v<T>
  T getMessage(std::shared_ptr<MessageData> in) {
  std::shared_ptr<Message<T>> tmp = std::dynamic_pointer_cast<Message<T>>(in);
  if (tmp != nullptr) {
@@ -66,7 +46,6 @@ namespace KawaiiMQ {
  }
 
  template<typename T>
- requires std::is_base_of_v<ISerializable, T> || std::is_fundamental_v<T>
  std::shared_ptr<Message<T>> makeMessage(T content) {
  auto msg = std::make_shared<Message<T>>(content);
  return msg;

include/KawaiiMQ/Producer.h

@@ -17,6 +17,8 @@ namespace KawaiiMQ {
 
  class Producer {
  public:
+ explicit Producer(const std::string &name);
+
  /**
  * subscribe to a topic
  * @param topic topic you want to subscribe
@@ -69,9 +71,14 @@ namespace KawaiiMQ {
  }
  }
  }
+
+ std::string getName() const {
+ return name;
+ }
  private:
  std::vector<Topic> subscribed;
  std::mutex mtx;
+ std::string name;
  };
 }
 

src/Consumer.cpp

@@ -72,4 +72,8 @@ namespace KawaiiMQ {
  return ret;
  }
 
+ Consumer::Consumer(const std::string &name): name(name) {
+
+ }
+
 }

src/Producer.cpp

@@ -36,4 +36,8 @@ namespace KawaiiMQ {
  }
  subscribed.erase(std::remove(subscribed.begin(), subscribed.end(), topic));
  }
+
+ Producer::Producer(const std::string &name) {
+ this->name = name;
+ }
 }