Server Code:
from oslo_config import cfg
import oslo_messaging as messaging
from handler import Handler

endpoints = [
        Handler(),
]

serializer = messaging.RequestContextSerializer(messaging.JsonPayloadSerializer())
transport = messaging.get_transport(cfg.CONF)
target = messaging.Target(topic="testQ",server="localhost")
rpc_server = messaging.get_rpc_server(transport,target,endpoints,serializer=serializer)
print "starting rpc server"
rpc_server.start()
print "waiting for request"
rpc_server.wait()


Client Code:
from oslo_config import cfg
import oslo_messaging as om

transport = om.get_transport(cfg.CONF)
target = om.Target(topic='testQ')

client = om.RPCClient(transport, target)
ctxt ={}
print "making Call"
client.cast(ctxt,'render_graph',message="hello1234"


Handler Code:
class Handler(object):

    def render_graph(self,ctxt,message):
        print message;