Queue writes should support a Timeout

Currently the Queue API supports `push` but does not take a timeout. We should consider adding something akin to the Java [BlockingQueue.offer](https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/BlockingQueue.html#offer(E,%20long,%20java.util.concurrent.TimeUnit)) method.

This would be useful for the Logstash HTTP input and other request response protocols. These protocols expect operations to be completed relatively quickly, with the client retrying if necessary. Elasticsearch does this with the 429 response code.