We should not send any data if channel is closed:

```
case message, open := <-consumer.in:
    if !open {
        consumer.conn.Close()
        return
    } else {
        conn.SetWriteDeadline(time.Now().Add(consumer.es.timeout))
        _, err := conn.Write(message)
        if err != nil {
            // ...
        }
    }