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, hasOneof
boolean 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–2018 The Apache Software Foundation. All rights reserved.