Repair reconnecting

[nodarret]

• repair reconnecting
• logging with exchange name instead NettyStreamingService
• removed WebSocketClientCompressionHandler.INSTANCE handler

[hlbkin]

Should we consider blockingAwait logic like here firegnome@5d09ad5?

I mean if we insert .blockingAwait after connect. in line 305?

[nodarret]

I think timeout execption should be from netty, not completable (possible memory leaks?). Also every blocking mechanism in async programing is not recommended - both netty and rxJava are async. Better way is register action on event. In my case retryWhen retry with delay when Exception is thrown and doOnComplete resubscribes if completable completes.