Try to flush messages in the queue individually if queue can't be read
into a list.
Merge pull request #121 from segmentio/prateek/flush-queue

Try to flush messages in the queue individually if queue can't be read