fraglab / nameko-proxy Goto Github PK

from nameko.rpc import rpc


class FooService(object):
    name = 'foo_service'

    @rpc
    def test(self, val):
        return val

from nameko_proxy import StandaloneRpcProxy

config = {
    'AMQP_URI': 'pyamqp://root:root@localhost:5672/'
}


with StandaloneRpcProxy(config) as rpc:
    response = rpc.foo_service.test("hello")
    print(response)

    response = rpc.foo_service.test.call_async("hello")
    print(response.result())