feat: add task manager and queue message tasks in agent

src/agent/include/agent.hpp

@@ -1,8 +1,18 @@
 #pragma once
 
+#include <task_manager.hpp>
+
+#include <queue>
+#include <string>
+
 class Agent
 {
 public:
     Agent();
     ~Agent();
+
+private:
+    std::queue<std::string> m_messageQueue;
+
+    TaskManager m_taskManager;
 };

src/agent/src/agent.cpp

@@ -1,5 +1,20 @@
 #include "agent.hpp"
 
-Agent::Agent() {}
+#include <message_task.hpp>
 
-Agent::~Agent() {}
+#include <chrono>
+#include <thread>
+
+Agent::Agent()
+{
+    m_taskManager.start(std::thread::hardware_concurrency());
+    m_taskManager.enqueueTask(StatefulMessageProcessingTask(m_messageQueue));
+    m_taskManager.enqueueTask(StatelessMessageProcessingTask(m_messageQueue));
+}
+
+Agent::~Agent()
+{
+    // Sleep for 2 seconds
+    std::this_thread::sleep_for(std::chrono::seconds(2));
+    m_taskManager.stop();
+}