diff --git a/crates/adapters/nats/src/subject.rs b/crates/adapters/nats/src/subject.rs index 055555c..a180920 100644 --- a/crates/adapters/nats/src/subject.rs +++ b/crates/adapters/nats/src/subject.rs @@ -16,6 +16,8 @@ pub fn event_to_subject(prefix: &str, event: &DomainEvent) -> String { DomainEvent::BackfillFollower { .. } => "backfill.follower", DomainEvent::FederationDeliveryRequested { .. } => "federation.delivery.requested", DomainEvent::WatchEventIngested { .. } => "watch.event.ingested", + DomainEvent::WrapUpRequested { .. } => "wrapup.requested", + DomainEvent::WrapUpCompleted { .. } => "wrapup.completed", }; format!("{prefix}.{suffix}") }