Orchestrata Ultimate › Tests › Reference › postman › test_delivery
Tests reference — tests/postman/test_delivery.py
Module of tests/postman, split out because the directory page would be too large.
Prose pending.
tests/postman/test_delivery.py
source · 33 tests · 1019 lines
Tests for Postman delivery management.
Covers: postman.delivery, postman.exceptions, postman.interfaces, postman.queue_manager, postman.router, postman.types
| Kind | Name | Line | Description |
|---|---|---|---|
| function | test_deliver_actually_enqueues_into_recipient_real_queue |
311 | A message to a live/registered recipient doesn't just get reported |
| function | test_deliver_reports_failed_not_delivered_when_transport_full |
339 | A recipient can be perfectly reachable at the routing layer yet still |
| function | test_init_creates_delivery_manager |
378 | Test DeliveryManager initialization with dependencies. |
| function | test_init_creates_lock |
393 | Test DeliveryManager creates asyncio lock for thread safety. |
| function | test_deliver_single_recipient_success |
407 | Test successful delivery to single recipient. |
| function | test_deliver_multiple_recipients_via_routing |
427 | Test delivery to multiple recipients via routing engine. |
| function | test_delivery_lifecycle_queued_to_delivered |
458 | Test delivery lifecycle: QUEUED -> DELIVERING -> DELIVERED. |
| function | test_delivery_creates_receipts |
476 | Test delivery creates proper receipts. |
| function | test_get_status_existing_message |
502 | Test get_status returns correct status for existing message. |
| function | test_get_status_nonexistent_message |
519 | Test get_status returns None for nonexistent message. |
| function | test_get_status_multiple_messages |
526 | Test get_status correctly tracks multiple messages. |
| function | test_cancel_nonexistent_message |
549 | Test cancel returns False for nonexistent message. |
| function | test_cancel_delivered_message_fails |
556 | Test cannot cancel already delivered message. |
| function | test_cancel_failed_message |
570 | Test cancel behavior with failed message. |
| function | test_retry_nonexistent_message_raises_error |
593 | Test retry raises DeliveryError for nonexistent message. |
| function | test_retry_non_failed_message_raises_error |
601 | Test retry raises DeliveryError for non-failed message. |
| function | test_retry_failed_message_redelivers_original_payload |
616 | A failed delivery PERSISTS the original (envelope, payload); retry |
| function | test_retry_raises_when_persisted_message_missing |
645 | If a FAILED message has no persisted envelope/payload (e.g. evicted), |
| function | test_delivery_fails_with_invalid_envelope |
667 | Test delivery fails with validation errors. |
| function | test_delivery_fails_with_no_recipients |
691 | Test delivery fails when no recipients found. |
| function | test_delivery_fails_with_routing_error |
709 | Test delivery fails when routing raises error. |
| function | test_deliver_with_empty_payload |
732 | Test delivery with empty payload content. |
| function | test_deliver_concurrent_messages |
748 | Test concurrent delivery of multiple messages. |
| function | test_deliver_with_different_modes |
765 | Test delivery with different delivery modes. |
| function | test_delivery_timestamp_accuracy |
799 | Test delivery timestamps are accurate. |
| function | test_delivery_generates_unique_message_ids |
818 | Test each delivery generates unique message ID. |
| function | test_concurrent_status_checks |
844 | Test concurrent status checks are thread-safe. |
| function | test_concurrent_deliveries |
861 | Test concurrent delivery operations are thread-safe. |
| function | test_extract_message_id_uses_headers_dict_when_present |
925 | _extract_message_id prefers a raw headers dict's MESSAGE_ID, |
| function | test_extract_message_id_generates_uuid_when_nothing_available |
936 | _extract_message_id generates a fresh UUID when the envelope has |
| function | test_validate_envelope_reports_failure_on_handler_exception |
947 | A real envelope-handler exception (not just a validation failure) |
| function | test_resolve_recipients_wraps_generic_routing_error |
966 | _resolve_recipients wraps ANY routing failure -- not just |
| function | test_cancel_queued_message_succeeds |
1000 | A message still in QUEUED status (queued but not yet resolved or |