Class ZMQSerializer

Inheritance Relationships

Base Type

  • public IProcessor

Class Documentation

class ZMQSerializer : public IProcessor

Public Functions

ZMQSerializer()
void CreatePorts() override
void Preprocess(ProcessingContext &context) override
void Process(ProcessingContext &context) override
void Postprocess(ProcessingContext &context) override

Protected Attributes

PortIn<AnyType> *data_port_
options::Value<unsigned int, false> port_ = {7777}
options::Value<Serialization::Encoding, false> encoding_{Serialization::Encoding::BINARY}
options::Value<Serialization::Format, false> format_{Serialization::Format::FULL}
options::Bool interleave_ = {false}
std::vector<std::unique_ptr<zmq::socket_t>> sockets_
std::vector<uint64_t> packetid_
std::unique_ptr<Serialization::Serializer> serializer_