Package | Description |
---|---|
org.apache.hedwig.protocol |
Modifier and Type | Class and Description |
---|---|
static class |
PubSubProtocol.MessageSeqId
Protobuf type
Hedwig.MessageSeqId |
static class |
PubSubProtocol.MessageSeqId.Builder
Protobuf type
Hedwig.MessageSeqId |
Modifier and Type | Method and Description |
---|---|
PubSubProtocol.MessageSeqIdOrBuilder |
PubSubProtocol.LedgerRangeOrBuilder.getEndSeqIdIncludedOrBuilder()
optional .Hedwig.MessageSeqId endSeqIdIncluded = 2; |
PubSubProtocol.MessageSeqIdOrBuilder |
PubSubProtocol.LedgerRange.getEndSeqIdIncludedOrBuilder()
optional .Hedwig.MessageSeqId endSeqIdIncluded = 2; |
PubSubProtocol.MessageSeqIdOrBuilder |
PubSubProtocol.LedgerRange.Builder.getEndSeqIdIncludedOrBuilder()
optional .Hedwig.MessageSeqId endSeqIdIncluded = 2; |
PubSubProtocol.MessageSeqIdOrBuilder |
PubSubProtocol.MessageOrBuilder.getMsgIdOrBuilder()
optional .Hedwig.MessageSeqId msgId = 3; |
PubSubProtocol.MessageSeqIdOrBuilder |
PubSubProtocol.Message.getMsgIdOrBuilder()
optional .Hedwig.MessageSeqId msgId = 3; |
PubSubProtocol.MessageSeqIdOrBuilder |
PubSubProtocol.Message.Builder.getMsgIdOrBuilder()
optional .Hedwig.MessageSeqId msgId = 3; |
PubSubProtocol.MessageSeqIdOrBuilder |
PubSubProtocol.ConsumeRequestOrBuilder.getMsgIdOrBuilder()
the msgId is cumulative: all messages up to this id are marked as consumed
|
PubSubProtocol.MessageSeqIdOrBuilder |
PubSubProtocol.ConsumeRequest.getMsgIdOrBuilder()
the msgId is cumulative: all messages up to this id are marked as consumed
|
PubSubProtocol.MessageSeqIdOrBuilder |
PubSubProtocol.ConsumeRequest.Builder.getMsgIdOrBuilder()
the msgId is cumulative: all messages up to this id are marked as consumed
|
PubSubProtocol.MessageSeqIdOrBuilder |
PubSubProtocol.SubscriptionStateOrBuilder.getMsgIdOrBuilder()
required .Hedwig.MessageSeqId msgId = 1; |
PubSubProtocol.MessageSeqIdOrBuilder |
PubSubProtocol.SubscriptionState.getMsgIdOrBuilder()
required .Hedwig.MessageSeqId msgId = 1; |
PubSubProtocol.MessageSeqIdOrBuilder |
PubSubProtocol.SubscriptionState.Builder.getMsgIdOrBuilder()
required .Hedwig.MessageSeqId msgId = 1; |
PubSubProtocol.MessageSeqIdOrBuilder |
PubSubProtocol.PublishResponseOrBuilder.getPublishedMsgIdOrBuilder()
If the request was a publish request, this was the message Id of the published message.
|
PubSubProtocol.MessageSeqIdOrBuilder |
PubSubProtocol.PublishResponse.getPublishedMsgIdOrBuilder()
If the request was a publish request, this was the message Id of the published message.
|
PubSubProtocol.MessageSeqIdOrBuilder |
PubSubProtocol.PublishResponse.Builder.getPublishedMsgIdOrBuilder()
If the request was a publish request, this was the message Id of the published message.
|
Copyright © 2011–2019 The Apache Software Foundation. All rights reserved.