mistral.engine.rpc_backend.kombu package

Subpackages

• mistral.engine.rpc_backend.kombu.examples package
  • Submodules
  • mistral.engine.rpc_backend.kombu.examples.client module
  • mistral.engine.rpc_backend.kombu.examples.server module
  • Module contents

Submodules

mistral.engine.rpc_backend.kombu.base module

class mistral.engine.rpc_backend.kombu.base.Base

Bases: object

Base class for Client and Server.

mistral.engine.rpc_backend.kombu.kombu_client module

class mistral.engine.rpc_backend.kombu.kombu_client.KombuRPCClient(conf)

Bases: mistral.engine.rpc_backend.base.RPCClient, mistral.engine.rpc_backend.kombu.base.Base

async_call(ctx, method, target=None, **kwargs)

sync_call(ctx, method, target=None, **kwargs)

mistral.engine.rpc_backend.kombu.kombu_server module

class mistral.engine.rpc_backend.kombu.kombu_server.KombuRPCServer(conf)

Bases: mistral.engine.rpc_backend.base.RPCServer, mistral.engine.rpc_backend.kombu.base.Base

publish_message(body, reply_to, corr_id, res_type='response')

register_endpoint(endpoint)

run(executor='blocking')

Start the server.

stop()

Stop the server.

Module contents