Instantiate a new BatchingReceiver.
The client entity context.
Resets the _newMessageReceivedTimer
timer when a new message is received.
Closes the Sender|Receiver link and it's underlying session and also removes it from the internal map.
Creates the options that need to be specified while creating an AMQP receiver link.
Ensures that the token is renewed within the predefined renewal margin.
Creates a new AMQP receiver under a new AMQP session.
Promise
Negotiates the cbs claim for the ClientEntity.
Promise
Adds credits to the receiver, respecting any state that indicates the receiver is closed or should not continue to receive more messages.
Number of credits to add.
Closes the underlying AMQP receiver.
Promise
Determines whether the AMQP receiver link is open. If open then returns true else returns false.
boolean
To be called when connection is disconnected to gracefully close ongoing receive request.
Promise
Receives a batch of messages from a ServiceBus Queue/Topic.
The maximum number of messages to receive. In Peeklock mode, this number is capped at 2047 due to constraints of the underlying buffer.
The total wait time in milliseconds until which the receiver will attempt to receive specified number of messages.
If this time elapses before the maxMessageCount
is reached, then messages collected till then will be returned to the user.
A promise that resolves with an array of Message objects.
Settles the message with the specified disposition.
The ServiceBus Message that needs to be settled.
The disposition type.
Optional parameters that can be provided while disposing the message.
Prevents us from receiving any further messages.
Creates a batching receiver.
The connection context.
Generated using TypeDoc
Describes the batching receiver where the user can receive a specified number of messages for a predefined time.