ddtDataProducer.hpp

Go to the documentation of this file.

 
#ifndef DDTDATAPRODUCER_HPP_
#define DDTDATAPRODUCER_HPP_
 
#include "ddt/ddtProducerConsumerBase.hpp"
 
namespace mal = ::elt::mal;
namespace datatransfer = ::elt::ddt::datatransfer;
 
static const std::chrono::milliseconds PUBLISH_TIMEOUT{450};
 
namespace ddt {

class DdtDataProducer : public DdtProducerConsumerBase {
 public:
  explicit DdtDataProducer(DdtLogger* logger);

  DdtDataProducer(const std::string& data_stream_identifier,
                  const int32_t latency, const int32_t deadline,
                  const std::string publishing_uri, DdtLogger* logger);

  ~DdtDataProducer() override;

  void Publish(DataPacket data_packet);

  void Notify(const NotificationType type) override;

  std::string get_publishing_uri() const;
 
 private:
  void Initialize(const std::string& data_stream_identifier,
                  const int32_t latency, const int32_t deadline,
                  const std::string pub_uri, DdtLogger* ddt_logger);

  std::string CreatePublishingUri(
      const std::string& data_stream_identifier) const;
 
  std::unique_ptr<mal::ps::InstancePublisher<datatransfer::DataPacket>,
                  std::default_delete<
                      mal::ps::InstancePublisher<datatransfer::DataPacket> > >
      data_publisher;
  std::shared_ptr<datatransfer::DataPacket> ddt_data_packet;
 
  double timestamp_prev;
  std::string publishing_uri;
};
 
}  // namespace ddt
 
#endif /* DDTDATAPRODUCER_HPP_ */