✅ Should_create_new_lock
✅ Should_not_get_lease_when_already_locked
✅ Should_not_renew_expired_lease
✅ Should_release_lease
✅ Should_renew_lease

✅ Complete_should_delete_the_saga
✅ Complete_should_delete_the_saga_when_etag_matches
✅ Complete_should_throw_when_etag_differs
✅ Complete_should_throw_when_saga_not_found
✅ Delete_should_delete_the_saga
✅ Should_create_and_read_saga
✅ Should_not_throw_when_create_and_saga_expired
✅ Should_throw_when_create_and_saga_exists
✅ Should_throw_when_get_and_saga_does_not_exist
✅ Should_throw_when_get_and_saga_expired
✅ Update_should_change_to_current_etag_on_success
✅ Update_should_throw_when_etag_differs
✅ Update_should_throw_when_saga_not_found
✅ Update_should_update_the_saga
✅ Update_should_update_when_etag_match

✅ Should_list_queues
✅ Should_move_dead_letter_message_to_original_queue
✅ Should_peek_dead_letter_message_without_deleting_it
✅ Should_peek_message_without_deleting_it
✅ Should_receive_dead_letter_message_and_delete_it
✅ Should_reflect_current_queue_properties
✅ Should_specify_queue_type

✅ PumpAsync_WhenQueuesDoesNotExist_ShouldCreateQueuesWithoutThrowing

✅ Should_abandon_the_message_and_return_it_to_the_queue
✅ Should_complete_the_message_and_remove_it_from_the_queue
✅ Should_dead_letter_the_message_and_move_it_to_the_dl_queue
✅ Should_lock_the_message_and_make_it_invisible_when_processing

✅ Should_allow_regular_processing_settings_to_bypass_the_renewal
✅ Should_not_renew_after_completion
✅ Should_not_renew_lock_after_message_timeout
✅ Should_renew_lock

✅ Should_create_queue_when_it_doesnt_exists
✅ Should_not_create_queue_when_it_exists
✅ Should_not_exceed_max_concurrent_when_prefetch_is_high
✅ Should_not_fetch_more_messages_when_max_concurrent_is_reached
✅ Should_not_release_semaphore_until_task_is_completed
✅ Should_prefetch_messages
✅ Should_prefetch_one_message_when_set_to_zero
✅ Should_release_semaphore_if_exception
✅ Should_release_semaphore_when_message_lock_timeout_expires

✅ Should_allow_creation_when_message_is_storage_message
✅ Should_create_instance
✅ Should_disallow_creation_when_message_is_not_storage_message

✅ Should_not_start_storage_queue_reader_with_too_high_prefetch_count

✅ When_publish_should_publish_message
✅ When_request_should_publish_message_and_receive
✅ When_request_stream_error_should_throw
✅ When_request_stream_should_recieve_all_messages
✅ When_send_should_publish_message

✅ AbandonByError
✅ Complete
✅ DeadLetterMessage
✅ GetMessages
✅ GetMessages_Empty
✅ GetMessages_visibility_timeout
✅ InsertMessages
✅ ManagementClient_SendMessages
✅ PeekDeadLetterMessagesAsync
✅ Schedule

✅ Should_abandon_the_message_and_return_it_to_the_queue
✅ Should_complete_the_message_and_remove_it_from_the_queue
✅ Should_dead_letter_the_message_and_move_it_to_the_dl_queue
✅ Should_lock_the_message_and_make_it_invisible_when_processing

✅ Should_list_queues
✅ Should_move_dead_letter_message_to_original_queue
✅ Should_peek_dead_letter_message_without_deleting_it
✅ Should_peek_message_without_deleting_it
✅ Should_receive_dead_letter_message_and_delete_it
✅ Should_reflect_current_queue_properties
✅ Should_specify_queue_type

✅ Complete_should_delete_the_saga
✅ Complete_should_throw_when_saga_not_found
✅ Delete_should_delete_the_saga
✅ Should_create_and_read_saga
✅ Should_not_throw_when_create_and_saga_expired
✅ Should_throw_when_create_and_saga_exists
✅ Should_throw_when_get_and_saga_does_not_exist
✅ Should_throw_when_get_and_saga_expired
✅ Update_should_throw_when_saga_not_found
✅ Update_should_update_the_saga

✅ Should_list_queues
✅ Should_move_dead_letter_message_to_original_queue
✅ Should_peek_dead_letter_message_without_deleting_it
✅ Should_peek_message_without_deleting_it
✅ Should_receive_dead_letter_message_and_delete_it
✅ Should_reflect_current_queue_properties
✅ Should_specify_queue_type

✅ Should_list_subscription

✅ Should_abandon_the_message_and_return_it_to_the_queue
✅ Should_complete_the_message_and_remove_it_from_the_queue
✅ Should_dead_letter_the_message_and_move_it_to_the_dl_queue
✅ Should_lock_the_message_and_make_it_invisible_when_processing

✅ AbandonMessageByErrorAsync_should_requeue_message_and_set_error_hash
✅ CompleteMessageAsync_should_delete_hash_and_expiration_keys_then_remove_message
✅ DeadLetterMessageAsync_should_remove_from_processing_queue_and_put_message_in_deadletter_queue
✅ DeleteDeadletter_should_delete_deadletter_and_related_data
✅ GetDeadlettersAsync_should_return_deadletters
✅ GetMessagesAsync_should_get_messages
✅ RequeueDeadletterAsync_should_requeue_message_remove_errors_and_delivery_count

✅ Should_list_queues
✅ Should_move_dead_letter_message_to_original_queue
✅ Should_peek_dead_letter_message_without_deleting_it
✅ Should_peek_message_without_deleting_it
✅ Should_receive_dead_letter_message_and_delete_it
✅ Should_reflect_current_queue_properties
✅ Should_specify_queue_type

✅ Complete_should_delete_the_saga
✅ Complete_should_throw_when_saga_not_found
✅ Delete_should_delete_the_saga
✅ Should_create_and_read_saga
✅ Should_not_throw_when_create_and_saga_expired
✅ Should_throw_when_create_and_saga_exists
✅ Should_throw_when_get_and_saga_does_not_exist
✅ Should_throw_when_get_and_saga_expired
✅ Update_should_throw_when_saga_not_found
✅ Update_should_update_the_saga

✅ GetMessagesAsync_should_not_try_to_fetch_messages_when_there_are_none
✅ GetMessagesAsync_should_return_available_messages_when_there_are_messages

✅ Should_execute_processor
✅ Should_not_execute_processor_when_no_lock
✅ Should_not_throw_on_lock_exceptions
✅ Should_not_throw_on_processor_exceptions

✅ Should_attach_attachment_when_command_have_attachment
✅ Should_delete_attachment_when_finished
✅ Should_not_attach_attachments_for_other_commands

✅ Should_find_registered_generic
✅ Should_find_registered_type
✅ Should_throw_for_non_registered_message

✅ Should_call_BeforeDeadLetterAsync_before_dead_letter_messages
✅ Should_continue_when_not_dead_lettering
✅ Should_dead_letter_messages
✅ Should_not_continue_after_dead_letter_messages

✅ Should_abandon_message_on_errors
✅ Should_catch_errors
✅ Should_log_errors
✅ Should_not_throw_when_abandon_message_on_errors_fails

✅ Newtonsoft_Should_not_serialize_attachments
✅ Newtonsoft_Should_serialize_deserialize_message
✅ Should_not_serialize_attachments
✅ Should_serialize_deserialize_message

✅ Should_find_registered_mapping
✅ Should_find_registered_mapping_queue_name
✅ Should_map_assembly
✅ Should_throw_for_non_registered_message

✅ Should_serialize_deserialize_message

✅ Dependency_injection_can_resolve_service_from_RegisterOpenGenericType
✅ DependencyInjection_can_register_open_generic
✅ DependencyInjection_resolves_services_in_correct_scope

✅ Should_serialize_deserialize_message

✅ Initialize_should_resume_saga_when_start_message_is_received
✅ Initialize_should_start_new_saga_when_start_message_is_received
✅ Initialize_should_throw_when_message_is_not_mapped

✅ Should_map_message
✅ Should_map_start_message
✅ Should_throw_unmapped_message

✅ If_Saga_implements_ISagaDuplicateDetected_then_ProcessDuplicateAsync_should_be_called_and_should_complete_message_if_saga_already_is_started
✅ If_Saga_implements_ISagaDuplicateDetected_then_ProcessDuplicateAsync_throws_then_Exception_should_be_thrown
✅ Should_complete_message_if_saga_already_is_started
✅ Should_load_sagadata_and_call_next_when_success

✅ Should_release_throttle_on_exception
✅ Should_release_throttle_when_cancellation_token_cancelled
✅ Should_throttle

✅ Should_complete_successful_message
✅ Should_not_complete_failed_message
✅ Should_process_message

✅ Should_complete_successful_request
✅ Should_not_complete_failed_request
✅ Should_not_reply_failed_request
✅ Should_process_request
✅ Should_reply_successful_request

✅ Should_complete_successful_request
✅ Should_not_complete_failed_request
✅ Should_not_reply_failed_request
✅ Should_process_request
✅ Should_reply_successful_request

✅ Should_locate_event_processors
✅ Should_locate_multiple_command_processors
✅ Should_locate_single__stream_request_processor
✅ Should_locate_single_command_processor
✅ Should_locate_single_request_processor
✅ Should_should_locate_singleton_processors
✅ Should_throw_when_message_transport_is_unknown

✅ Should_execute_ordered_pipeline_from_microsoft_di
✅ Should_execute_scoped_MessageProcessor_with_dependency_injection
✅ Should_move_message_scope_provider_right_after_error_middleware

✅ Should_only_start_one_queue_reader
✅ Should_override_singleton_impacted_settings
❌ Should_restart_queue_reader_when_lock_is_lost
	Moq.MockException : 
	Expected invocation on the mock exactly 2 times, but was 3 times: x => x.StartAsync(It.IsAny<CancellationToken>())
	
	Performed invocations:
	
	   Mock<IChannelReceiver:10> (x):
	
	      IChannelReceiver.Settings  => Mock<IProcessingSettings:2>
	      IChannelReceiver.Settings  => Mock<IProcessingSettings:2>
	      IChannelReceiver.Settings = SingletonProcessingSettings
	      IChannelReceiver.StartAsync(CancellationToken)
	      IChannelReceiver.StartAsync(CancellationToken)
	      IChannelReceiver.StartAsync(CancellationToken)
	
	   Mock<IProcessingSettings:2>:
	
	      IProcessingSettings.MessageLockTimeout
	      IProcessingSettings.DeadLetterDeliveryLimit
	
✅ Should_start_new_queue_reader_when_lock_is_released

✅ Should_abandon_message
✅ Should_deadletter_message
✅ Should_log_error
✅ Should_process_message

✅ Should_RespondToPing

✅ Should_use_custom_serializer
✅ Should_use_default_serializer