equal
deleted
inserted
replaced
53 } currentRelation; |
53 } currentRelation; |
54 |
54 |
55 public: |
55 public: |
56 |
56 |
57 ZeroMQHandler(Configuration configuration) : configuration(configuration), zmqSocket(zmqContext, zmq::socket_type::push) { |
57 ZeroMQHandler(Configuration configuration) : configuration(configuration), zmqSocket(zmqContext, zmq::socket_type::push) { |
58 zmqSocket.connect(convertor.to_bytes(configuration.endpointUrl)); |
58 zmqSocket.connect(convertor.to_bytes(configuration.connectionString)); |
59 } |
59 } |
60 |
60 |
61 void startRelation(relpipe::common::type::StringX name, std::vector<relpipe::reader::handlers::AttributeMetadata> attributes) override { |
61 void startRelation(relpipe::common::type::StringX name, std::vector<relpipe::reader::handlers::AttributeMetadata> attributes) override { |
62 currentRelation = CurrentRelation{name, attributes}; |
62 currentRelation = CurrentRelation{name, attributes}; |
63 } |
63 } |