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)

Bases: mistral.tests.unit.base.BaseTest

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)

Bases: mistral.exceptions.MistralException

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)

Bases: mistral.exceptions.MistralError

Module contents