Skip to main content Link Search Menu Expand Document (external link)

AMQPSubscriber overview

Added in v0.3.0


Table of contents


constructors

make

Signature

export declare const make: (
  queueName: string,
  options?: AMQPSubscriberOptions
) => Effect.Effect<AMQPSubscriber, AMQPError.AMQPConnectionError, AMQPChannel.AMQPChannel>

Added in v0.3.0

models

AMQPPublishMessage (interface)

Signature

export interface AMQPPublishMessage {
  exchange: string
  routingKey: string
  content: Buffer
  options?: Options.Publish
}

Added in v0.3.0

AMQPSubscriber (interface)

Signature

export interface AMQPSubscriber extends Subscriber.Subscriber<AMQPConsumeMessage.AMQPConsumeMessage> {
  readonly [TypeId]: TypeId
}

Added in v0.3.0

AMQPSubscriberOptions (interface)

Signature

export interface AMQPSubscriberOptions {
  uninterruptible?: boolean
  handlerTimeout?: Duration.DurationInput
}

Added in v0.4.0

type ids

TypeId

Signature

export declare const TypeId: typeof TypeId

Added in v0.3.0

TypeId (type alias)

Signature

export type TypeId = typeof TypeId

Added in v0.3.0