IMessageBrowser.peekAsync 方法

定义

重载

peekAsync()

Asynchronously reads the active messages without changing the state of the receiver or the message source.

peekAsync(long fromSequenceNumber)

Asynchronously reads next the active message without changing the state of the receiver or the message source.

peekAsync()

Asynchronously reads the active messages without changing the state of the receiver or the message source.

public CompletableFuture<IMessage> peekAsync()

返回

CompletableFuture<IMessage>

Message peeked

peekAsync(long fromSequenceNumber)

Asynchronously reads next the active message without changing the state of the receiver or the message source.

public CompletableFuture<IMessage> peekAsync(long fromSequenceNumber)

参数

fromSequenceNumber
long

The sequence number from where to read the message.

返回

CompletableFuture<IMessage>

CompletableFuture that returns Message peeked.

适用于