ZmqPubExtractor.h

Go to the documentation of this file.

#ifndef ZMQ_PUB_EXTRACTOR_H
#define ZMQ_PUB_EXTRACTOR_H

#include <utils.h>
#include <Extractor.h>

class ZmqPubExtractor : public Extractor {
public:
    ZmqPubExtractor(zmq::context_t & _ctx,
                    const PubSubEndpoint & _source,
                    const PubSubEndpoint & _destination,
                    const Roi<unsigned int> & _roi);
    ~ZmqPubExtractor();
    std::string type();
    std::string identifier();
    std::list<std::string> parameters();
private:
    PubSubEndpoint destination;
    Roi<unsigned int> roi;
    
    zmq::socket_t * destinationSocket;
    
    void extractSetup();
    void extractImpl(unsigned int width,
                     unsigned int height,
                     unsigned int bytesPerPixel,
                     uint64_t highResTime,
                     uint64_t wallTime,
                     zmq::message_t * sourceImage);
    void extractTeardown();
};

#endif /* ZMQ_PUB_EXTRACTOR_H */