Options
All
  • Public
  • Public/Protected
  • All
Menu

Class RequestResponseLink

Package version

Describes an amqp request(sender)-response(receiver) link that is created over an amqp session.

Hierarchy

  • RequestResponseLink

Implements

  • any

Index

Constructors

Properties

Accessors

Methods

Constructors

constructor

  • new RequestResponseLink(session: Session, sender: Sender, receiver: Receiver): RequestResponseLink

Properties

receiver

receiver: Receiver

The amqp receiver link.

sender

sender: Sender

The amqp sender link.

session

session: Session

The amqp session.

Accessors

connection

  • get connection(): Connection

Methods

close

  • close(): Promise<void>

isOpen

  • isOpen(): boolean

remove

  • remove(): void

sendRequest

  • Sends the given request message and returns the received response. If the operation is not completed in the provided timeout in milliseconds default: 60000, then OperationTimeoutError is thrown.

    Parameters

    • request: RheaMessage

      The AMQP (request) message.

    • Default value options: SendRequestOptions = {}

    Returns Promise<RheaMessage>

    Promise The AMQP (response) message.

Static create

  • create(connection: Connection, senderOptions: SenderOptions, receiverOptions: ReceiverOptions): Promise<RequestResponseLink>

Generated using TypeDoc