davidszotten · June 11, 2015 14:45 · davidszotten · Jun 12, 2015
diff --git a/README.txt b/README.txt
 add `import pdb; pdb.set_trace()` to `RpcConsumer.handle_message` and `ReplyListener.handle_message`
diff --git a/client.py b/client.py
 import eventlet

 from nameko.rpc import RpcProxy
 from nameko.testing.services import once


 class MyClient(object):
    name = 'my_client'

    server_rpc = RpcProxy('my_server')


    @once
    def caller(self):
        eventlet.sleep(.1)  # `once` fires too early (bug?)

        import pdb; pdb.set_trace()
        print self.server_rpc.my_method(value=12)
diff --git a/server.py b/server.py
 from nameko.rpc import rpc


 class MyServer(object):
    name = 'my_server'

    @rpc
    def my_method(self, value):
        return value + 1
	import eventlet

	from nameko.rpc import RpcProxy
	from nameko.testing.services import once


	class MyClient(object):
	name = 'my_client'

	server_rpc = RpcProxy('my_server')


	@once
	def caller(self):
	eventlet.sleep(.1) # `once` fires too early (bug?)

	import pdb; pdb.set_trace()
	print self.server_rpc.my_method(value=12)
No results found