Did I find the right examples for you? yes no

All Samples(7)  |  Call(6)  |  Derive(0)  |  Import(1)
Wrap `pika.adapters.tornado_connection.TornadoConnection` 
to provide a simple RPC client powered by ``tornado.gen.engine``
semantics.

src/c/h/Chu-0.2.0/chu/examples/simple_rpc.py   Chu(Download)
def simple_rpc():
    # Make sure you have rabbitmq running locally, or modify localhost
    client = chu.rpc.AsyncTornadoRPCClient(host='localhost')
 
    # The params passed to RPCRequest are serialized to JSON

src/c/h/Chu-0.2.0/chu/tests/test_rabbit_worker.py   Chu(Download)
import simplejson as json
from datetime import timedelta
from chu.rpc import AsyncTornadoRPCClient, RPCRequest, RPCTimeoutError
from chu.tests.rabbit_worker import Worker
from chu.tests.util import gen_wrapper, AsyncEvent
    def test_call(self):
        client = AsyncTornadoRPCClient('localhost',
                                       self.io_loop)
 
        rpc_request = RPCRequest(exchange='exch',
    def test_call_timeout(self):
        client = AsyncTornadoRPCClient('localhost',
                                       self.io_loop)
 
        rpc_request = RPCRequest(exchange='exch',
    def test_call_no_reply(self):
        client = AsyncTornadoRPCClient('localhost',
                                       self.io_loop)
 
        rpc_request = RPCRequest(exchange='exch',
    def test_call_double_reply(self):
        client = AsyncTornadoRPCClient('localhost',
                                       self.io_loop)
 
        rpc_request = RPCRequest(exchange='exch',