equal
deleted
inserted
replaced
45 namespace zeromq { |
45 namespace zeromq { |
46 |
46 |
47 void ZeroMQCommand::process(std::shared_ptr<writer::RelationalWriter> writer, Configuration& configuration) { |
47 void ZeroMQCommand::process(std::shared_ptr<writer::RelationalWriter> writer, Configuration& configuration) { |
48 zmq::context_t zmqContext; |
48 zmq::context_t zmqContext; |
49 zmq::socket_t zmqSocket(zmqContext, zmq::socket_type::pull); |
49 zmq::socket_t zmqSocket(zmqContext, zmq::socket_type::pull); |
50 zmqSocket.bind(convertor.to_bytes(configuration.endpointUrl)); |
50 zmqSocket.bind(convertor.to_bytes(configuration.connectionString)); |
51 |
51 |
52 |
52 |
53 if (false) { |
53 if (false) { |
54 // TODO: optionally generate and print keys and/or do encryption |
54 // TODO: optionally generate and print keys and/or do encryption |
55 char server_public_key[41]; |
55 char server_public_key[41]; |