followKafkaRequestProvider.h

Go to the documentation of this file.

#ifndef __followKafkaRequestProvider_h__
#define __followKafkaRequestProvider_h__
#include "followJsonRequestProvider.h"
#include "kafkaQueue.h"
class followKafkaRequestProvider: public followJsonRequestProvider {
  private:
    static factoryTemplate<followKafkaRequestProvider> factory;
    static messageQueue::kafka kafkaInQueue;
    void followStream(std::istream& stream) override;
  public:
    followKafkaRequestProvider(decltype(requests) aRequests,
                               decltype(delayedRequests) aDelayedRequests,
                               decltype(parents) aParents,
                               decltype(InputHandler) aInputHandler,
                               decltype(OutputHandler) aOutputHandler):
        followJsonRequestProvider(aRequests, aDelayedRequests, aParents,
                                  aInputHandler, aOutputHandler) {
        kafkaInQueue.init(true);
    };
    ~followKafkaRequestProvider() override = default;
    void processSources(const std::vector<std::string>& sources) override;
};
 
 
 
#endif