diff --git a/receiver/jfjoch_receiver.cpp b/receiver/jfjoch_receiver.cpp index 63c70fabc..f8e7a0c9e 100644 --- a/receiver/jfjoch_receiver.cpp +++ b/receiver/jfjoch_receiver.cpp @@ -152,13 +152,13 @@ int main(int argc, char **argv) { } if (input.contains("compression_threads")) { - service.NumThreads(input["compression_threads"]); - logger.Info("Compression threads {}", input["compression_threads"]); + service.NumThreads(input["compression_threads"].get()); + logger.Info("Compression threads {}", input["compression_threads"].get()); } if (input.contains("send_buffer_count")) { - service.SendBufferCount(input["send_buffer_count"]); - logger.Info("Send buffer count {}", input["send_buffer_count"]); + service.SendBufferCount(input["send_buffer_count"].get()); + logger.Info("Send buffer count {}", input["send_buffer_count"].get()); } auto server = gRPCServer(grpc_addr, service);