brokers leak because of exception at broker.flush call
Merge pull request #1 from shabanovd/develop

brokers leak because of exception at broker.flush call