Specs for consumer connection

Improve unit test coverage
Specs for producer connection

Improve unit test coverage
Specs for connection

Improve unit test coverage