QueueSenderModel.hpp

Go to the documentation of this file.

 
#ifndef IOMANAGER_INCLUDE_IOMANAGER_QUEUE_QUEUESENDERMODEL_HPP_
#define IOMANAGER_INCLUDE_IOMANAGER_QUEUE_QUEUESENDERMODEL_HPP_
 
#include "iomanager/Sender.hpp"
 
#include <memory>
#include <string>
 
namespace dunedaq::iomanager {
 
// QImpl
template<typename Datatype>
class QueueSenderModel : public SenderConcept<Datatype>
{
public:
  explicit QueueSenderModel(ConnectionId const& request);
 
  QueueSenderModel(QueueSenderModel&& other);
 
  void send(Datatype&& data, Sender::timeout_t timeout) override;
 
  bool try_send(Datatype&& data, Sender::timeout_t timeout) override;
 
  void send_with_topic(Datatype&& data, Sender::timeout_t timeout, std::string) override;
 
  bool is_ready_for_sending(Sender::timeout_t timeout) override;
 
private:
  std::shared_ptr<Queue<Datatype>> m_queue;
};
 
} // namespace dunedaq::iomanager
 
#include "detail/QueueSenderModel.hxx"
 
#endif // IOMANAGER_INCLUDE_IOMANAGER_QUEUE_QUEUESENDERMODEL_HPP_