index.ts

export { DoNotProcessMessageError } from './errors/DoNotProcessError.ts'
export {
  isMessageError,
  MessageInvalidFormatError,
  MessageValidationError,
} from './errors/Errors.ts'
export { RetryMessageLaterError } from './errors/RetryMessageLaterError.ts'
export * from './events/baseEventSchemas.ts'
export { DomainEventEmitter } from './events/DomainEventEmitter.ts'
export { EventRegistry } from './events/EventRegistry.ts'
export * from './events/eventTypes.ts'
export { FakeListener } from './events/fakes/FakeListener.ts'
export * from './message-deduplication/AcquireLockTimeoutError.ts'
export {
  type AcquireLockOptions,
  type DeduplicationRequester,
  DeduplicationRequesterEnum,
  type MessageDeduplicationConfig,
  type MessageDeduplicationStore,
  noopReleasableLock,
  type ReleasableLock,
} from './message-deduplication/messageDeduplicationTypes.ts'
export * from './messages/baseMessageSchemas.ts'
export * from './messages/MetadataFiller.ts'
export {
  isOffloadedPayloadPointerPayload,
  OFFLOADED_PAYLOAD_POINTER_PAYLOAD_SCHEMA,
  type OffloadedPayloadPointerPayload,
  PAYLOAD_REF_SCHEMA,
  type PayloadRef,
} from './payload-store/offloadedPayloadMessageSchemas.ts'
export type {
  MultiPayloadStoreConfig,
  PayloadSerializer,
  PayloadStore,
  PayloadStoreConfig,
  SerializedPayload,
  SinglePayloadStoreConfig,
} from './payload-store/payloadStoreTypes.ts'
export {
  createMultiStoreConfig,
  isMultiPayloadStoreConfig,
} from './payload-store/payloadStoreTypes.ts'
export * from './queues/AbstractPublisherManager.ts'
export {
  AbstractQueueService,
  type Deserializer,
  type ResolvedMessage,
} from './queues/AbstractQueueService.ts'
export type {
  BarrierCallback,
  BarrierResult,
  BarrierResultNegative,
  BarrierResultPositive,
  Handler,
  HandlerContainerOptions,
  PreHandlingOutputs,
  Prehandler,
} from './queues/HandlerContainer.ts'
export {
  HandlerContainer,
  MessageHandlerConfig,
  MessageHandlerConfigBuilder,
  type PrehandlerResult,
} from './queues/HandlerContainer.ts'
export {
  ANY_MESSAGE_TYPE,
  HandlerSpy,
  type HandlerSpyParams,
  type PublicHandlerSpy,
  resolveHandlerSpy,
  type SpyResultCounts,
  type SpyResultInput,
  TYPE_NOT_RESOLVED,
} from './queues/HandlerSpy.ts'
export type {
  DefinitionEntry,
  MessageSchemaContainerOptions,
  SchemaEntry,
} from './queues/MessageSchemaContainer.ts'
export { MessageSchemaContainer } from './queues/MessageSchemaContainer.ts'
export type {
  MessageTypeResolverConfig,
  MessageTypeResolverContext,
  MessageTypeResolverFn,
} from './queues/MessageTypeResolver.ts'
export {
  extractMessageTypeFromSchema,
  isMessageTypeLiteralConfig,
  isMessageTypePathConfig,
  isMessageTypeResolverFnConfig,
  resolveMessageType,
} from './queues/MessageTypeResolver.ts'
export type {
  AsyncPublisher,
  ExtraParams,
  MessageProcessingResult,
  QueueConsumer,
  SchemaMap,
  SyncPublisher,
  TransactionObservabilityManager,
} from './types/MessageQueueTypes.ts'
export * from './types/queueOptionsTypes.ts'
export { isRetryDateExceeded } from './utils/dateUtils.ts'
export { isProduction, reloadConfig } from './utils/envUtils.ts'
export { isShallowSubset, objectMatches } from './utils/matchUtils.ts'
export { type ParseMessageResult, parseMessage } from './utils/parseUtils.ts'
export { objectToBuffer } from './utils/queueUtils.ts'
export {
  isStartupResourcePollingEnabled,
  type PollingErrorCallback,
  type PollingErrorContext,
  type StartupResourcePollingCheckResult,
  StartupResourcePollingTimeoutError,
  type WaitForResourceOptions,
  waitForResource,
} from './utils/startupResourcePollingUtils.ts'
export { toDatePreprocessor } from './utils/toDateProcessor.ts'
export { waitAndRetry } from './utils/waitUtils.ts'