Future(Stream.continually(bfIn.readLine).foreach { message =>
    q.enqueue((System.nanoTime, DateTime.now(DateTimeZone.UTC), message))
})