Redis sink
Modified the logstash source API