replierProcess.hpp

#ifndef UMPS_PROXY_SERVICES_COMMAND_REPLIER_PROCESS_HPP
#define UMPS_PROXY_SERVICES_COMMAND_REPLIER_PROCESS_HPP
#include <memory>
#include <chrono>
#include <functional>
#include "umps/modules/process.hpp"
namespace UMPS
{
 namespace Services::ConnectionInformation
 {
  class Requestor;
 }
 namespace Logging
 {
  class ILog;
 }
 namespace Messaging
 {
  class Context;
 }
 namespace MessageFormats
 {
  class IMessage;
 }
 namespace ProxyServices::Command
 {
  class ModuleDetails;
  class ReplierOptions;
  class Replier;
 }
}
namespace UMPS::ProxyServices::Command
{
class ReplierProcess : public UMPS::Modules::IProcess
{
public:
 
    ReplierProcess();
    explicit ReplierProcess(std::shared_ptr<UMPS::Logging::ILog> &logger);
    explicit ReplierProcess(std::shared_ptr<UMPS::Messaging::Context> &context);
    ReplierProcess(std::shared_ptr<UMPS::Messaging::Context> &context,
                   std::shared_ptr<UMPS::Logging::ILog> &logger);
 
 
    void initialize(const ReplierOptions &options);
    [[nodiscard]] bool isInitialized() const noexcept;
    [[nodiscard]] std::string getName() const noexcept override;
 
 
    void start() override;
    [[nodiscard]] bool isRunning() const noexcept override;
 
 
    void stop() override;
 
 
    ~ReplierProcess() override;
private:
    class ReplierProcessImpl;
    std::unique_ptr<ReplierProcessImpl> pImpl;
};
std::unique_ptr<ReplierProcess>
    createReplierProcess(const UMPS::Services::ConnectionInformation::Requestor &requestor,
                         const ModuleDetails &moduleDetails,
                         const std::function<std::unique_ptr<UMPS::MessageFormats::IMessage>
                                 (const std::string &messageType, const void *data, size_t length)> &callback,
                         const std::string &iniFile,
                         const std::string &section = "ModuleRegistry",
                         std::shared_ptr<UMPS::Messaging::Context> context = nullptr,
                         std::shared_ptr<UMPS::Logging::ILog> logger = nullptr);
}
#endif