Package | Description |
---|---|
org.apache.hedwig.client.netty |
A Netty based Hedwig client implementation.
|
org.apache.hedwig.protocol |
Modifier and Type | Method and Description |
---|---|
static PubSubProtocol.PubSubRequest.Builder |
NetUtils.buildConsumeRequest(long txnId,
TopicSubscriber topicSubscriber,
PubSubProtocol.MessageSeqId messageSeqId)
Build consume request
|
static PubSubProtocol.PubSubRequest.Builder |
NetUtils.buildPubSubRequest(long txnId,
PubSubData pubSubData)
This is a helper method to build the actual pub/sub message.
|
Modifier and Type | Method and Description |
---|---|
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.addAllTriedServers(Iterable<? extends com.google.protobuf.ByteString> values)
repeated bytes triedServers = 3; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.addTriedServers(com.google.protobuf.ByteString value)
repeated bytes triedServers = 3; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clear() |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clearCloseSubscriptionRequest()
optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clearConsumeRequest()
optional .Hedwig.ConsumeRequest consumeRequest = 54; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clearProtocolVersion()
required .Hedwig.ProtocolVersion protocolVersion = 1; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clearPublishRequest()
optional .Hedwig.PublishRequest publishRequest = 52; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clearShouldClaim()
optional bool shouldClaim = 5; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clearStartDeliveryRequest()
optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clearStopDeliveryRequest()
optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clearSubscribeRequest()
optional .Hedwig.SubscribeRequest subscribeRequest = 53; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clearTopic()
required bytes topic = 6; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clearTriedServers()
repeated bytes triedServers = 3; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clearTxnId()
required uint64 txnId = 4; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clearType()
required .Hedwig.OperationType type = 2; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clearUnsubscribeRequest()
optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.clone() |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.mergeCloseSubscriptionRequest(PubSubProtocol.CloseSubscriptionRequest value)
optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.mergeConsumeRequest(PubSubProtocol.ConsumeRequest value)
optional .Hedwig.ConsumeRequest consumeRequest = 54; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.mergeFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.mergeFrom(com.google.protobuf.Message other) |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.mergeFrom(PubSubProtocol.PubSubRequest other) |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.mergePublishRequest(PubSubProtocol.PublishRequest value)
optional .Hedwig.PublishRequest publishRequest = 52; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.mergeStartDeliveryRequest(PubSubProtocol.StartDeliveryRequest value)
optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.mergeStopDeliveryRequest(PubSubProtocol.StopDeliveryRequest value)
optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.mergeSubscribeRequest(PubSubProtocol.SubscribeRequest value)
optional .Hedwig.SubscribeRequest subscribeRequest = 53; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.mergeUnsubscribeRequest(PubSubProtocol.UnsubscribeRequest value)
optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55; |
static PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.newBuilder() |
static PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.newBuilder(PubSubProtocol.PubSubRequest prototype) |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.newBuilderForType() |
protected PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.newBuilderForType(com.google.protobuf.GeneratedMessage.BuilderParent parent) |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setCloseSubscriptionRequest(PubSubProtocol.CloseSubscriptionRequest.Builder builderForValue)
optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setCloseSubscriptionRequest(PubSubProtocol.CloseSubscriptionRequest value)
optional .Hedwig.CloseSubscriptionRequest closeSubscriptionRequest = 58; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setConsumeRequest(PubSubProtocol.ConsumeRequest.Builder builderForValue)
optional .Hedwig.ConsumeRequest consumeRequest = 54; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setConsumeRequest(PubSubProtocol.ConsumeRequest value)
optional .Hedwig.ConsumeRequest consumeRequest = 54; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setProtocolVersion(PubSubProtocol.ProtocolVersion value)
required .Hedwig.ProtocolVersion protocolVersion = 1; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setPublishRequest(PubSubProtocol.PublishRequest.Builder builderForValue)
optional .Hedwig.PublishRequest publishRequest = 52; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setPublishRequest(PubSubProtocol.PublishRequest value)
optional .Hedwig.PublishRequest publishRequest = 52; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setShouldClaim(boolean value)
optional bool shouldClaim = 5; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setStartDeliveryRequest(PubSubProtocol.StartDeliveryRequest.Builder builderForValue)
optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setStartDeliveryRequest(PubSubProtocol.StartDeliveryRequest value)
optional .Hedwig.StartDeliveryRequest startDeliveryRequest = 57; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setStopDeliveryRequest(PubSubProtocol.StopDeliveryRequest.Builder builderForValue)
optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setStopDeliveryRequest(PubSubProtocol.StopDeliveryRequest value)
optional .Hedwig.StopDeliveryRequest stopDeliveryRequest = 56; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setSubscribeRequest(PubSubProtocol.SubscribeRequest.Builder builderForValue)
optional .Hedwig.SubscribeRequest subscribeRequest = 53; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setSubscribeRequest(PubSubProtocol.SubscribeRequest value)
optional .Hedwig.SubscribeRequest subscribeRequest = 53; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setTopic(com.google.protobuf.ByteString value)
required bytes topic = 6; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setTriedServers(int index,
com.google.protobuf.ByteString value)
repeated bytes triedServers = 3; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setTxnId(long value)
required uint64 txnId = 4; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setType(PubSubProtocol.OperationType value)
required .Hedwig.OperationType type = 2; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setUnsubscribeRequest(PubSubProtocol.UnsubscribeRequest.Builder builderForValue)
optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.Builder.setUnsubscribeRequest(PubSubProtocol.UnsubscribeRequest value)
optional .Hedwig.UnsubscribeRequest unsubscribeRequest = 55; |
PubSubProtocol.PubSubRequest.Builder |
PubSubProtocol.PubSubRequest.toBuilder() |
Copyright © 2015 The Apache Software Foundation. All rights reserved.