mistral.tests.unit.engine.rpc_backend.kombu package¶
Submodules¶
mistral.tests.unit.engine.rpc_backend.kombu.base module¶
-
class
mistral.tests.unit.engine.rpc_backend.kombu.base.KombuTestCase(*args, **kwds)¶
mistral.tests.unit.engine.rpc_backend.kombu.fake_kombu module¶
mistral.tests.unit.engine.rpc_backend.kombu.test_kombu_client module¶
-
class
mistral.tests.unit.engine.rpc_backend.kombu.test_kombu_client.KombuClientTestCase(*args, **kwds)¶ Bases:
mistral.tests.unit.engine.rpc_backend.kombu.base.KombuTestCase-
setUp()¶
-
test__on_response_message_ack_fail()¶
-
test__on_response_message_ack_ok(*args, **keywargs)¶
-
test__on_response_message_ack_ok_corr_id_not_match(*args, **keywargs)¶
-
test__on_response_message_ack_ok_messsage_type_error(*args, **keywargs)¶
-
test_async_call(*args, **keywargs)¶
-
test_sync_call_result_get(*args, **keywargs)¶
-
test_sync_call_result_not_get(*args, **keywargs)¶
-
test_sync_call_result_type_error(*args, **keywargs)¶
-
-
exception
mistral.tests.unit.engine.rpc_backend.kombu.test_kombu_client.TestException(message=None)¶
mistral.tests.unit.engine.rpc_backend.kombu.test_kombu_server module¶
-
class
mistral.tests.unit.engine.rpc_backend.kombu.test_kombu_server.KombuServerTestCase(*args, **kwds)¶ Bases:
mistral.tests.unit.engine.rpc_backend.kombu.base.KombuTestCase-
setUp()¶
-
test__on_message_is_async(*args, **keywargs)¶
-
test__on_message_is_sync(*args, **keywargs)¶
-
test__on_message_rpc_method_not_found(*args, **keywargs)¶
-
test__on_message_safe_message_processing_ok(*args, **keywargs)¶
-
test__on_message_safe_message_processing_raise(*args, **keywargs)¶
-
test_is_running_is_not_running()¶
-
test_is_running_is_running()¶
-
test_publish_message()¶
-
test_run_keyboard_interrupt_not_running()¶
-
test_run_launch_successfully()¶
-
test_run_launch_successfully_than_stop()¶
-
test_run_raise_mistral_exception()¶
-
test_run_socket_timeout_still_running()¶
-
test_stop()¶
-
-
exception
mistral.tests.unit.engine.rpc_backend.kombu.test_kombu_server.TestException(message=None)¶