feat(OMN-1740): Add operational semantics to EventBusSubcontractWiring

pyproject.toml

@@ -36,8 +36,8 @@ python = "^3.12"
 #   omnibase-core = { git = "https://github.com/org/omnibase_core.git", rev = "SHA" }
 # Remember to switch back to PyPI versions before merging to main.
 #
-# omnibase-core v0.9.11: Version bump
-omnibase-core = "^0.9.11"
+# omnibase-core v0.10.1: Adds Kafka import lint guard validator
+omnibase-core = "^0.10.1"
 # omnibase-spi v0.6.4: Version bump
 omnibase-spi = "^0.6.4"
 

src/omnibase_infra/models/__init__.py

@@ -22,6 +22,11 @@
     ModelTopicParser,
 )
 from omnibase_infra.models.errors import ModelHandlerValidationError
+from omnibase_infra.models.event_bus import (
+    ModelConsumerRetryConfig,
+    ModelIdempotencyConfig,
+    ModelOffsetPolicyConfig,
+)
 from omnibase_infra.models.handlers import ModelHandlerIdentifier
 from omnibase_infra.models.health import ModelHealthCheckResult
 from omnibase_infra.models.logging import ModelLogContext
@@ -84,6 +89,10 @@
     # Dispatch models
     "EnumDispatchStatus",
     "EnumTopicStandard",
+    # Event bus models
+    "ModelConsumerRetryConfig",
+    "ModelIdempotencyConfig",
+    "ModelOffsetPolicyConfig",
     # Resilience models
     "ModelCircuitBreakerConfig",
     # Validation models

src/omnibase_infra/models/event_bus/__init__.py

@@ -0,0 +1,22 @@
+# SPDX-FileCopyrightText: 2025 OmniNode Team <info@omninode.ai>
+#
+# SPDX-License-Identifier: Apache-2.0
+"""Event bus models for message consumption, idempotency, and DLQ configuration."""
+
+from omnibase_infra.models.event_bus.model_consumer_retry_config import (
+    ModelConsumerRetryConfig,
+)
+from omnibase_infra.models.event_bus.model_dlq_config import ModelDlqConfig
+from omnibase_infra.models.event_bus.model_idempotency_config import (
+    ModelIdempotencyConfig,
+)
+from omnibase_infra.models.event_bus.model_offset_policy_config import (
+    ModelOffsetPolicyConfig,
+)
+
+__all__ = [
+    "ModelConsumerRetryConfig",
+    "ModelDlqConfig",
+    "ModelIdempotencyConfig",
+    "ModelOffsetPolicyConfig",
+]