Class AwsTransportDriver

constructor

• new AwsTransportDriver(
      Sns: SnsGateway,
      Sqs: SqsGateway,
      options?: { Now?: () => number },
  ): AwsTransportDriver

  Parameters

  • Sns: SnsGateway
  • Sqs: SqsGateway
  • options: { Now?: () => number } = {}

  Returns AwsTransportDriver

ReadonlyCapabilities

ReadonlyName

ReadonlySns

ReadonlySqs

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[]>

ValidateBindings

• ValidateBindings(
      topic: TopicBinding,
      subscriptions: SubscriptionBinding[],
  ): Promise<BindingValidationIssue[]>

  Parameters

  • topic: TopicBinding
  • subscriptions: SubscriptionBinding[]

  Returns Promise<BindingValidationIssue[]>

StaticCreate

• Create(
      config: AwsTransportConfig,
      credentials?: AwsCredentialIdentity | AwsCredentialIdentityProvider,
  ): AwsTransportDriver

  Parameters

  • config: AwsTransportConfig
  • Optionalcredentials: AwsCredentialIdentity | AwsCredentialIdentityProvider

  Returns AwsTransportDriver