RequestResponseLink class

amqp 세션을 통해 만들어진 amqp request(sender)-response(receiver) 링크를 설명합니다.

생성자

RequestResponseLink(Session, Sender, Receiver)

속성

connection

기본 amqp 연결 개체를 제공합니다.

receiver
sender
session

메서드

close()

보낸 사람, 수신자 링크 및 기본 세션을 닫습니다.

create(Connection, SenderOptions, ReceiverOptions, { abortSignal?: AbortSignalLike })

amqp 요청/응답 링크를 만듭니다.

isOpen()

세션과 보낸 사람 및 수신자 링크가 모두 열려 있는지 또는 닫혀 있는지 여부를 나타냅니다.

remove()

보낸 사람, 수신자 링크를 제거하고 기본 세션입니다.

sendRequest(Message, SendRequestOptions)

지정된 요청 메시지를 보내고 받은 응답을 반환합니다. 제공된 시간 제한(밀리초 default: 60000)에서 작업이 완료되지 않으면 이 OperationTimeoutError throw됩니다.

생성자 세부 정보

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

매개 변수

session

Session

amqp 세션입니다.

sender

Sender

amqp 보낸 사람 링크입니다.

receiver

Receiver

amqp 수신기 링크입니다.

속성 세부 정보

기본 amqp 연결 개체를 제공합니다.

Connection connection

속성 값

Connection

연결,

receiver: Receiver

속성 값

Receiver

sender: Sender

속성 값

Sender

session: Session

속성 값

Session

메서드 세부 정보

보낸 사람, 수신자 링크 및 기본 세션을 닫습니다.

function close(): Promise<void>

반환

Promise<void>

Promise

amqp 요청/응답 링크를 만듭니다.

static function create(connection: Connection, senderOptions: SenderOptions, receiverOptions: ReceiverOptions, createOptions?: { abortSignal?: AbortSignalLike }): Promise<RequestResponseLink>

매개 변수

connection

Connection

amqp 연결입니다.

senderOptions

SenderOptions

보낸 사람 링크를 만들려면 제공해야 하는 옵션입니다.

receiverOptions

ReceiverOptions

수신기 링크를 만들려면 제공해야 하는 옵션입니다.

createOptions

{ abortSignal?: AbortSignalLike }

이 메서드의 동작에 영향을 주는 데 사용할 수 있는 선택적 매개 변수입니다. 예를 들어 abortSignal 진행 중인 create 호출을 취소할 수 있도록 을 전달할 수 있습니다.

반환

Promise

세션과 보낸 사람 및 수신자 링크가 모두 열려 있는지 또는 닫혀 있는지 여부를 나타냅니다.

function isOpen(): boolean

반환

boolean

boolean - true - open, . false - closed

보낸 사람, 수신자 링크를 제거하고 기본 세션입니다.

function remove()

지정된 요청 메시지를 보내고 받은 응답을 반환합니다. 제공된 시간 제한(밀리초 default: 60000)에서 작업이 완료되지 않으면 이 OperationTimeoutError throw됩니다.

function sendRequest(request: Message, options?: SendRequestOptions): Promise<Message>

매개 변수

request

Message

AMQP(요청) 메시지입니다.

options
SendRequestOptions

요청을 보내는 동안 제공할 수 있는 옵션입니다.

반환

Promise<Message>

Promise AMQP(응답) 메시지입니다.