export type AmqPriority = "urgent" | "normal" | "low";
export interface AmqHeaderV1 {
    readonly schema: 1;
    readonly id: string;
    readonly from: string;
    readonly to: readonly string[];
    readonly thread: string;
    readonly subject: string;
    readonly created: string;
    readonly priority: AmqPriority;
    readonly kind: string;
    readonly labels: readonly string[];
    readonly context: Readonly<Record<string, unknown>>;
    readonly replyTo: string;
    readonly replyProject: string;
    readonly fromProject: string;
}
export interface AmqMessage {
    readonly header: AmqHeaderV1;
    readonly body: string;
}
export interface WatchCandidate {
    readonly id: string;
    readonly priority: AmqPriority;
    readonly created: string;
    readonly parseError?: string;
}
export interface WatchCohort {
    readonly event: "existing" | "new_message" | "timeout";
    readonly messages: readonly WatchCandidate[];
}
export type AmqReadOutcome = {
    readonly kind: "message";
    readonly message: AmqMessage;
} | {
    readonly kind: "dlq";
    readonly id: string;
    readonly diagnostic: string;
};
export declare function parseWatchCohort(value: unknown): WatchCohort;
export declare function parseMessageList(value: unknown): readonly WatchCandidate[];
export declare function parseWatchCandidate(value: unknown): WatchCandidate;
export declare function parseAmqReadOutcome(value: unknown): AmqReadOutcome;
export declare function parseAmqHeaderV1(value: unknown): AmqHeaderV1;
export declare function sortAndDeduplicateCandidates(candidates: readonly WatchCandidate[]): readonly WatchCandidate[];
export declare function sortMessages(messages: readonly AmqMessage[]): readonly AmqMessage[];
//# sourceMappingURL=amq-message.d.ts.map