Fix avro message broker failing tests.
Refactor transport implementation to be more flexible
with different protocol/codec implementations.
Add JSON codec for testing purposes.