mistral.engine.rpc_backend.kombu package¶
Subpackages¶
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.
-