Package | Description |
---|---|
com.azure.messaging.servicebus |
Package containing classes for creating
ServiceBusSenderAsyncClient ,
ServiceBusProcessorClient , and
ServiceBusReceiverAsyncClient to perform operations on Azure Service Bus. |
Modifier and Type | Method and Description |
---|---|
ServiceBusReceivedMessage |
ServiceBusReceivedMessageContext.getMessage()
Gets the message received from Service Bus.
|
ServiceBusReceivedMessage |
ServiceBusReceiverClient.peekMessage()
Reads the next active message without changing the state of the receiver or the message source.
|
ServiceBusReceivedMessage |
ServiceBusReceiverClient.peekMessage(long sequenceNumber)
Starting from the given sequence number, reads next the active message without changing the state of the receiver
or the message source.
|
ServiceBusReceivedMessage |
ServiceBusReceiverClient.receiveDeferredMessage(long sequenceNumber)
Receives a deferred
message . |
Modifier and Type | Method and Description |
---|---|
void |
ServiceBusReceiverClient.abandon(ServiceBusReceivedMessage message)
Abandons a
message . |
Mono<Void> |
ServiceBusReceiverAsyncClient.abandon(ServiceBusReceivedMessage message)
Abandons a
message . |
void |
ServiceBusReceiverClient.abandon(ServiceBusReceivedMessage message,
AbandonOptions options)
Abandons a
message and updates the message's properties. |
Mono<Void> |
ServiceBusReceiverAsyncClient.abandon(ServiceBusReceivedMessage message,
AbandonOptions options)
Abandons a
message updates the message's properties. |
void |
ServiceBusReceiverClient.complete(ServiceBusReceivedMessage message)
Completes a
message . |
Mono<Void> |
ServiceBusReceiverAsyncClient.complete(ServiceBusReceivedMessage message)
Completes a
message . |
void |
ServiceBusReceiverClient.complete(ServiceBusReceivedMessage message,
CompleteOptions options)
Completes a
message . |
Mono<Void> |
ServiceBusReceiverAsyncClient.complete(ServiceBusReceivedMessage message,
CompleteOptions options)
Completes a
message with the given options. |
void |
ServiceBusReceiverClient.deadLetter(ServiceBusReceivedMessage message)
Moves a
message to the dead-letter sub-queue. |
Mono<Void> |
ServiceBusReceiverAsyncClient.deadLetter(ServiceBusReceivedMessage message)
Moves a
message to the dead-letter sub-queue. |
void |
ServiceBusReceiverClient.deadLetter(ServiceBusReceivedMessage message,
DeadLetterOptions options)
Moves a
message to the dead-letter sub-queue with dead-letter reason, error
description, and/or modified properties. |
Mono<Void> |
ServiceBusReceiverAsyncClient.deadLetter(ServiceBusReceivedMessage message,
DeadLetterOptions options)
Moves a
message to the dead-letter sub-queue with the given options. |
void |
ServiceBusReceiverClient.defer(ServiceBusReceivedMessage message)
Defers a
message . |
Mono<Void> |
ServiceBusReceiverAsyncClient.defer(ServiceBusReceivedMessage message)
Defers a
message . |
void |
ServiceBusReceiverClient.defer(ServiceBusReceivedMessage message,
DeferOptions options)
Defers a
message using its lock token with modified message property. |
Mono<Void> |
ServiceBusReceiverAsyncClient.defer(ServiceBusReceivedMessage message,
DeferOptions options)
Defers a
message with the options set. |
OffsetDateTime |
ServiceBusReceiverClient.renewMessageLock(ServiceBusReceivedMessage message)
Renews the lock on the specified message.
|
Mono<OffsetDateTime> |
ServiceBusReceiverAsyncClient.renewMessageLock(ServiceBusReceivedMessage message)
Asynchronously renews the lock on the message.
|
Mono<Void> |
ServiceBusReceiverAsyncClient.renewMessageLock(ServiceBusReceivedMessage message,
Duration maxLockRenewalDuration)
Starts the auto lock renewal for a
message . |
void |
ServiceBusReceiverClient.renewMessageLock(ServiceBusReceivedMessage message,
Duration maxLockRenewalDuration,
Consumer<Throwable> onError)
Starts the auto lock renewal for a message with the given lock.
|
Constructor and Description |
---|
ServiceBusMessage(ServiceBusReceivedMessage receivedMessage)
Creates a
ServiceBusMessage using properties from receivedMessage . |
Copyright © 2021 Microsoft Corporation. All rights reserved.