Creates a connection to a publish/subscribe service for this CA.
It is transactional, delaying requests to this service until the message commits.
It also keeps track of subscribed topics to provide transparent recovery during failures or migration.
- Source: