All files / libs/contracts/src messaging.ts

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
 
 
 
 
 
14x
 
 
 
 
 
 
 
 
 
 
14x
 
 
 
/**
 * Broker topology shared by every service. Producers and consumers import
 * these names instead of repeating strings, so a rename is a compile-time
 * refactor rather than a silently broken binding.
 */
export const EXCHANGES = {
  /** Topic exchange all domain events are published to. */
  EVENTS: 'propflow.events',
  /** Messages that exhausted their retries end up here. */
  DEAD_LETTER: 'propflow.dlx',
} as const;
 
/**
 * Kafka topics. Work order events are keyed by workOrderId so every event of
 * one aggregate lands on the same partition, preserving its order.
 */
export const TOPICS = {
  WORK_ORDER_EVENTS: 'propflow.work-orders',
} as const;