Observables and amqp

- (cikl/cikl#69) Emit event/observable format
- (cikl/cikl#41) Retry connection if socket is closed