IMessageBrowser Interface
public interface IMessageBrowser
Represents a message browser that can browse messages from Azure Service Bus.
Method Summary
Modifier and Type | Method and Description |
---|---|
abstract IMessage |
peek()
reads next the active message without changing the state of the receiver or the message source. |
abstract IMessage |
peek(long fromSequenceNumber)
Reads next the active message without changing the state of the receiver or the message source. |
abstract
Completable |
peekAsync()
Asynchronously reads the active messages without changing the state of the receiver or the message source. |
abstract
Completable |
peekAsync(long fromSequenceNumber)
Asynchronously reads next the active message without changing the state of the receiver or the message source. |
abstract Collection<IMessage> |
peekBatch(int messageCount)
Reads next batch of the active messages without changing the state of the receiver or the message source. |
abstract Collection<IMessage> |
peekBatch(long fromSequenceNumber, int messageCount)
Reads next batch of the active messages without changing the state of the receiver or the message source. |
abstract
Completable |
peekBatchAsync(int messageCount)
Asynchronously reads the next batch of active messages without changing the state of the receiver or the message source. |
abstract
Completable |
peekBatchAsync(long fromSequenceNumber, int messageCount)
Asynchronously reads the next batch of active messages without changing the state of the receiver or the message source. |
Method Details
peek
public abstract IMessage peek()
reads next the active message without changing the state of the receiver or the message source. The first call to peek() fetches the first active message for this receiver. Each subsequent call fetches the subsequent message in the entity.
Returns:
Throws:
peek
public abstract IMessage peek(long fromSequenceNumber)
Reads next the active message without changing the state of the receiver or the message source.
Parameters:
Returns:
Throws:
peekAsync
public abstract CompletableFuture
Asynchronously reads the active messages without changing the state of the receiver or the message source.
Returns:
peekAsync
public abstract CompletableFuture
Asynchronously reads next the active message without changing the state of the receiver or the message source.
Parameters:
Returns:
peekBatch
public abstract Collection
Reads next batch of the active messages without changing the state of the receiver or the message source.
Parameters:
Returns:
Throws:
peekBatch
public abstract Collection
Reads next batch of the active messages without changing the state of the receiver or the message source.
Parameters:
Returns:
Throws:
peekBatchAsync
public abstract CompletableFuture
Asynchronously reads the next batch of active messages without changing the state of the receiver or the message source.
Parameters:
Returns:
peekBatchAsync
public abstract CompletableFuture
Asynchronously reads the next batch of active messages without changing the state of the receiver or the message source.
Parameters:
Returns:
Applies to
Azure SDK for Java