The idea is to add another parameter to the function RPCCLient as:
client = oslo_messaging.RPCClient(transport, target, options={'mandatory': True})
client.call({}, 'foo', id_value=str(i), test_value="hello oslo")Inside the function, _publish decode the option value, as: