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_async_call()¶
-
test_sync_call_result_get()¶
-
test_sync_call_result_not_get()¶
-
test_sync_call_result_type_error()¶
-
-
exception
mistral.tests.unit.engine.rpc_backend.kombu.test_kombu_client.TestException(message=None)¶
mistral.tests.unit.engine.rpc_backend.kombu.test_kombu_listener module¶
-
class
mistral.tests.unit.engine.rpc_backend.kombu.test_kombu_listener.KombuListenerTestCase(*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()¶
-
test__on_response_message_ack_ok_corr_id_not_match()¶
-
test__on_response_message_ack_ok_messsage_type_error()¶
-
test_add_listener()¶
-
test_get_result_lack_of_queue()¶
-
test_get_result_not_in_queue()¶
-
test_get_result_results_in_queue()¶
-
test_remove_listener_correlation_id_in_results()¶
-
test_remove_listener_correlation_id_not_in_results()¶
-
test_start_thread_not_set(*args, **keywargs)¶
-
test_start_thread_set(*args, **keywargs)¶
-
-
exception
mistral.tests.unit.engine.rpc_backend.kombu.test_kombu_listener.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__prepare_worker(*args, **keywargs)¶
-
test__prepare_worker_no_valid_executor(*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_socket_error_reconnect()¶
-
test_run_socket_timeout_still_running()¶
-
test_stop()¶
-
-
exception
mistral.tests.unit.engine.rpc_backend.kombu.test_kombu_server.TestException(message=None)¶