Skip to content

Commit a9f0adc

Browse files
authored
[Service Bus] Peek doc updates (Azure#33320)
The focus of these changes is to add a "see also" link to the peek-related methods helping developers to find the official documentation with context around browsing messages. Also riding along are some minor formatting fixes.
1 parent 81e39f7 commit a9f0adc

File tree

3 files changed

+18
-16
lines changed

3 files changed

+18
-16
lines changed

sdk/servicebus/Azure.Messaging.ServiceBus/src/Processor/ProcessorReceiveActions.cs

Lines changed: 15 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,7 @@ public virtual async Task<IReadOnlyList<ServiceBusReceivedMessage>> ReceiveMessa
7272
return TrackMessagesAsReceived(messages);
7373
}
7474

75-
/// <summary>
75+
/// <summary>
7676
/// Receives a list of deferred <see cref="ServiceBusReceivedMessage"/> identified by <paramref name="sequenceNumbers"/>.
7777
/// Messages received using this method are subject to the behavior defined in the <see cref="ServiceBusProcessorOptions.AutoCompleteMessages"/>
7878
/// and <see cref="ServiceBusProcessorOptions.MaxAutoLockRenewalDuration"/> properties.
@@ -88,7 +88,7 @@ public virtual async Task<IReadOnlyList<ServiceBusReceivedMessage>> ReceiveMessa
8888
/// The specified sequence number does not correspond to a message that has been deferred.
8989
/// The <see cref="ServiceBusException.Reason" /> will be set to <see cref="ServiceBusFailureReason.MessageNotFound"/> in this case.
9090
/// </exception>
91-
public virtual async Task<IReadOnlyList<ServiceBusReceivedMessage>> ReceiveDeferredMessagesAsync(
91+
public virtual async Task<IReadOnlyList<ServiceBusReceivedMessage>> ReceiveDeferredMessagesAsync(
9292
IEnumerable<long> sequenceNumbers,
9393
CancellationToken cancellationToken = default)
9494
{
@@ -97,22 +97,22 @@ public virtual async Task<IReadOnlyList<ServiceBusReceivedMessage>> ReceiveDefer
9797
return TrackMessagesAsReceived(messages);
9898
}
9999

100-
/// <inheritdoc cref="ServiceBusReceiver.PeekMessagesAsync"/>
101-
public virtual async Task<IReadOnlyList<ServiceBusReceivedMessage>> PeekMessagesAsync(
102-
int maxMessages,
103-
long? fromSequenceNumber = default,
104-
CancellationToken cancellationToken = default)
100+
/// <inheritdoc cref="ServiceBusReceiver.PeekMessagesAsync"/>
101+
public virtual async Task<IReadOnlyList<ServiceBusReceivedMessage>> PeekMessagesAsync(
102+
int maxMessages,
103+
long? fromSequenceNumber = default,
104+
CancellationToken cancellationToken = default)
105105
{
106-
ValidateCallbackInScope();
106+
ValidateCallbackInScope();
107107

108-
// Peeked messages are not locked so we don't need to track them for lock renewal or autocompletion, as these options do not apply.
109-
return await _receiver.PeekMessagesAsync(
110-
maxMessages: maxMessages,
111-
fromSequenceNumber: fromSequenceNumber,
112-
cancellationToken: cancellationToken).ConfigureAwait(false);
108+
// Peeked messages are not locked so we don't need to track them for lock renewal or autocompletion, as these options do not apply.
109+
return await _receiver.PeekMessagesAsync(
110+
maxMessages: maxMessages,
111+
fromSequenceNumber: fromSequenceNumber,
112+
cancellationToken: cancellationToken).ConfigureAwait(false);
113113
}
114114

115-
private IReadOnlyList<ServiceBusReceivedMessage> TrackMessagesAsReceived(IReadOnlyList<ServiceBusReceivedMessage> messages)
115+
private IReadOnlyList<ServiceBusReceivedMessage> TrackMessagesAsReceived(IReadOnlyList<ServiceBusReceivedMessage> messages)
116116
{
117117
if (_autoRenew)
118118
{
@@ -169,4 +169,4 @@ private void ValidateCallbackInScope()
169169
}
170170
}
171171
}
172-
}
172+
}

sdk/servicebus/Azure.Messaging.ServiceBus/src/Receiver/ServiceBusReceiver.cs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -419,6 +419,7 @@ public virtual async Task<ServiceBusReceivedMessage> ReceiveMessageAsync(
419419
/// </remarks>
420420
///
421421
/// <returns>The <see cref="ServiceBusReceivedMessage" /> that represents the next message to be read. Returns null when nothing to peek.</returns>
422+
/// <seealso href="https://aka.ms/azsdk/servicebus/message-browsing">Service Bus message browsing</seealso>
422423
public virtual async Task<ServiceBusReceivedMessage> PeekMessageAsync(
423424
long? fromSequenceNumber = default,
424425
CancellationToken cancellationToken = default)
@@ -451,6 +452,7 @@ public virtual async Task<ServiceBusReceivedMessage> PeekMessageAsync(
451452
/// </remarks>
452453
///
453454
/// <returns>An <see cref="IReadOnlyList{ServiceBusReceivedMessage}" /> of messages that were peeked.</returns>
455+
/// <seealso href="https://aka.ms/azsdk/servicebus/message-browsing">Service Bus message browsing</seealso>
454456
public virtual async Task<IReadOnlyList<ServiceBusReceivedMessage>> PeekMessagesAsync(
455457
int maxMessages,
456458
long? fromSequenceNumber = default,

sdk/servicebus/Microsoft.Azure.WebJobs.Extensions.ServiceBus/src/Primitives/ServiceBusReceiveActions.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -102,7 +102,7 @@ public virtual async Task<IReadOnlyList<ServiceBusReceivedMessage>> ReceiveMessa
102102
/// The specified sequence number does not correspond to a message that has been deferred.
103103
/// The <see cref="ServiceBusException.Reason" /> will be set to <see cref="ServiceBusFailureReason.MessageNotFound"/> in this case.
104104
/// </exception>
105-
public virtual async Task<IReadOnlyList<ServiceBusReceivedMessage>> ReceiveDeferredMessagesAsync(
105+
public virtual async Task<IReadOnlyList<ServiceBusReceivedMessage>> ReceiveDeferredMessagesAsync(
106106
IEnumerable<long> sequenceNumbers,
107107
CancellationToken cancellationToken = default)
108108
{

0 commit comments

Comments
 (0)