Add base context to pub/sub transport implementation

This MR introduces a base context when processing pub/sub transport messages, this allow us to eventually implement other transport mechanisms that support context propagation with timeouts.