Function publishIntegrationEvent

publishIntegrationEvent<T>(
    runtime: IRuntimeServices,
    broker: IMessageBroker,
    definition: IntegrationEventDefinition<T>,
    payload: T,
    metadata?: IntegrationEventMetadata,
    options?: PublishOptions,
): Promise<void>
Publishes one integration event: builds the envelope from the caller's already-typed payload and hands it to broker.publish on the definition's topic.

The definition's parse function is deliberately NOT run here. parse is a narrowing function unknown → T, and a realistic one (a schema with defaults, coercion, or stripping) returns a different object than it was given — running it on publish would silently change what the producer asked to send. It also would not buy the guarantee it appears to: what the consumer parses is the value after a JSON round trip, which this call has not seen. The consequence is honest and documented: a producer CAN publish a payload its own consumers reject, and that surfaces at the consumer as a reason: 'parse' rejection.
Type Parameters
- T
  The event payload type
Parameters
- runtime: IRuntimeServices
  Runtime services supplying uuid() and now()
- broker: IMessageBroker
  The broker to publish through
- definition: IntegrationEventDefinition<T>
  The contract being published
- payload: T
  The event payload, carried verbatim
- Optionalmetadata: IntegrationEventMetadata
  Optional causal metadata
- Optionaloptions: PublishOptions
  Optional publish options (M106 §3.7); orderingKey beats the definition's selector, and deduplicationId defaults to the envelope id
Returns Promise<void>
Throws
As a rejected promise when the options (or the value the definition's selector returns) fail §3.4 validation

Throws
Whatever broker.publish rejects with, unchanged
Example
```
import { publishIntegrationEvent } from '@setu-ts/messaging-plugin';

await publishIntegrationEvent(runtime, broker, orderPlaced, { orderId: '1' });
```
Since
0.6.0
- Defined in packages/messaging-plugin/src/integration/publish.ts:67

Function publishIntegrationEvent

Type Parameters

Parameters

Returns Promise<void>

Throws

Throws

Example

Since

Settings