Package | Description |
---|---|
org.apache.hedwig.client.api | |
org.apache.hedwig.client.handlers | |
org.apache.hedwig.client.netty |
A Netty based Hedwig client implementation.
|
org.apache.hedwig.client.netty.impl | |
org.apache.hedwig.protocol |
Modifier and Type | Method and Description |
---|---|
void |
Subscriber.consume(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
PubSubProtocol.MessageSeqId messageSeqId)
Manually send a consume message to the server for the given inputs.
|
Modifier and Type | Method and Description |
---|---|
abstract void |
SubscribeResponseHandler.consume(TopicSubscriber topicSubscriber,
PubSubProtocol.MessageSeqId messageSeqId)
Consume a given message for given topic subscriber thru this handler.
|
Modifier and Type | Method and Description |
---|---|
static PubSubProtocol.PubSubRequest.Builder |
NetUtils.buildConsumeRequest(long txnId,
TopicSubscriber topicSubscriber,
PubSubProtocol.MessageSeqId messageSeqId)
Build consume request
|
void |
HedwigSubscriber.consume(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
PubSubProtocol.MessageSeqId messageSeqId) |
Modifier and Type | Method and Description |
---|---|
void |
ActiveSubscriber.consume(PubSubProtocol.MessageSeqId messageSeqId)
Consume a specific message.
|
void |
AbstractSubscribeResponseHandler.consume(TopicSubscriber topicSubscriber,
PubSubProtocol.MessageSeqId messageSeqId) |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<PubSubProtocol.MessageSeqId> |
PubSubProtocol.MessageSeqId.PARSER
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
PubSubProtocol.MessageSeqId |
PubSubProtocol.MessageSeqId.Builder.build() |
PubSubProtocol.MessageSeqId |
PubSubProtocol.MessageSeqId.Builder.buildPartial() |
static PubSubProtocol.MessageSeqId |
PubSubProtocol.MessageSeqId.getDefaultInstance() |
PubSubProtocol.MessageSeqId |
PubSubProtocol.MessageSeqId.getDefaultInstanceForType() |
PubSubProtocol.MessageSeqId |
PubSubProtocol.MessageSeqId.Builder.getDefaultInstanceForType() |
PubSubProtocol.MessageSeqId |
PubSubProtocol.LedgerRangeOrBuilder.getEndSeqIdIncluded()
optional .Hedwig.MessageSeqId endSeqIdIncluded = 2; |
PubSubProtocol.MessageSeqId |
PubSubProtocol.LedgerRange.getEndSeqIdIncluded()
optional .Hedwig.MessageSeqId endSeqIdIncluded = 2; |
PubSubProtocol.MessageSeqId |
PubSubProtocol.LedgerRange.Builder.getEndSeqIdIncluded()
optional .Hedwig.MessageSeqId endSeqIdIncluded = 2; |
PubSubProtocol.MessageSeqId |
PubSubProtocol.MessageOrBuilder.getMsgId()
optional .Hedwig.MessageSeqId msgId = 3; |
PubSubProtocol.MessageSeqId |
PubSubProtocol.Message.getMsgId()
optional .Hedwig.MessageSeqId msgId = 3; |
PubSubProtocol.MessageSeqId |
PubSubProtocol.Message.Builder.getMsgId()
optional .Hedwig.MessageSeqId msgId = 3; |
PubSubProtocol.MessageSeqId |
PubSubProtocol.ConsumeRequestOrBuilder.getMsgId()
the msgId is cumulative: all messages up to this id are marked as consumed
|
PubSubProtocol.MessageSeqId |
PubSubProtocol.ConsumeRequest.getMsgId()
the msgId is cumulative: all messages up to this id are marked as consumed
|
PubSubProtocol.MessageSeqId |
PubSubProtocol.ConsumeRequest.Builder.getMsgId()
the msgId is cumulative: all messages up to this id are marked as consumed
|
PubSubProtocol.MessageSeqId |
PubSubProtocol.SubscriptionStateOrBuilder.getMsgId()
required .Hedwig.MessageSeqId msgId = 1; |
PubSubProtocol.MessageSeqId |
PubSubProtocol.SubscriptionState.getMsgId()
required .Hedwig.MessageSeqId msgId = 1; |
PubSubProtocol.MessageSeqId |
PubSubProtocol.SubscriptionState.Builder.getMsgId()
required .Hedwig.MessageSeqId msgId = 1; |
PubSubProtocol.MessageSeqId |
PubSubProtocol.PublishResponseOrBuilder.getPublishedMsgId()
If the request was a publish request, this was the message Id of the published message.
|
PubSubProtocol.MessageSeqId |
PubSubProtocol.PublishResponse.getPublishedMsgId()
If the request was a publish request, this was the message Id of the published message.
|
PubSubProtocol.MessageSeqId |
PubSubProtocol.PublishResponse.Builder.getPublishedMsgId()
If the request was a publish request, this was the message Id of the published message.
|
static PubSubProtocol.MessageSeqId |
PubSubProtocol.MessageSeqId.parseDelimitedFrom(InputStream input) |
static PubSubProtocol.MessageSeqId |
PubSubProtocol.MessageSeqId.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static PubSubProtocol.MessageSeqId |
PubSubProtocol.MessageSeqId.parseFrom(byte[] data) |
static PubSubProtocol.MessageSeqId |
PubSubProtocol.MessageSeqId.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static PubSubProtocol.MessageSeqId |
PubSubProtocol.MessageSeqId.parseFrom(com.google.protobuf.ByteString data) |
static PubSubProtocol.MessageSeqId |
PubSubProtocol.MessageSeqId.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static PubSubProtocol.MessageSeqId |
PubSubProtocol.MessageSeqId.parseFrom(com.google.protobuf.CodedInputStream input) |
static PubSubProtocol.MessageSeqId |
PubSubProtocol.MessageSeqId.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static PubSubProtocol.MessageSeqId |
PubSubProtocol.MessageSeqId.parseFrom(InputStream input) |
static PubSubProtocol.MessageSeqId |
PubSubProtocol.MessageSeqId.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<PubSubProtocol.MessageSeqId> |
PubSubProtocol.MessageSeqId.getParserForType() |
static com.google.protobuf.Parser<PubSubProtocol.MessageSeqId> |
PubSubProtocol.MessageSeqId.parser() |
Modifier and Type | Method and Description |
---|---|
PubSubProtocol.LedgerRange.Builder |
PubSubProtocol.LedgerRange.Builder.mergeEndSeqIdIncluded(PubSubProtocol.MessageSeqId value)
optional .Hedwig.MessageSeqId endSeqIdIncluded = 2; |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.Builder.mergeFrom(PubSubProtocol.MessageSeqId other) |
PubSubProtocol.Message.Builder |
PubSubProtocol.Message.Builder.mergeMsgId(PubSubProtocol.MessageSeqId value)
optional .Hedwig.MessageSeqId msgId = 3; |
PubSubProtocol.ConsumeRequest.Builder |
PubSubProtocol.ConsumeRequest.Builder.mergeMsgId(PubSubProtocol.MessageSeqId value)
the msgId is cumulative: all messages up to this id are marked as consumed
|
PubSubProtocol.SubscriptionState.Builder |
PubSubProtocol.SubscriptionState.Builder.mergeMsgId(PubSubProtocol.MessageSeqId value)
required .Hedwig.MessageSeqId msgId = 1; |
PubSubProtocol.PublishResponse.Builder |
PubSubProtocol.PublishResponse.Builder.mergePublishedMsgId(PubSubProtocol.MessageSeqId value)
If the request was a publish request, this was the message Id of the published message.
|
static PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.newBuilder(PubSubProtocol.MessageSeqId prototype) |
PubSubProtocol.LedgerRange.Builder |
PubSubProtocol.LedgerRange.Builder.setEndSeqIdIncluded(PubSubProtocol.MessageSeqId value)
optional .Hedwig.MessageSeqId endSeqIdIncluded = 2; |
PubSubProtocol.Message.Builder |
PubSubProtocol.Message.Builder.setMsgId(PubSubProtocol.MessageSeqId value)
optional .Hedwig.MessageSeqId msgId = 3; |
PubSubProtocol.ConsumeRequest.Builder |
PubSubProtocol.ConsumeRequest.Builder.setMsgId(PubSubProtocol.MessageSeqId value)
the msgId is cumulative: all messages up to this id are marked as consumed
|
PubSubProtocol.SubscriptionState.Builder |
PubSubProtocol.SubscriptionState.Builder.setMsgId(PubSubProtocol.MessageSeqId value)
required .Hedwig.MessageSeqId msgId = 1; |
PubSubProtocol.PublishResponse.Builder |
PubSubProtocol.PublishResponse.Builder.setPublishedMsgId(PubSubProtocol.MessageSeqId value)
If the request was a publish request, this was the message Id of the published message.
|
Copyright © 2011–2017 The Apache Software Foundation. All rights reserved.