Skip to content

Integration Platform — events

Generated from the architecture model

This page is rendered from model/**/*.yaml by tools/docs_model during mkdocs build. Edit the YAML, not this page; hand-written design lives on the linked service, platform and plane pages.

Topics follow context.area.vN.event-name (ADR-0012 port, ADR-0014 envelope). The context segment is the producing bounded context's slug.

Event Producer Topic Scope Consumers
ConnectorActivated ConnectorRegistryService connectors.connectors.v1.connector-activated integration 3
ConnectorDeprecated ConnectorRegistryService connectors.connectors.v1.connector-deprecated integration 2
ConnectorSubscriptionChanged ConnectorRegistryService connectors.subscriptions.v1.connector-subscription-changed integration 3
DeliveryReceived ConnectorRegistryService connectors.deliveries.v1.delivery-received integration 4
DeliveryDispatched ConnectorRegistryService connectors.deliveries.v1.delivery-dispatched integration 2
DeliveryFailed ConnectorRegistryService connectors.deliveries.v1.delivery-failed integration 5
DeliveryReplayed ConnectorRegistryService connectors.deliveries.v1.delivery-replayed integration 1
ConnectionRegistered IntegrationService connections.connections.v1.connection-registered integration 2
ConnectionStateChanged IntegrationService connections.connections.v1.connection-state-changed integration 7
ConnectionGrantChanged IntegrationService connections.grants.v1.connection-grant-changed integration 2
CredentialRotated IntegrationService connections.connections.v1.credential-rotated integration 2
InboundDeliveryVerified WebhookGatewayService connectors.ingress.v1.inbound-delivery-verified integration 2
InboundDeliveryRejected WebhookGatewayService connectors.ingress.v1.inbound-delivery-rejected integration 2

ConnectorActivated

A certified connector version is usable.

Producer ConnectorRegistryService (BC-17 Connectors & Webhooks)
Scope / version integration / v1
Topic connectors.connectors.v1.connector-activated
Aggregate ConnectorDescriptor
Consumers ToolAdapterService, StudioBff, AuditService
Field Type Required Description
connectorId string yes
version string yes
tenantId string yes
provider string yes

ConnectorDeprecated

A connector version is deprecated.

Producer ConnectorRegistryService (BC-17 Connectors & Webhooks)
Scope / version integration / v1
Topic connectors.connectors.v1.connector-deprecated
Aggregate ConnectorDescriptor
Consumers ToolAdapterService, StudioBff
Field Type Required Description
connectorId string yes
version string yes
tenantId string yes

ConnectorSubscriptionChanged

A subscription was created, changed or deactivated.

Producer ConnectorRegistryService (BC-17 Connectors & Webhooks)
Scope / version integration / v1
Topic connectors.subscriptions.v1.connector-subscription-changed
Aggregate Subscription
Consumers WebhookGatewayService, StudioBff, AuditService
Field Type Required Description
subscriptionId guid yes
tenantId string yes
connectorId string yes
active bool yes

DeliveryReceived

A verified inbound delivery was recorded.

Producer ConnectorRegistryService (BC-17 Connectors & Webhooks)
Scope / version integration / v1
Topic connectors.deliveries.v1.delivery-received
Aggregate Delivery
Consumers PipelineExecutionService, WorkflowEngineService, KnowledgeIngestionService, DashboardService
Field Type Required Description
deliveryId guid yes
tenantId string yes
connectorId string yes
subscriptionId guid no
eventType string yes
payloadHash hash yes

DeliveryDispatched

An inbound delivery reached its target or an outbound delivery was sent.

Producer ConnectorRegistryService (BC-17 Connectors & Webhooks)
Scope / version integration / v1
Topic connectors.deliveries.v1.delivery-dispatched
Aggregate Delivery
Consumers DashboardService, AuditService
Field Type Required Description
deliveryId guid yes
tenantId string yes
direction enum:DeliveryDirection yes
receiptRef string yes

DeliveryFailed

Delivery failed after retries.

Producer ConnectorRegistryService (BC-17 Connectors & Webhooks)
Scope / version integration / v1
Topic connectors.deliveries.v1.delivery-failed
Aggregate Delivery
Consumers AlertRuleService, StudioBff, StudioNotificationService, DashboardService, AuditService
Field Type Required Description
deliveryId guid yes
tenantId string yes
direction enum:DeliveryDirection yes
reason string yes

DeliveryReplayed

An operator replayed a failed delivery.

Producer ConnectorRegistryService (BC-17 Connectors & Webhooks)
Scope / version integration / v1
Topic connectors.deliveries.v1.delivery-replayed
Aggregate Delivery
Consumers AuditService
Field Type Required Description
deliveryId guid yes
tenantId string yes
replayedBy string yes

ConnectionRegistered

A connection exists.

Producer IntegrationService (BC-16 Connections)
Scope / version integration / v1
Topic connections.connections.v1.connection-registered
Aggregate Connection
Consumers StudioBff, AuditService
Field Type Required Description
connectionId guid yes
tenantId string yes
provider string yes
credentialKind enum:CredentialKind yes

ConnectionStateChanged

Verified, active, degraded, suspended or revoked.

Producer IntegrationService (BC-16 Connections)
Scope / version integration / v1
Topic connections.connections.v1.connection-state-changed
Aggregate Connection
Consumers KnowledgeIngestionService, ToolAdapterService, McpServerRegistryService, ConnectorRegistryService, StudioBff, DashboardService, AuditService
Field Type Required Description
connectionId guid yes
tenantId string yes
fromState enum:ConnectionState yes
toState enum:ConnectionState yes

ConnectionGrantChanged

A grant was set, narrowed or removed.

Producer IntegrationService (BC-16 Connections)
Scope / version integration / v1
Topic connections.grants.v1.connection-grant-changed
Aggregate Connection
Consumers StudioBff, AuditService
Field Type Required Description
connectionId guid yes
tenantId string yes
subjectKind enum:GrantSubjectKind yes
subjectId string yes
change string yes

CredentialRotated

A new credential reference is in force.

Producer IntegrationService (BC-16 Connections)
Scope / version integration / v1
Topic connections.connections.v1.credential-rotated
Aggregate Connection
Consumers AuditService, DashboardService
Field Type Required Description
connectionId guid yes
tenantId string yes
rotatedAt datetime yes

InboundDeliveryVerified

A delivery passed signature and replay checks and its payload is captured.

Producer WebhookGatewayService (BC-17 Connectors & Webhooks)
Scope / version integration / v1
Topic connectors.ingress.v1.inbound-delivery-verified
Aggregate InboundDelivery
Consumers ConnectorRegistryService, DashboardService
Field Type Required Description
inboundId guid yes
tenantId string yes
subscriptionId guid yes
connectorId string yes
externalId string yes
dedupKey string yes
payloadRef string yes
payloadHash hash yes

InboundDeliveryRejected

A delivery was rejected with its outcome.

Producer WebhookGatewayService (BC-17 Connectors & Webhooks)
Scope / version integration / v1
Topic connectors.ingress.v1.inbound-delivery-rejected
Aggregate InboundDelivery
Consumers AuditService, DashboardService
Field Type Required Description
inboundId guid yes
tenantId string yes
ingressRef string yes
outcome enum:VerificationOutcome yes

Commands

Command Service Handled by Result events Summary
CertifyConnector ConnectorRegistryService ConnectorDescriptor ConnectorActivated
CreateSubscription ConnectorRegistryService Subscription ConnectorSubscriptionChanged
Deliver ConnectorRegistryService Delivery DeliveryDispatched, DeliveryFailed
ReplayDelivery ConnectorRegistryService Delivery DeliveryReplayed
RegisterConnection IntegrationService Connection ConnectionRegistered
VerifyConnection IntegrationService Connection ConnectionStateChanged
RotateCredential IntegrationService Connection CredentialRotated, ConnectionStateChanged
RevokeConnection IntegrationService Connection ConnectionStateChanged
ReceiveWebhook WebhookGatewayService InboundDelivery InboundDeliveryVerified, InboundDeliveryRejected

Consumed from other services

Consumer Event Producer Handler Purpose
ConnectorRegistryService InboundDeliveryVerified WebhookGatewayService RecordAndDispatch Record a verified inbound delivery, deduplicate and dispatch to its target.
ConnectorRegistryService ConnectionStateChanged IntegrationService PauseOnRevocation Deactivate subscriptions and fail pending deliveries of a revoked connection.
IntegrationService ProjectStateChanged ProjectService RevokeProjectGrants Revoke project grants on Closing (XL-13).
WebhookGatewayService ConnectorSubscriptionChanged ConnectorRegistryService RefreshIngressTable Know which ingress identities are active and which scheme verifies them.