nameko-query 0.0.2

Query extension for nameko.

Nameko extension for support of running queries.

Queries supports multiple replies for a single query sent and will be returned as a list.

Examples

from nameko_query.responder import query_responder

class BlockedListener(object):
    name = "service"
    routing_prefix = "service"

    @query_responder
    def method(self, parameters, message):
        return "hello world"

from nameko_query.request import ClusterQueryProxy

def query_request(service_name, method_name, parameters={}):
    with ClusterQueryProxy({"AMQP_URI": "amqp://guest:guest@localhost", timeout=0.05) as cluster_query:
        service = getattr(cluster_query, service_name)
        method = getattr(service, method_name)
        return method(parameters)

print query_request("service", "method", parameters)