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

brokers leak because of exception at broker.flush call