@mjt-engine/message
    Preparing search index...

    Variable MessagesConst

    Messages: {
        connectEventListenerToSubjectRoot: <
            S extends string,
            EM extends EventMap<S>,
            E extends Record<string, string> = Record<string, string>,
        >(
            __namedParameters: {
                connection: NatsConnection;
                env?: Partial<E>;
                listener: EventListener<S, EM, E>;
                onError?: (error: unknown) => void;
                options?: Partial<
                    {
                        log: (message: unknown, ...extra: unknown[]) => void;
                        maxMessages?: number;
                        queue?: string;
                        timeout?: number;
                    },
                >;
                signal?: AbortSignal;
                subjectRoot: string;
            },
        ) => Promise<void>;
        createConnection: <
            CM extends ConnectionMap,
            E extends Record<string, string> = Record<string, string>,
        >(
            __namedParameters: {
                creds?: string;
                env?: Partial<E>;
                options?: Partial<
                    {
                        log: (message: unknown, ...extra: unknown[]) => void;
                        maxMessageSize?: number;
                    },
                >;
                server: string
                | string[];
                subscribers?: Partial<
                    { [k in string
                    | number
                    | symbol]: ConnectionListener<CM, k, E> },
                >;
                token?: string;
            },
        ) => Promise<MessageConnectionInstance<CM>>;
        parseSubject: <T extends string = string>(
            subject: PartialSubject<T>,
        ) => ParsedSubject<T>;
    } = ...

    Type declaration

    • connectEventListenerToSubjectRoot: <
          S extends string,
          EM extends EventMap<S>,
          E extends Record<string, string> = Record<string, string>,
      >(
          __namedParameters: {
              connection: NatsConnection;
              env?: Partial<E>;
              listener: EventListener<S, EM, E>;
              onError?: (error: unknown) => void;
              options?: Partial<
                  {
                      log: (message: unknown, ...extra: unknown[]) => void;
                      maxMessages?: number;
                      queue?: string;
                      timeout?: number;
                  },
              >;
              signal?: AbortSignal;
              subjectRoot: string;
          },
      ) => Promise<void>
    • createConnection: <
          CM extends ConnectionMap,
          E extends Record<string, string> = Record<string, string>,
      >(
          __namedParameters: {
              creds?: string;
              env?: Partial<E>;
              options?: Partial<
                  {
                      log: (message: unknown, ...extra: unknown[]) => void;
                      maxMessageSize?: number;
                  },
              >;
              server: string
              | string[];
              subscribers?: Partial<
                  { [k in string
                  | number
                  | symbol]: ConnectionListener<CM, k, E> },
              >;
              token?: string;
          },
      ) => Promise<MessageConnectionInstance<CM>>
    • parseSubject: <T extends string = string>(subject: PartialSubject<T>) => ParsedSubject<T>