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: