Instantiate a new Streaming receiver for receiving messages with handlers.
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
Closes the underlying AMQP receiver.
Promise
Determines whether the AMQP receiver link is open. If open then returns true else returns false.
boolean
Will reconnect the receiver link if necessary.
The receiver error or connection error, if any.
Promise
Starts the receiver by establishing an AMQP session and an AMQP receiver link on the session.
The message handler to receive servicebus messages.
The error handler to receive an error that occurs while receivin messages.
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 streaming receiver.
The connection context.
A promise that resolves with an instance of StreamingReceiver.
Generated using TypeDoc
Describes the streaming receiver where the user can receive the message by providing handler functions.