public static interface PubSubProtocol.SubscriptionOptionsOrBuilder
extends com.google.protobuf.MessageOrBuilder
| Modifier and Type | Method and Description |
|---|---|
PubSubProtocol.SubscribeRequest.CreateOrAttach |
getCreateOrAttach()
optional .Hedwig.SubscribeRequest.CreateOrAttach createOrAttach = 2 [default = CREATE_OR_ATTACH]; |
boolean |
getEnableResubscribe()
enable resubscribe
|
boolean |
getForceAttach()
force attach subscription which would kill existed channel
this option doesn't need to be persisted
|
int |
getMessageBound()
optional uint32 messageBound = 3 [default = 0]; |
String |
getMessageFilter()
server-side message filter
|
com.google.protobuf.ByteString |
getMessageFilterBytes()
server-side message filter
|
int |
getMessageWindowSize()
message window size, this is the maximum number of messages
which will be delivered without being consumed
|
PubSubProtocol.Map |
getOptions()
user customized subscription options
|
PubSubProtocol.MapOrBuilder |
getOptionsOrBuilder()
user customized subscription options
|
boolean |
hasCreateOrAttach()
optional .Hedwig.SubscribeRequest.CreateOrAttach createOrAttach = 2 [default = CREATE_OR_ATTACH]; |
boolean |
hasEnableResubscribe()
enable resubscribe
|
boolean |
hasForceAttach()
force attach subscription which would kill existed channel
this option doesn't need to be persisted
|
boolean |
hasMessageBound()
optional uint32 messageBound = 3 [default = 0]; |
boolean |
hasMessageFilter()
server-side message filter
|
boolean |
hasMessageWindowSize()
message window size, this is the maximum number of messages
which will be delivered without being consumed
|
boolean |
hasOptions()
user customized subscription options
|
findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneofboolean hasForceAttach()
force attach subscription which would kill existed channel this option doesn't need to be persisted
optional bool forceAttach = 1 [default = false];boolean getForceAttach()
force attach subscription which would kill existed channel this option doesn't need to be persisted
optional bool forceAttach = 1 [default = false];boolean hasCreateOrAttach()
optional .Hedwig.SubscribeRequest.CreateOrAttach createOrAttach = 2 [default = CREATE_OR_ATTACH];PubSubProtocol.SubscribeRequest.CreateOrAttach getCreateOrAttach()
optional .Hedwig.SubscribeRequest.CreateOrAttach createOrAttach = 2 [default = CREATE_OR_ATTACH];boolean hasMessageBound()
optional uint32 messageBound = 3 [default = 0];int getMessageBound()
optional uint32 messageBound = 3 [default = 0];boolean hasOptions()
user customized subscription options
optional .Hedwig.Map options = 4;PubSubProtocol.Map getOptions()
user customized subscription options
optional .Hedwig.Map options = 4;PubSubProtocol.MapOrBuilder getOptionsOrBuilder()
user customized subscription options
optional .Hedwig.Map options = 4;boolean hasMessageFilter()
server-side message filter
optional string messageFilter = 5;String getMessageFilter()
server-side message filter
optional string messageFilter = 5;com.google.protobuf.ByteString getMessageFilterBytes()
server-side message filter
optional string messageFilter = 5;boolean hasMessageWindowSize()
message window size, this is the maximum number of messages which will be delivered without being consumed
optional uint32 messageWindowSize = 6;int getMessageWindowSize()
message window size, this is the maximum number of messages which will be delivered without being consumed
optional uint32 messageWindowSize = 6;boolean hasEnableResubscribe()
enable resubscribe
optional bool enableResubscribe = 7 [default = true];boolean getEnableResubscribe()
enable resubscribe
optional bool enableResubscribe = 7 [default = true];Copyright © 2011–2021 The Apache Software Foundation. All rights reserved.