SinkRunner

class savant.client.runner.sink.SinkRunner(socket, log_provider, idle_timeout, module_health_check_url, module_health_check_timeout, module_health_check_interval, receive_timeout=1000, receive_hwm=50)

Receives messages from ZeroMQ socket.