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