implement synchronous subscription (ATDAQCCMRS-41) in C++