Class default

new default(
    __namedParameters: AggregateMessageType,
    broker: BrokerAsPromised,
    logger: Logger,
): default

onError(error: Error, messageId: string): Promise<void>

onPaused(messageId: string): Promise<void>

onReturn(
    message: {
        fields?: {
            exchange?: string;
            replyCode?: number;
            replyText?: string;
            routingKey?: string;
        };
        properties?: { messageId?: string };
    },
): Promise<void>

onSuccess(messageId: string): Promise<void>

publish(
    aggregateId: string,
    payload: unknown,
    envelopeOverrides?: MessageEnvelopeOverrides,
    options?: PublicationConfig,
    eventSigning?: Required<
        Pick<
            ValueObject<
                {
                    rmqChannelMax: () => number;
                    rmqDevMiddleware: () => boolean;
                    rmqEventSigningKeyVersion: () => number;
                    rmqEventSigningKeyVersionsToRevoke: () => number[];
                    rmqEventSigningPrivateKey: () => string;
                    rmqEventSigningPublicKey: () => string;
                    rmqHost: () => string;
                    rmqMgmtHost: () => string | undefined;
                    rmqMgmtPort: () => number | undefined;
                    rmqMgmtProtocol: () => string | undefined;
                    rmqPassword: () => string;
                    rmqPort: () => number;
                    rmqProtocol: () => string;
                    rmqUser: () => string;
                    rmqVHost: () => string;
                    rmqVHostAssert: () => boolean;
                },
            >,
            "rmqEventSigningPrivateKey"
            | "rmqEventSigningKeyVersion",
        >,
    >,
): Promise<PublicationSession>