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

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

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

export type AMQPSubscriberApp<E, R> = SubscriberApp.SubscriberApp<
  AMQPSubscriberResponse.AMQPSubscriberResponse,
  AMQPConsumeMessage.AMQPConsumeMessage,
  E,
  R
>

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

export declare const TypeId: typeof TypeId

export type TypeId = typeof TypeId