Add CloseableQueue to prevent endless consumer freezing

[heckad]

This pull request adds the CloseableQueue class which have a close method. Now if _reader_task unexpected close with any exception we call close method which report to all listeners that no new messages will be delivered (current messages in the queue will be freely received until the end). This should make problems explicit instead of freezing forever for some unknown reason.

Related to #62