Class InMemoryTransport

constructor

• new InMemoryTransport(options?: InMemoryTransportOptions): InMemoryTransport

  Parameters

  • options: InMemoryTransportOptions = {}

  Returns InMemoryTransport

ReadonlyCapabilities

ReadonlyName

OpenConsumer

• OpenConsumer<TPayload extends WorkJson>(
      subscription: SubscriptionBinding,
  ): ITransportConsumer<TPayload>

  Type Parameters

  • TPayload extends WorkJson

  Parameters

  • subscription: SubscriptionBinding

  Returns ITransportConsumer<TPayload>

Operator

• Operator(): ITransportOperator

  Returns ITransportOperator

Publish

• Publish(
      topic: TopicBinding,
      messages: WorkMessage<WorkJson>[],
      subscriptions: SubscriptionBinding[],
      _opts?: DatabasePublishOptions,
  ): Promise<PublishResult[]>

  Parameters

  • topic: TopicBinding
  • messages: WorkMessage<WorkJson>[]
  • subscriptions: SubscriptionBinding[]
  • Optional_opts: DatabasePublishOptions

  Returns Promise<PublishResult[]>

RunSweep

• RunSweep(): { ExpiredLeases: number }

  Expire leases everywhere (the sweeper's job).

  Returns { ExpiredLeases: number }

Snapshot

• Snapshot(subscriptionName: string): InMemoryDeliverySnapshot[]

  Test/diagnostic view of one subscription's deliveries, in claim order.

  Parameters

  • subscriptionName: string

  Returns InMemoryDeliverySnapshot[]

ValidateBindings

• ValidateBindings(
      _topic: TopicBinding,
      _subscriptions: SubscriptionBinding[],
  ): Promise<BindingValidationIssue[]>

  Parameters

  • _topic: TopicBinding
  • _subscriptions: SubscriptionBinding[]

  Returns Promise<BindingValidationIssue[]>