//#region ../@warlock.js/herald/src/types/message.types.d.ts
type MessageMetadata = {
  messageId: string;
  correlationId?: string;
  replyTo?: string;
  priority?: number;
  timestamp: Date;
  headers?: Record<string, string>;
  retryCount?: number;
  originalChannel?: string;
};
type Message<TPayload = unknown> = {
  readonly metadata: MessageMetadata;
  readonly payload: TPayload;
  readonly raw?: unknown;
};
type MessageContext = {
  ack(): Promise<void>;
  nack(requeue?: boolean): Promise<void>;
  reject(): Promise<void>;
  reply<T>(payload: T): Promise<void>;
  retry(delay?: number): Promise<void>;
};
type Subscription = {
  readonly id: string;
  readonly channel: string;
  readonly consumerTag?: string;
  unsubscribe(): Promise<void>;
  pause(): Promise<void>;
  resume(): Promise<void>;
  isActive(): boolean;
};
type MessageHandler<TPayload = unknown> = (message: Message<TPayload>, ctx: MessageContext) => Promise<void> | void;
type ResponseHandler<TPayload = unknown, TResponse = unknown> = (message: Message<TPayload>, ctx: MessageContext) => Promise<TResponse> | TResponse;
//#endregion
export { Message, MessageContext, MessageHandler, MessageMetadata, ResponseHandler, Subscription };
//# sourceMappingURL=message.types.d.mts.map