Use BidirectionalTopicClient from policy-common