cm_publisher.h

/*
 * Developer : Alexey Zakharov (alexey.zakharov@vectioneer.com)
 * All rights reserved. Copyright (c) 2016 VECTIONEER.
 */
 
#ifndef CM_PUBLISHER_H
#define CM_PUBLISHER_H
 
#include "ct_module.h"
#include "cm_conndata.h"
 
namespace mcx::comm {
 
class BaseRequestReply;
 
class BasePublisher;
 
class Publisher : public container::Module {
public:
 
  Publisher(const BaseRequestReply& req, ConnectionData url);
 
  ~Publisher() override;
 
private:
 
  void create_(const char* name, parameter_server::Parameter* parameter_server, uint64_t dt_micro_s) override {};
 
  bool initPhase1_() override;
 
  bool initPhase2_() override { return true; };
 
  bool startOp_() override;
 
  bool iterateOp_(const container::TaskTime& system_time, container::UserTime* user_time) override;
 
  bool stopOp_() override;
 
  BasePublisher* pub_;
  ConnectionData url_;
 
};
 
}  // namespace mcx::comm
 
#endif /* CM_PUBLISHER_H */