Knowledge Wiki Orchestrata Ultimate

Orchestrata Ultimate › Tests › Reference › postman › test_postman_interface_compliance

Tests reference — tests/postman/test_postman_interface_compliance.py

Module of tests/postman, split out because the directory page would be too large.

Prose pending.

tests/postman/test_postman_interface_compliance.py

source · 105 tests · 1544 lines

Interface Compliance Test Suite for Postman Message Broker

Covers: postman.admin, postman.config, postman.delivery, postman.envelope, postman.exceptions, postman.filter, postman.guarantees, postman.message_store, postman.metrics, postman.payload, postman.priority, postman.queue, postman.queue_manager, postman.receipt_store, postman.replay_engine, postman.router, postman.subscription_manager, postman.topic_registry, postman.types

Kind Name Line Description
class TestIMessageEnvelopeCompliance 114 Test compliance with IMessageEnvelope interface (7 tests).
method TestIMessageEnvelopeCompliance.test_envelope_creation 117
method TestIMessageEnvelopeCompliance.test_envelope_immutability 124
method TestIMessageEnvelopeCompliance.test_envelope_serialization 128
method TestIMessageEnvelopeCompliance.test_envelope_deserialization 135
method TestIMessageEnvelopeCompliance.test_envelope_validation 141
method TestIMessageEnvelopeCompliance.test_envelope_priority_default 145
method TestIMessageEnvelopeCompliance.test_envelope_timestamp_auto 151
class TestIPayloadHandlerCompliance 162 Test compliance with IPayloadHandler interface (5 tests).
method TestIPayloadHandlerCompliance.test_attach_payload 165 Test creating a payload and attaching data.
method TestIPayloadHandlerCompliance.test_extract_payload 173 Test extracting data from a payload.
method TestIPayloadHandlerCompliance.test_payload_validation 181 Test payload validation for valid and invalid data.
method TestIPayloadHandlerCompliance.test_payload_size_limit 190 Test payload size enforcement.
method TestIPayloadHandlerCompliance.test_payload_artifacts 200 Test payload creation preserves complex data.
class TestIRoutingEngineCompliance 209 Test compliance with IRoutingEngine interface (8 tests).
method TestIRoutingEngineCompliance.test_route_message 212 Test routing a message to correct destination.
method TestIRoutingEngineCompliance.test_route_validation 219 Test that empty recipient is rejected.
method TestIRoutingEngineCompliance.test_route_broadcast 224 Test broadcast routing to multiple recipients.
method TestIRoutingEngineCompliance.test_route_thread_tracking 233 Test that routing preserves thread information.
method TestIRoutingEngineCompliance.test_route_priority_handling 240 Test that different priorities route to same destination.
method TestIRoutingEngineCompliance.test_route_dead_letter 255 Test adding and removing static routes.
method TestIRoutingEngineCompliance.test_route_retry_logic 263 Test routing cache returns consistent results.
method TestIRoutingEngineCompliance.test_route_metrics 270 Test routing type detection.
class TestIDeliveryManagerCompliance 278 Test compliance with IDeliveryManager interface (5 tests).
method TestIDeliveryManagerCompliance.test_deliver_message 281 Test message delivery flow.
method TestIDeliveryManagerCompliance.test_delivery_receipt 298 Test delivery generates receipts.
method TestIDeliveryManagerCompliance.test_delivery_timeout 314 Test delivery status tracking for timeouts.
method TestIDeliveryManagerCompliance.test_delivery_acknowledgment 334 Test getting delivery status.
method TestIDeliveryManagerCompliance.test_delivery_status_tracking 351 Test delivery cancel on queued message.
class TestIQueueCompliance 375 Test compliance with IQueue interface (8 tests).
method TestIQueueCompliance.test_queue_enqueue 378 Test enqueueing entries.
method TestIQueueCompliance.test_queue_dequeue 386 Test dequeueing entries.
method TestIQueueCompliance.test_queue_peek 395 Test peeking without removal.
method TestIQueueCompliance.test_queue_size 404 Test queue size tracking.
method TestIQueueCompliance.test_queue_empty 412 Test empty queue behavior.
method TestIQueueCompliance.test_queue_full 419 Test bounded queue rejects when full.
method TestIQueueCompliance.test_queue_ordering 427 Test FIFO ordering.
method TestIQueueCompliance.test_queue_concurrent_access 437 Test concurrent enqueue operations.
class TestIPriorityQueueCompliance 450 Test compliance with IPriorityQueue interface (5 tests).
method TestIPriorityQueueCompliance.test_priority_ordering 453 Test high priority dequeued first.
method TestIPriorityQueueCompliance.test_priority_levels 464 Test all priority levels are accepted.
method TestIPriorityQueueCompliance.test_priority_same_level 478 Test FIFO within same priority level.
method TestIPriorityQueueCompliance.test_priority_insertion 488 Test priority boost works.
method TestIPriorityQueueCompliance.test_priority_starvation_prevention 496 Test get_by_priority returns entries for a specific level.
class TestIQueueManagerCompliance 512 Test compliance with IQueueManager interface (7 tests).
method TestIQueueManagerCompliance.test_create_queue 515 Test queue creation.
method TestIQueueManagerCompliance.test_delete_queue 527 Test queue deletion.
method TestIQueueManagerCompliance.test_list_queues 540 Test listing all queues.
method TestIQueueManagerCompliance.test_queue_stats 554 Test retrieving queue status.
method TestIQueueManagerCompliance.test_queue_purge 567 Test purging queue contents.
method TestIQueueManagerCompliance.test_queue_capacity 582 Test bounded queue capacity.
method TestIQueueManagerCompliance.test_queue_isolation 596 Test queues are isolated from each other.
class TestIDeliveryGuaranteesCompliance 616 Test compliance with IDeliveryGuarantees interface (5 tests).
method TestIDeliveryGuaranteesCompliance.test_at_least_once 619 Test at-least-once delivery tracks pending acks.
method TestIDeliveryGuaranteesCompliance.test_at_most_once 629 Test at-most-once delivery does not track acks.
method TestIDeliveryGuaranteesCompliance.test_exactly_once 637 Test exactly-once delivery with deduplication.
method TestIDeliveryGuaranteesCompliance.test_message_deduplication 643 Test duplicate message detection in exactly-once mode.
method TestIDeliveryGuaranteesCompliance.test_idempotency_handling 649 Test acknowledge removes pending ack.
class TestITopicRegistryCompliance 664 Test compliance with ITopicRegistry interface (8 tests).
method TestITopicRegistryCompliance.test_create_topic 667 Test topic creation.
method TestITopicRegistryCompliance.test_delete_topic 674 Test topic deletion.
method TestITopicRegistryCompliance.test_list_topics 682 Test listing topics.
method TestITopicRegistryCompliance.test_topic_exists 690 Test checking topic existence.
method TestITopicRegistryCompliance.test_topic_metadata 699 Test topic metadata.
method TestITopicRegistryCompliance.test_topic_naming_validation 710 Test that topics require valid names.
method TestITopicRegistryCompliance.test_topic_hierarchy 717 Test hierarchical topic names.
method TestITopicRegistryCompliance.test_topic_wildcards 726 Test wildcard topic matching.
class TestISubscriptionManagerCompliance 737 Test compliance with ISubscriptionManager interface (7 tests).
method TestISubscriptionManagerCompliance.test_subscribe 740 Test subscribing to topic.
method TestISubscriptionManagerCompliance.test_unsubscribe 747 Test unsubscribing from topic.
method TestISubscriptionManagerCompliance.test_list_subscriptions 754 Test listing subscriptions for an agent.
method TestISubscriptionManagerCompliance.test_publish 762 Test finding subscribers for a topic.
method TestISubscriptionManagerCompliance.test_subscription_filters 771 Test wildcard subscription matching.
method TestISubscriptionManagerCompliance.test_subscription_lifecycle 778 Test subscribe then unsubscribe lifecycle.
method TestISubscriptionManagerCompliance.test_subscription_isolation 788 Test subscriber isolation between agents.
class TestIMessageStoreCompliance 805 Test compliance with IMessageStore interface (8 tests).
method TestIMessageStoreCompliance.test_store_message 808 Test storing a message.
method TestIMessageStoreCompliance.test_retrieve_message 829 Test retrieving a stored message.
method TestIMessageStoreCompliance.test_query_by_thread 852 Test querying messages by sender.
method TestIMessageStoreCompliance.test_query_by_recipient 873 Test querying messages by recipient.
method TestIMessageStoreCompliance.test_query_by_timerange 894 Test querying messages by time range.
method TestIMessageStoreCompliance.test_message_expiry 917 Test message cleanup by age.
method TestIMessageStoreCompliance.test_storage_capacity 939 Test get_stats returns storage info.
method TestIMessageStoreCompliance.test_message_deletion 958 Test message deletion.
class TestIReceiptStoreCompliance 981 Test compliance with IReceiptStore interface (6 tests).
method TestIReceiptStoreCompliance.test_store_receipt 984 Test storing a delivery receipt.
method TestIReceiptStoreCompliance.test_retrieve_receipt 1003 Test retrieving receipts by message ID.
method TestIReceiptStoreCompliance.test_receipt_history 1023 Test querying receipt history.
method TestIReceiptStoreCompliance.test_receipt_status_updates 1042 Test storing multiple receipts for same message.
method TestIReceiptStoreCompliance.test_receipt_expiry 1067 Test receipt expiration cleanup.
method TestIReceiptStoreCompliance.test_receipt_query 1087 Test querying receipts by time range.
class TestIReplayEngineCompliance 1110 Test compliance with IReplayEngine interface (6 tests).
method TestIReplayEngineCompliance.test_replay_by_thread 1113 Test replaying messages by ID list.
method TestIReplayEngineCompliance.test_replay_by_timerange 1157 Test replaying messages by query.
method TestIReplayEngineCompliance.test_replay_with_filter 1198 Test replaying with sender filter.
method TestIReplayEngineCompliance.test_replay_ordering 1237 Test replay result has correct structure.
method TestIReplayEngineCompliance.test_replay_rate_limiting 1275 Test replay with delay between messages.
method TestIReplayEngineCompliance.test_replay_state_consistency 1313 Test cancelling a replay.
class TestIMetricsCollectorCompliance 1359 Test compliance with IMetricsCollector interface (5 tests).
method TestIMetricsCollectorCompliance.test_record_metric 1362 Test recording a message sent metric.
method TestIMetricsCollectorCompliance.test_get_snapshot 1369 Test retrieving metrics snapshot.
method TestIMetricsCollectorCompliance.test_metric_aggregation 1376 Test aggregation across multiple records.
method TestIMetricsCollectorCompliance.test_metric_reset 1385 Test fresh collector starts at zero.
method TestIMetricsCollectorCompliance.test_metric_export 1393 Test exporting metrics as JSON.
class TestIAdminInterfaceCompliance 1403 Test compliance with IAdminInterface interface (5 tests).
method TestIAdminInterfaceCompliance.test_get_status 1406 Test getting system status.
method TestIAdminInterfaceCompliance.test_list_agents 1413 Test listing agents (admin capability).
method TestIAdminInterfaceCompliance.test_disconnect_agent 1420 Test disconnecting an agent.
method TestIAdminInterfaceCompliance.test_export_config 1426 Test exporting configuration.
method TestIAdminInterfaceCompliance.test_import_config 1433 Test importing configuration.
class TestIConfigManagerCompliance 1451 Test compliance with IConfigManager interface (5 tests).
method TestIConfigManagerCompliance.test_load_config 1454 Test loading default configuration.
method TestIConfigManagerCompliance.test_validate_config 1461 Test configuration has expected fields.
method TestIConfigManagerCompliance.test_update_config 1469 Test config can be reloaded.
method TestIConfigManagerCompliance.test_config_hot_reload 1475 Test config reload mechanism.
method TestIConfigManagerCompliance.test_config_defaults 1484 Test default configuration values.
class TestIMessageFilterCompliance 1496 Test compliance with IMessageFilter interface (5 tests).
method TestIMessageFilterCompliance.test_filter_by_sender 1499 Test filtering by sender pattern.
method TestIMessageFilterCompliance.test_filter_by_recipient 1508 Test filtering works with recipient pattern.
method TestIMessageFilterCompliance.test_filter_by_content 1515 Test filtering by content pattern.
method TestIMessageFilterCompliance.test_filter_composition 1524 Test AND/OR filter logic.
method TestIMessageFilterCompliance.test_filter_compiled 1537 Test compiled filter function.