Denotes if we are currently receiving messages
Closes the Sender|Receiver link and it's underlying session and also removes it from the internal map.
Ensures that the token is renewed within the predefined renewal margin.
Negotiates the cbs claim for the ClientEntity.
Promise
Closes the underlying AMQP receiver link.
Flag that denotes if close is invoked due to session expiring. This is so that the internal map of expired sessions doesn't get cleared when session is closed due to expiry.
Determines whether the AMQP receiver link is open. If open then returns true else returns false.
Registers handlers to deal with the incoming stream of messages over an AMQP receiver link
from a Queue/Subscription.
To stop receiving messages, call close()
on the SessionReceiver or set the property
newMessageWaitTimeoutInMs
in the options to provide a timeout.
Handler for processing each incoming message.
Handler for any error that occurs while receiving or processing messages.
Options to control whether messages should be automatically completed. You can also provide a timeout in milliseconds to denote the amount of time to wait for a new message before closing the receiver.
void
Returns a batch of messages based on given count and timeout over an AMQP receiver link from a Queue/Subscription.
The maximum number of messages to receive from Queue/Subscription.
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.
Promise<ServiceBusMessage[]> 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.
Creates a new instance of the MessageSession based on the provided parameters.
The client entity context
Options that can be provided while creating the MessageSession.
Generated using TypeDoc
Describes the receiver for a Message Session.