http://git-wip-us.apache.org/repos/asf/bookkeeper/blob/9a8d62b1/hedwig-protocol/src/main/java/org/apache/hedwig/protocol/PubSubProtocol.java ---------------------------------------------------------------------- diff --git a/hedwig-protocol/src/main/java/org/apache/hedwig/protocol/PubSubProtocol.java b/hedwig-protocol/src/main/java/org/apache/hedwig/protocol/PubSubProtocol.java deleted file mode 100644 index 4bba8cc..0000000 --- a/hedwig-protocol/src/main/java/org/apache/hedwig/protocol/PubSubProtocol.java +++ /dev/null @@ -1,16883 +0,0 @@ -// Generated by the protocol buffer compiler. DO NOT EDIT! -// source: src/main/protobuf/PubSubProtocol.proto - -package org.apache.hedwig.protocol; - -public final class PubSubProtocol { - private PubSubProtocol() {} - public static void registerAllExtensions( - com.google.protobuf.ExtensionRegistry registry) { - } - public enum ProtocolVersion - implements com.google.protobuf.ProtocolMessageEnum { - VERSION_ONE(0, 1), - ; - - public static final int VERSION_ONE_VALUE = 1; - - - public final int getNumber() { return value; } - - public static ProtocolVersion valueOf(int value) { - switch (value) { - case 1: return VERSION_ONE; - default: return null; - } - } - - public static com.google.protobuf.Internal.EnumLiteMap<ProtocolVersion> - internalGetValueMap() { - return internalValueMap; - } - private static com.google.protobuf.Internal.EnumLiteMap<ProtocolVersion> - internalValueMap = - new com.google.protobuf.Internal.EnumLiteMap<ProtocolVersion>() { - public ProtocolVersion findValueByNumber(int number) { - return ProtocolVersion.valueOf(number); - } - }; - - public final com.google.protobuf.Descriptors.EnumValueDescriptor - getValueDescriptor() { - return getDescriptor().getValues().get(index); - } - public final com.google.protobuf.Descriptors.EnumDescriptor - getDescriptorForType() { - return getDescriptor(); - } - public static final com.google.protobuf.Descriptors.EnumDescriptor - getDescriptor() { - return org.apache.hedwig.protocol.PubSubProtocol.getDescriptor().getEnumTypes().get(0); - } - - private static final ProtocolVersion[] VALUES = { - VERSION_ONE, - }; - - public static ProtocolVersion valueOf( - com.google.protobuf.Descriptors.EnumValueDescriptor desc) { - if (desc.getType() != getDescriptor()) { - throw new java.lang.IllegalArgumentException( - "EnumValueDescriptor is not for this type."); - } - return VALUES[desc.getIndex()]; - } - - private final int index; - private final int value; - - private ProtocolVersion(int index, int value) { - this.index = index; - this.value = value; - } - - // @@protoc_insertion_point(enum_scope:Hedwig.ProtocolVersion) - } - - public enum OperationType - implements com.google.protobuf.ProtocolMessageEnum { - PUBLISH(0, 0), - SUBSCRIBE(1, 1), - CONSUME(2, 2), - UNSUBSCRIBE(3, 3), - START_DELIVERY(4, 4), - STOP_DELIVERY(5, 5), - CLOSESUBSCRIPTION(6, 6), - ; - - public static final int PUBLISH_VALUE = 0; - public static final int SUBSCRIBE_VALUE = 1; - public static final int CONSUME_VALUE = 2; - public static final int UNSUBSCRIBE_VALUE = 3; - public static final int START_DELIVERY_VALUE = 4; - public static final int STOP_DELIVERY_VALUE = 5; - public static final int CLOSESUBSCRIPTION_VALUE = 6; - - - public final int getNumber() { return value; } - - public static OperationType valueOf(int value) { - switch (value) { - case 0: return PUBLISH; - case 1: return SUBSCRIBE; - case 2: return CONSUME; - case 3: return UNSUBSCRIBE; - case 4: return START_DELIVERY; - case 5: return STOP_DELIVERY; - case 6: return CLOSESUBSCRIPTION; - default: return null; - } - } - - public static com.google.protobuf.Internal.EnumLiteMap<OperationType> - internalGetValueMap() { - return internalValueMap; - } - private static com.google.protobuf.Internal.EnumLiteMap<OperationType> - internalValueMap = - new com.google.protobuf.Internal.EnumLiteMap<OperationType>() { - public OperationType findValueByNumber(int number) { - return OperationType.valueOf(number); - } - }; - - public final com.google.protobuf.Descriptors.EnumValueDescriptor - getValueDescriptor() { - return getDescriptor().getValues().get(index); - } - public final com.google.protobuf.Descriptors.EnumDescriptor - getDescriptorForType() { - return getDescriptor(); - } - public static final com.google.protobuf.Descriptors.EnumDescriptor - getDescriptor() { - return org.apache.hedwig.protocol.PubSubProtocol.getDescriptor().getEnumTypes().get(1); - } - - private static final OperationType[] VALUES = { - PUBLISH, SUBSCRIBE, CONSUME, UNSUBSCRIBE, START_DELIVERY, STOP_DELIVERY, CLOSESUBSCRIPTION, - }; - - public static OperationType valueOf( - com.google.protobuf.Descriptors.EnumValueDescriptor desc) { - if (desc.getType() != getDescriptor()) { - throw new java.lang.IllegalArgumentException( - "EnumValueDescriptor is not for this type."); - } - return VALUES[desc.getIndex()]; - } - - private final int index; - private final int value; - - private OperationType(int index, int value) { - this.index = index; - this.value = value; - } - - // @@protoc_insertion_point(enum_scope:Hedwig.OperationType) - } - - public enum SubscriptionEvent - implements com.google.protobuf.ProtocolMessageEnum { - TOPIC_MOVED(0, 1), - SUBSCRIPTION_FORCED_CLOSED(1, 2), - ; - - public static final int TOPIC_MOVED_VALUE = 1; - public static final int SUBSCRIPTION_FORCED_CLOSED_VALUE = 2; - - - public final int getNumber() { return value; } - - public static SubscriptionEvent valueOf(int value) { - switch (value) { - case 1: return TOPIC_MOVED; - case 2: return SUBSCRIPTION_FORCED_CLOSED; - default: return null; - } - } - - public static com.google.protobuf.Internal.EnumLiteMap<SubscriptionEvent> - internalGetValueMap() { - return internalValueMap; - } - private static com.google.protobuf.Internal.EnumLiteMap<SubscriptionEvent> - internalValueMap = - new com.google.protobuf.Internal.EnumLiteMap<SubscriptionEvent>() { - public SubscriptionEvent findValueByNumber(int number) { - return SubscriptionEvent.valueOf(number); - } - }; - - public final com.google.protobuf.Descriptors.EnumValueDescriptor - getValueDescriptor() { - return getDescriptor().getValues().get(index); - } - public final com.google.protobuf.Descriptors.EnumDescriptor - getDescriptorForType() { - return getDescriptor(); - } - public static final com.google.protobuf.Descriptors.EnumDescriptor - getDescriptor() { - return org.apache.hedwig.protocol.PubSubProtocol.getDescriptor().getEnumTypes().get(2); - } - - private static final SubscriptionEvent[] VALUES = { - TOPIC_MOVED, SUBSCRIPTION_FORCED_CLOSED, - }; - - public static SubscriptionEvent valueOf( - com.google.protobuf.Descriptors.EnumValueDescriptor desc) { - if (desc.getType() != getDescriptor()) { - throw new java.lang.IllegalArgumentException( - "EnumValueDescriptor is not for this type."); - } - return VALUES[desc.getIndex()]; - } - - private final int index; - private final int value; - - private SubscriptionEvent(int index, int value) { - this.index = index; - this.value = value; - } - - // @@protoc_insertion_point(enum_scope:Hedwig.SubscriptionEvent) - } - - public enum StatusCode - implements com.google.protobuf.ProtocolMessageEnum { - SUCCESS(0, 0), - MALFORMED_REQUEST(1, 401), - NO_SUCH_TOPIC(2, 402), - CLIENT_ALREADY_SUBSCRIBED(3, 403), - CLIENT_NOT_SUBSCRIBED(4, 404), - COULD_NOT_CONNECT(5, 405), - TOPIC_BUSY(6, 406), - RESUBSCRIBE_EXCEPTION(7, 407), - NOT_RESPONSIBLE_FOR_TOPIC(8, 501), - SERVICE_DOWN(9, 502), - UNCERTAIN_STATE(10, 503), - INVALID_MESSAGE_FILTER(11, 504), - BAD_VERSION(12, 520), - NO_TOPIC_PERSISTENCE_INFO(13, 521), - TOPIC_PERSISTENCE_INFO_EXISTS(14, 522), - NO_SUBSCRIPTION_STATE(15, 523), - SUBSCRIPTION_STATE_EXISTS(16, 524), - NO_TOPIC_OWNER_INFO(17, 525), - TOPIC_OWNER_INFO_EXISTS(18, 526), - UNEXPECTED_CONDITION(19, 600), - COMPOSITE(20, 700), - ; - - public static final int SUCCESS_VALUE = 0; - public static final int MALFORMED_REQUEST_VALUE = 401; - public static final int NO_SUCH_TOPIC_VALUE = 402; - public static final int CLIENT_ALREADY_SUBSCRIBED_VALUE = 403; - public static final int CLIENT_NOT_SUBSCRIBED_VALUE = 404; - public static final int COULD_NOT_CONNECT_VALUE = 405; - public static final int TOPIC_BUSY_VALUE = 406; - public static final int RESUBSCRIBE_EXCEPTION_VALUE = 407; - public static final int NOT_RESPONSIBLE_FOR_TOPIC_VALUE = 501; - public static final int SERVICE_DOWN_VALUE = 502; - public static final int UNCERTAIN_STATE_VALUE = 503; - public static final int INVALID_MESSAGE_FILTER_VALUE = 504; - public static final int BAD_VERSION_VALUE = 520; - public static final int NO_TOPIC_PERSISTENCE_INFO_VALUE = 521; - public static final int TOPIC_PERSISTENCE_INFO_EXISTS_VALUE = 522; - public static final int NO_SUBSCRIPTION_STATE_VALUE = 523; - public static final int SUBSCRIPTION_STATE_EXISTS_VALUE = 524; - public static final int NO_TOPIC_OWNER_INFO_VALUE = 525; - public static final int TOPIC_OWNER_INFO_EXISTS_VALUE = 526; - public static final int UNEXPECTED_CONDITION_VALUE = 600; - public static final int COMPOSITE_VALUE = 700; - - - public final int getNumber() { return value; } - - public static StatusCode valueOf(int value) { - switch (value) { - case 0: return SUCCESS; - case 401: return MALFORMED_REQUEST; - case 402: return NO_SUCH_TOPIC; - case 403: return CLIENT_ALREADY_SUBSCRIBED; - case 404: return CLIENT_NOT_SUBSCRIBED; - case 405: return COULD_NOT_CONNECT; - case 406: return TOPIC_BUSY; - case 407: return RESUBSCRIBE_EXCEPTION; - case 501: return NOT_RESPONSIBLE_FOR_TOPIC; - case 502: return SERVICE_DOWN; - case 503: return UNCERTAIN_STATE; - case 504: return INVALID_MESSAGE_FILTER; - case 520: return BAD_VERSION; - case 521: return NO_TOPIC_PERSISTENCE_INFO; - case 522: return TOPIC_PERSISTENCE_INFO_EXISTS; - case 523: return NO_SUBSCRIPTION_STATE; - case 524: return SUBSCRIPTION_STATE_EXISTS; - case 525: return NO_TOPIC_OWNER_INFO; - case 526: return TOPIC_OWNER_INFO_EXISTS; - case 600: return UNEXPECTED_CONDITION; - case 700: return COMPOSITE; - default: return null; - } - } - - public static com.google.protobuf.Internal.EnumLiteMap<StatusCode> - internalGetValueMap() { - return internalValueMap; - } - private static com.google.protobuf.Internal.EnumLiteMap<StatusCode> - internalValueMap = - new com.google.protobuf.Internal.EnumLiteMap<StatusCode>() { - public StatusCode findValueByNumber(int number) { - return StatusCode.valueOf(number); - } - }; - - public final com.google.protobuf.Descriptors.EnumValueDescriptor - getValueDescriptor() { - return getDescriptor().getValues().get(index); - } - public final com.google.protobuf.Descriptors.EnumDescriptor - getDescriptorForType() { - return getDescriptor(); - } - public static final com.google.protobuf.Descriptors.EnumDescriptor - getDescriptor() { - return org.apache.hedwig.protocol.PubSubProtocol.getDescriptor().getEnumTypes().get(3); - } - - private static final StatusCode[] VALUES = { - SUCCESS, MALFORMED_REQUEST, NO_SUCH_TOPIC, CLIENT_ALREADY_SUBSCRIBED, CLIENT_NOT_SUBSCRIBED, COULD_NOT_CONNECT, TOPIC_BUSY, RESUBSCRIBE_EXCEPTION, NOT_RESPONSIBLE_FOR_TOPIC, SERVICE_DOWN, UNCERTAIN_STATE, INVALID_MESSAGE_FILTER, BAD_VERSION, NO_TOPIC_PERSISTENCE_INFO, TOPIC_PERSISTENCE_INFO_EXISTS, NO_SUBSCRIPTION_STATE, SUBSCRIPTION_STATE_EXISTS, NO_TOPIC_OWNER_INFO, TOPIC_OWNER_INFO_EXISTS, UNEXPECTED_CONDITION, COMPOSITE, - }; - - public static StatusCode valueOf( - com.google.protobuf.Descriptors.EnumValueDescriptor desc) { - if (desc.getType() != getDescriptor()) { - throw new java.lang.IllegalArgumentException( - "EnumValueDescriptor is not for this type."); - } - return VALUES[desc.getIndex()]; - } - - private final int index; - private final int value; - - private StatusCode(int index, int value) { - this.index = index; - this.value = value; - } - - // @@protoc_insertion_point(enum_scope:Hedwig.StatusCode) - } - - public interface MapOrBuilder - extends com.google.protobuf.MessageOrBuilder { - - // repeated .Hedwig.Map.Entry entries = 1; - java.util.List<org.apache.hedwig.protocol.PubSubProtocol.Map.Entry> - getEntriesList(); - org.apache.hedwig.protocol.PubSubProtocol.Map.Entry getEntries(int index); - int getEntriesCount(); - java.util.List<? extends org.apache.hedwig.protocol.PubSubProtocol.Map.EntryOrBuilder> - getEntriesOrBuilderList(); - org.apache.hedwig.protocol.PubSubProtocol.Map.EntryOrBuilder getEntriesOrBuilder( - int index); - } - public static final class Map extends - com.google.protobuf.GeneratedMessage - implements MapOrBuilder { - // Use Map.newBuilder() to construct. - private Map(Builder builder) { - super(builder); - } - private Map(boolean noInit) {} - - private static final Map defaultInstance; - public static Map getDefaultInstance() { - return defaultInstance; - } - - public Map getDefaultInstanceForType() { - return defaultInstance; - } - - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return org.apache.hedwig.protocol.PubSubProtocol.internal_static_Hedwig_Map_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return org.apache.hedwig.protocol.PubSubProtocol.internal_static_Hedwig_Map_fieldAccessorTable; - } - - public interface EntryOrBuilder - extends com.google.protobuf.MessageOrBuilder { - - // optional string key = 1; - boolean hasKey(); - String getKey(); - - // optional bytes value = 2; - boolean hasValue(); - com.google.protobuf.ByteString getValue(); - } - public static final class Entry extends - com.google.protobuf.GeneratedMessage - implements EntryOrBuilder { - // Use Entry.newBuilder() to construct. - private Entry(Builder builder) { - super(builder); - } - private Entry(boolean noInit) {} - - private static final Entry defaultInstance; - public static Entry getDefaultInstance() { - return defaultInstance; - } - - public Entry getDefaultInstanceForType() { - return defaultInstance; - } - - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return org.apache.hedwig.protocol.PubSubProtocol.internal_static_Hedwig_Map_Entry_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return org.apache.hedwig.protocol.PubSubProtocol.internal_static_Hedwig_Map_Entry_fieldAccessorTable; - } - - private int bitField0_; - // optional string key = 1; - public static final int KEY_FIELD_NUMBER = 1; - private java.lang.Object key_; - public boolean hasKey() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public String getKey() { - java.lang.Object ref = key_; - if (ref instanceof String) { - return (String) ref; - } else { - com.google.protobuf.ByteString bs = - (com.google.protobuf.ByteString) ref; - String s = bs.toStringUtf8(); - if (com.google.protobuf.Internal.isValidUtf8(bs)) { - key_ = s; - } - return s; - } - } - private com.google.protobuf.ByteString getKeyBytes() { - java.lang.Object ref = key_; - if (ref instanceof String) { - com.google.protobuf.ByteString b = - com.google.protobuf.ByteString.copyFromUtf8((String) ref); - key_ = b; - return b; - } else { - return (com.google.protobuf.ByteString) ref; - } - } - - // optional bytes value = 2; - public static final int VALUE_FIELD_NUMBER = 2; - private com.google.protobuf.ByteString value_; - public boolean hasValue() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public com.google.protobuf.ByteString getValue() { - return value_; - } - - private void initFields() { - key_ = ""; - value_ = com.google.protobuf.ByteString.EMPTY; - } - private byte memoizedIsInitialized = -1; - public final boolean isInitialized() { - byte isInitialized = memoizedIsInitialized; - if (isInitialized != -1) return isInitialized == 1; - - memoizedIsInitialized = 1; - return true; - } - - public void writeTo(com.google.protobuf.CodedOutputStream output) - throws java.io.IOException { - getSerializedSize(); - if (((bitField0_ & 0x00000001) == 0x00000001)) { - output.writeBytes(1, getKeyBytes()); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - output.writeBytes(2, value_); - } - getUnknownFields().writeTo(output); - } - - private int memoizedSerializedSize = -1; - public int getSerializedSize() { - int size = memoizedSerializedSize; - if (size != -1) return size; - - size = 0; - if (((bitField0_ & 0x00000001) == 0x00000001)) { - size += com.google.protobuf.CodedOutputStream - .computeBytesSize(1, getKeyBytes()); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - size += com.google.protobuf.CodedOutputStream - .computeBytesSize(2, value_); - } - size += getUnknownFields().getSerializedSize(); - memoizedSerializedSize = size; - return size; - } - - private static final long serialVersionUID = 0L; - @java.lang.Override - protected java.lang.Object writeReplace() - throws java.io.ObjectStreamException { - return super.writeReplace(); - } - - public static org.apache.hedwig.protocol.PubSubProtocol.Map.Entry parseFrom( - com.google.protobuf.ByteString data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.Map.Entry parseFrom( - com.google.protobuf.ByteString data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.Map.Entry parseFrom(byte[] data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.Map.Entry parseFrom( - byte[] data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.Map.Entry parseFrom(java.io.InputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.Map.Entry parseFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return newBuilder().mergeFrom(input, extensionRegistry) - .buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.Map.Entry parseDelimitedFrom(java.io.InputStream input) - throws java.io.IOException { - Builder builder = newBuilder(); - if (builder.mergeDelimitedFrom(input)) { - return builder.buildParsed(); - } else { - return null; - } - } - public static org.apache.hedwig.protocol.PubSubProtocol.Map.Entry parseDelimitedFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - Builder builder = newBuilder(); - if (builder.mergeDelimitedFrom(input, extensionRegistry)) { - return builder.buildParsed(); - } else { - return null; - } - } - public static org.apache.hedwig.protocol.PubSubProtocol.Map.Entry parseFrom( - com.google.protobuf.CodedInputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.Map.Entry parseFrom( - com.google.protobuf.CodedInputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return newBuilder().mergeFrom(input, extensionRegistry) - .buildParsed(); - } - - public static Builder newBuilder() { return Builder.create(); } - public Builder newBuilderForType() { return newBuilder(); } - public static Builder newBuilder(org.apache.hedwig.protocol.PubSubProtocol.Map.Entry prototype) { - return newBuilder().mergeFrom(prototype); - } - public Builder toBuilder() { return newBuilder(this); } - - @java.lang.Override - protected Builder newBuilderForType( - com.google.protobuf.GeneratedMessage.BuilderParent parent) { - Builder builder = new Builder(parent); - return builder; - } - public static final class Builder extends - com.google.protobuf.GeneratedMessage.Builder<Builder> - implements org.apache.hedwig.protocol.PubSubProtocol.Map.EntryOrBuilder { - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return org.apache.hedwig.protocol.PubSubProtocol.internal_static_Hedwig_Map_Entry_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return org.apache.hedwig.protocol.PubSubProtocol.internal_static_Hedwig_Map_Entry_fieldAccessorTable; - } - - // Construct using org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.newBuilder() - private Builder() { - maybeForceBuilderInitialization(); - } - - private Builder(BuilderParent parent) { - super(parent); - maybeForceBuilderInitialization(); - } - private void maybeForceBuilderInitialization() { - if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { - } - } - private static Builder create() { - return new Builder(); - } - - public Builder clear() { - super.clear(); - key_ = ""; - bitField0_ = (bitField0_ & ~0x00000001); - value_ = com.google.protobuf.ByteString.EMPTY; - bitField0_ = (bitField0_ & ~0x00000002); - return this; - } - - public Builder clone() { - return create().mergeFrom(buildPartial()); - } - - public com.google.protobuf.Descriptors.Descriptor - getDescriptorForType() { - return org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.getDescriptor(); - } - - public org.apache.hedwig.protocol.PubSubProtocol.Map.Entry getDefaultInstanceForType() { - return org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.getDefaultInstance(); - } - - public org.apache.hedwig.protocol.PubSubProtocol.Map.Entry build() { - org.apache.hedwig.protocol.PubSubProtocol.Map.Entry result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException(result); - } - return result; - } - - private org.apache.hedwig.protocol.PubSubProtocol.Map.Entry buildParsed() - throws com.google.protobuf.InvalidProtocolBufferException { - org.apache.hedwig.protocol.PubSubProtocol.Map.Entry result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException( - result).asInvalidProtocolBufferException(); - } - return result; - } - - public org.apache.hedwig.protocol.PubSubProtocol.Map.Entry buildPartial() { - org.apache.hedwig.protocol.PubSubProtocol.Map.Entry result = new org.apache.hedwig.protocol.PubSubProtocol.Map.Entry(this); - int from_bitField0_ = bitField0_; - int to_bitField0_ = 0; - if (((from_bitField0_ & 0x00000001) == 0x00000001)) { - to_bitField0_ |= 0x00000001; - } - result.key_ = key_; - if (((from_bitField0_ & 0x00000002) == 0x00000002)) { - to_bitField0_ |= 0x00000002; - } - result.value_ = value_; - result.bitField0_ = to_bitField0_; - onBuilt(); - return result; - } - - public Builder mergeFrom(com.google.protobuf.Message other) { - if (other instanceof org.apache.hedwig.protocol.PubSubProtocol.Map.Entry) { - return mergeFrom((org.apache.hedwig.protocol.PubSubProtocol.Map.Entry)other); - } else { - super.mergeFrom(other); - return this; - } - } - - public Builder mergeFrom(org.apache.hedwig.protocol.PubSubProtocol.Map.Entry other) { - if (other == org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.getDefaultInstance()) return this; - if (other.hasKey()) { - setKey(other.getKey()); - } - if (other.hasValue()) { - setValue(other.getValue()); - } - this.mergeUnknownFields(other.getUnknownFields()); - return this; - } - - public final boolean isInitialized() { - return true; - } - - public Builder mergeFrom( - com.google.protobuf.CodedInputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - com.google.protobuf.UnknownFieldSet.Builder unknownFields = - com.google.protobuf.UnknownFieldSet.newBuilder( - this.getUnknownFields()); - while (true) { - int tag = input.readTag(); - switch (tag) { - case 0: - this.setUnknownFields(unknownFields.build()); - onChanged(); - return this; - default: { - if (!parseUnknownField(input, unknownFields, - extensionRegistry, tag)) { - this.setUnknownFields(unknownFields.build()); - onChanged(); - return this; - } - break; - } - case 10: { - bitField0_ |= 0x00000001; - key_ = input.readBytes(); - break; - } - case 18: { - bitField0_ |= 0x00000002; - value_ = input.readBytes(); - break; - } - } - } - } - - private int bitField0_; - - // optional string key = 1; - private java.lang.Object key_ = ""; - public boolean hasKey() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public String getKey() { - java.lang.Object ref = key_; - if (!(ref instanceof String)) { - String s = ((com.google.protobuf.ByteString) ref).toStringUtf8(); - key_ = s; - return s; - } else { - return (String) ref; - } - } - public Builder setKey(String value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000001; - key_ = value; - onChanged(); - return this; - } - public Builder clearKey() { - bitField0_ = (bitField0_ & ~0x00000001); - key_ = getDefaultInstance().getKey(); - onChanged(); - return this; - } - void setKey(com.google.protobuf.ByteString value) { - bitField0_ |= 0x00000001; - key_ = value; - onChanged(); - } - - // optional bytes value = 2; - private com.google.protobuf.ByteString value_ = com.google.protobuf.ByteString.EMPTY; - public boolean hasValue() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public com.google.protobuf.ByteString getValue() { - return value_; - } - public Builder setValue(com.google.protobuf.ByteString value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000002; - value_ = value; - onChanged(); - return this; - } - public Builder clearValue() { - bitField0_ = (bitField0_ & ~0x00000002); - value_ = getDefaultInstance().getValue(); - onChanged(); - return this; - } - - // @@protoc_insertion_point(builder_scope:Hedwig.Map.Entry) - } - - static { - defaultInstance = new Entry(true); - defaultInstance.initFields(); - } - - // @@protoc_insertion_point(class_scope:Hedwig.Map.Entry) - } - - // repeated .Hedwig.Map.Entry entries = 1; - public static final int ENTRIES_FIELD_NUMBER = 1; - private java.util.List<org.apache.hedwig.protocol.PubSubProtocol.Map.Entry> entries_; - public java.util.List<org.apache.hedwig.protocol.PubSubProtocol.Map.Entry> getEntriesList() { - return entries_; - } - public java.util.List<? extends org.apache.hedwig.protocol.PubSubProtocol.Map.EntryOrBuilder> - getEntriesOrBuilderList() { - return entries_; - } - public int getEntriesCount() { - return entries_.size(); - } - public org.apache.hedwig.protocol.PubSubProtocol.Map.Entry getEntries(int index) { - return entries_.get(index); - } - public org.apache.hedwig.protocol.PubSubProtocol.Map.EntryOrBuilder getEntriesOrBuilder( - int index) { - return entries_.get(index); - } - - private void initFields() { - entries_ = java.util.Collections.emptyList(); - } - private byte memoizedIsInitialized = -1; - public final boolean isInitialized() { - byte isInitialized = memoizedIsInitialized; - if (isInitialized != -1) return isInitialized == 1; - - memoizedIsInitialized = 1; - return true; - } - - public void writeTo(com.google.protobuf.CodedOutputStream output) - throws java.io.IOException { - getSerializedSize(); - for (int i = 0; i < entries_.size(); i++) { - output.writeMessage(1, entries_.get(i)); - } - getUnknownFields().writeTo(output); - } - - private int memoizedSerializedSize = -1; - public int getSerializedSize() { - int size = memoizedSerializedSize; - if (size != -1) return size; - - size = 0; - for (int i = 0; i < entries_.size(); i++) { - size += com.google.protobuf.CodedOutputStream - .computeMessageSize(1, entries_.get(i)); - } - size += getUnknownFields().getSerializedSize(); - memoizedSerializedSize = size; - return size; - } - - private static final long serialVersionUID = 0L; - @java.lang.Override - protected java.lang.Object writeReplace() - throws java.io.ObjectStreamException { - return super.writeReplace(); - } - - public static org.apache.hedwig.protocol.PubSubProtocol.Map parseFrom( - com.google.protobuf.ByteString data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.Map parseFrom( - com.google.protobuf.ByteString data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.Map parseFrom(byte[] data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.Map parseFrom( - byte[] data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.Map parseFrom(java.io.InputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.Map parseFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return newBuilder().mergeFrom(input, extensionRegistry) - .buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.Map parseDelimitedFrom(java.io.InputStream input) - throws java.io.IOException { - Builder builder = newBuilder(); - if (builder.mergeDelimitedFrom(input)) { - return builder.buildParsed(); - } else { - return null; - } - } - public static org.apache.hedwig.protocol.PubSubProtocol.Map parseDelimitedFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - Builder builder = newBuilder(); - if (builder.mergeDelimitedFrom(input, extensionRegistry)) { - return builder.buildParsed(); - } else { - return null; - } - } - public static org.apache.hedwig.protocol.PubSubProtocol.Map parseFrom( - com.google.protobuf.CodedInputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.Map parseFrom( - com.google.protobuf.CodedInputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return newBuilder().mergeFrom(input, extensionRegistry) - .buildParsed(); - } - - public static Builder newBuilder() { return Builder.create(); } - public Builder newBuilderForType() { return newBuilder(); } - public static Builder newBuilder(org.apache.hedwig.protocol.PubSubProtocol.Map prototype) { - return newBuilder().mergeFrom(prototype); - } - public Builder toBuilder() { return newBuilder(this); } - - @java.lang.Override - protected Builder newBuilderForType( - com.google.protobuf.GeneratedMessage.BuilderParent parent) { - Builder builder = new Builder(parent); - return builder; - } - public static final class Builder extends - com.google.protobuf.GeneratedMessage.Builder<Builder> - implements org.apache.hedwig.protocol.PubSubProtocol.MapOrBuilder { - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return org.apache.hedwig.protocol.PubSubProtocol.internal_static_Hedwig_Map_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return org.apache.hedwig.protocol.PubSubProtocol.internal_static_Hedwig_Map_fieldAccessorTable; - } - - // Construct using org.apache.hedwig.protocol.PubSubProtocol.Map.newBuilder() - private Builder() { - maybeForceBuilderInitialization(); - } - - private Builder(BuilderParent parent) { - super(parent); - maybeForceBuilderInitialization(); - } - private void maybeForceBuilderInitialization() { - if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { - getEntriesFieldBuilder(); - } - } - private static Builder create() { - return new Builder(); - } - - public Builder clear() { - super.clear(); - if (entriesBuilder_ == null) { - entries_ = java.util.Collections.emptyList(); - bitField0_ = (bitField0_ & ~0x00000001); - } else { - entriesBuilder_.clear(); - } - return this; - } - - public Builder clone() { - return create().mergeFrom(buildPartial()); - } - - public com.google.protobuf.Descriptors.Descriptor - getDescriptorForType() { - return org.apache.hedwig.protocol.PubSubProtocol.Map.getDescriptor(); - } - - public org.apache.hedwig.protocol.PubSubProtocol.Map getDefaultInstanceForType() { - return org.apache.hedwig.protocol.PubSubProtocol.Map.getDefaultInstance(); - } - - public org.apache.hedwig.protocol.PubSubProtocol.Map build() { - org.apache.hedwig.protocol.PubSubProtocol.Map result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException(result); - } - return result; - } - - private org.apache.hedwig.protocol.PubSubProtocol.Map buildParsed() - throws com.google.protobuf.InvalidProtocolBufferException { - org.apache.hedwig.protocol.PubSubProtocol.Map result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException( - result).asInvalidProtocolBufferException(); - } - return result; - } - - public org.apache.hedwig.protocol.PubSubProtocol.Map buildPartial() { - org.apache.hedwig.protocol.PubSubProtocol.Map result = new org.apache.hedwig.protocol.PubSubProtocol.Map(this); - int from_bitField0_ = bitField0_; - if (entriesBuilder_ == null) { - if (((bitField0_ & 0x00000001) == 0x00000001)) { - entries_ = java.util.Collections.unmodifiableList(entries_); - bitField0_ = (bitField0_ & ~0x00000001); - } - result.entries_ = entries_; - } else { - result.entries_ = entriesBuilder_.build(); - } - onBuilt(); - return result; - } - - public Builder mergeFrom(com.google.protobuf.Message other) { - if (other instanceof org.apache.hedwig.protocol.PubSubProtocol.Map) { - return mergeFrom((org.apache.hedwig.protocol.PubSubProtocol.Map)other); - } else { - super.mergeFrom(other); - return this; - } - } - - public Builder mergeFrom(org.apache.hedwig.protocol.PubSubProtocol.Map other) { - if (other == org.apache.hedwig.protocol.PubSubProtocol.Map.getDefaultInstance()) return this; - if (entriesBuilder_ == null) { - if (!other.entries_.isEmpty()) { - if (entries_.isEmpty()) { - entries_ = other.entries_; - bitField0_ = (bitField0_ & ~0x00000001); - } else { - ensureEntriesIsMutable(); - entries_.addAll(other.entries_); - } - onChanged(); - } - } else { - if (!other.entries_.isEmpty()) { - if (entriesBuilder_.isEmpty()) { - entriesBuilder_.dispose(); - entriesBuilder_ = null; - entries_ = other.entries_; - bitField0_ = (bitField0_ & ~0x00000001); - entriesBuilder_ = - com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders ? - getEntriesFieldBuilder() : null; - } else { - entriesBuilder_.addAllMessages(other.entries_); - } - } - } - this.mergeUnknownFields(other.getUnknownFields()); - return this; - } - - public final boolean isInitialized() { - return true; - } - - public Builder mergeFrom( - com.google.protobuf.CodedInputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - com.google.protobuf.UnknownFieldSet.Builder unknownFields = - com.google.protobuf.UnknownFieldSet.newBuilder( - this.getUnknownFields()); - while (true) { - int tag = input.readTag(); - switch (tag) { - case 0: - this.setUnknownFields(unknownFields.build()); - onChanged(); - return this; - default: { - if (!parseUnknownField(input, unknownFields, - extensionRegistry, tag)) { - this.setUnknownFields(unknownFields.build()); - onChanged(); - return this; - } - break; - } - case 10: { - org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder subBuilder = org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.newBuilder(); - input.readMessage(subBuilder, extensionRegistry); - addEntries(subBuilder.buildPartial()); - break; - } - } - } - } - - private int bitField0_; - - // repeated .Hedwig.Map.Entry entries = 1; - private java.util.List<org.apache.hedwig.protocol.PubSubProtocol.Map.Entry> entries_ = - java.util.Collections.emptyList(); - private void ensureEntriesIsMutable() { - if (!((bitField0_ & 0x00000001) == 0x00000001)) { - entries_ = new java.util.ArrayList<org.apache.hedwig.protocol.PubSubProtocol.Map.Entry>(entries_); - bitField0_ |= 0x00000001; - } - } - - private com.google.protobuf.RepeatedFieldBuilder< - org.apache.hedwig.protocol.PubSubProtocol.Map.Entry, org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder, org.apache.hedwig.protocol.PubSubProtocol.Map.EntryOrBuilder> entriesBuilder_; - - public java.util.List<org.apache.hedwig.protocol.PubSubProtocol.Map.Entry> getEntriesList() { - if (entriesBuilder_ == null) { - return java.util.Collections.unmodifiableList(entries_); - } else { - return entriesBuilder_.getMessageList(); - } - } - public int getEntriesCount() { - if (entriesBuilder_ == null) { - return entries_.size(); - } else { - return entriesBuilder_.getCount(); - } - } - public org.apache.hedwig.protocol.PubSubProtocol.Map.Entry getEntries(int index) { - if (entriesBuilder_ == null) { - return entries_.get(index); - } else { - return entriesBuilder_.getMessage(index); - } - } - public Builder setEntries( - int index, org.apache.hedwig.protocol.PubSubProtocol.Map.Entry value) { - if (entriesBuilder_ == null) { - if (value == null) { - throw new NullPointerException(); - } - ensureEntriesIsMutable(); - entries_.set(index, value); - onChanged(); - } else { - entriesBuilder_.setMessage(index, value); - } - return this; - } - public Builder setEntries( - int index, org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder builderForValue) { - if (entriesBuilder_ == null) { - ensureEntriesIsMutable(); - entries_.set(index, builderForValue.build()); - onChanged(); - } else { - entriesBuilder_.setMessage(index, builderForValue.build()); - } - return this; - } - public Builder addEntries(org.apache.hedwig.protocol.PubSubProtocol.Map.Entry value) { - if (entriesBuilder_ == null) { - if (value == null) { - throw new NullPointerException(); - } - ensureEntriesIsMutable(); - entries_.add(value); - onChanged(); - } else { - entriesBuilder_.addMessage(value); - } - return this; - } - public Builder addEntries( - int index, org.apache.hedwig.protocol.PubSubProtocol.Map.Entry value) { - if (entriesBuilder_ == null) { - if (value == null) { - throw new NullPointerException(); - } - ensureEntriesIsMutable(); - entries_.add(index, value); - onChanged(); - } else { - entriesBuilder_.addMessage(index, value); - } - return this; - } - public Builder addEntries( - org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder builderForValue) { - if (entriesBuilder_ == null) { - ensureEntriesIsMutable(); - entries_.add(builderForValue.build()); - onChanged(); - } else { - entriesBuilder_.addMessage(builderForValue.build()); - } - return this; - } - public Builder addEntries( - int index, org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder builderForValue) { - if (entriesBuilder_ == null) { - ensureEntriesIsMutable(); - entries_.add(index, builderForValue.build()); - onChanged(); - } else { - entriesBuilder_.addMessage(index, builderForValue.build()); - } - return this; - } - public Builder addAllEntries( - java.lang.Iterable<? extends org.apache.hedwig.protocol.PubSubProtocol.Map.Entry> values) { - if (entriesBuilder_ == null) { - ensureEntriesIsMutable(); - super.addAll(values, entries_); - onChanged(); - } else { - entriesBuilder_.addAllMessages(values); - } - return this; - } - public Builder clearEntries() { - if (entriesBuilder_ == null) { - entries_ = java.util.Collections.emptyList(); - bitField0_ = (bitField0_ & ~0x00000001); - onChanged(); - } else { - entriesBuilder_.clear(); - } - return this; - } - public Builder removeEntries(int index) { - if (entriesBuilder_ == null) { - ensureEntriesIsMutable(); - entries_.remove(index); - onChanged(); - } else { - entriesBuilder_.remove(index); - } - return this; - } - public org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder getEntriesBuilder( - int index) { - return getEntriesFieldBuilder().getBuilder(index); - } - public org.apache.hedwig.protocol.PubSubProtocol.Map.EntryOrBuilder getEntriesOrBuilder( - int index) { - if (entriesBuilder_ == null) { - return entries_.get(index); } else { - return entriesBuilder_.getMessageOrBuilder(index); - } - } - public java.util.List<? extends org.apache.hedwig.protocol.PubSubProtocol.Map.EntryOrBuilder> - getEntriesOrBuilderList() { - if (entriesBuilder_ != null) { - return entriesBuilder_.getMessageOrBuilderList(); - } else { - return java.util.Collections.unmodifiableList(entries_); - } - } - public org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder addEntriesBuilder() { - return getEntriesFieldBuilder().addBuilder( - org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.getDefaultInstance()); - } - public org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder addEntriesBuilder( - int index) { - return getEntriesFieldBuilder().addBuilder( - index, org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.getDefaultInstance()); - } - public java.util.List<org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder> - getEntriesBuilderList() { - return getEntriesFieldBuilder().getBuilderList(); - } - private com.google.protobuf.RepeatedFieldBuilder< - org.apache.hedwig.protocol.PubSubProtocol.Map.Entry, org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder, org.apache.hedwig.protocol.PubSubProtocol.Map.EntryOrBuilder> - getEntriesFieldBuilder() { - if (entriesBuilder_ == null) { - entriesBuilder_ = new com.google.protobuf.RepeatedFieldBuilder< - org.apache.hedwig.protocol.PubSubProtocol.Map.Entry, org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder, org.apache.hedwig.protocol.PubSubProtocol.Map.EntryOrBuilder>( - entries_, - ((bitField0_ & 0x00000001) == 0x00000001), - getParentForChildren(), - isClean()); - entries_ = null; - } - return entriesBuilder_; - } - - // @@protoc_insertion_point(builder_scope:Hedwig.Map) - } - - static { - defaultInstance = new Map(true); - defaultInstance.initFields(); - } - - // @@protoc_insertion_point(class_scope:Hedwig.Map) - } - - public interface MessageHeaderOrBuilder - extends com.google.protobuf.MessageOrBuilder { - - // optional .Hedwig.Map properties = 1; - boolean hasProperties(); - org.apache.hedwig.protocol.PubSubProtocol.Map getProperties(); - org.apache.hedwig.protocol.PubSubProtocol.MapOrBuilder getPropertiesOrBuilder(); - - // optional string messageType = 2; - boolean hasMessageType(); - String getMessageType(); - } - public static final class MessageHeader extends - com.google.protobuf.GeneratedMessage - implements MessageHeaderOrBuilder { - // Use MessageHeader.newBuilder() to construct. - private MessageHeader(Builder builder) { - super(builder); - } - private MessageHeader(boolean noInit) {} - - private static final MessageHeader defaultInstance; - public static MessageHeader getDefaultInstance() { - return defaultInstance; - } - - public MessageHeader getDefaultInstanceForType() { - return defaultInstance; - } - - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return org.apache.hedwig.protocol.PubSubProtocol.internal_static_Hedwig_MessageHeader_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return org.apache.hedwig.protocol.PubSubProtocol.internal_static_Hedwig_MessageHeader_fieldAccessorTable; - } - - private int bitField0_; - // optional .Hedwig.Map properties = 1; - public static final int PROPERTIES_FIELD_NUMBER = 1; - private org.apache.hedwig.protocol.PubSubProtocol.Map properties_; - public boolean hasProperties() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public org.apache.hedwig.protocol.PubSubProtocol.Map getProperties() { - return properties_; - } - public org.apache.hedwig.protocol.PubSubProtocol.MapOrBuilder getPropertiesOrBuilder() { - return properties_; - } - - // optional string messageType = 2; - public static final int MESSAGETYPE_FIELD_NUMBER = 2; - private java.lang.Object messageType_; - public boolean hasMessageType() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public String getMessageType() { - java.lang.Object ref = messageType_; - if (ref instanceof String) { - return (String) ref; - } else { - com.google.protobuf.ByteString bs = - (com.google.protobuf.ByteString) ref; - String s = bs.toStringUtf8(); - if (com.google.protobuf.Internal.isValidUtf8(bs)) { - messageType_ = s; - } - return s; - } - } - private com.google.protobuf.ByteString getMessageTypeBytes() { - java.lang.Object ref = messageType_; - if (ref instanceof String) { - com.google.protobuf.ByteString b = - com.google.protobuf.ByteString.copyFromUtf8((String) ref); - messageType_ = b; - return b; - } else { - return (com.google.protobuf.ByteString) ref; - } - } - - private void initFields() { - properties_ = org.apache.hedwig.protocol.PubSubProtocol.Map.getDefaultInstance(); - messageType_ = ""; - } - private byte memoizedIsInitialized = -1; - public final boolean isInitialized() { - byte isInitialized = memoizedIsInitialized; - if (isInitialized != -1) return isInitialized == 1; - - memoizedIsInitialized = 1; - return true; - } - - public void writeTo(com.google.protobuf.CodedOutputStream output) - throws java.io.IOException { - getSerializedSize(); - if (((bitField0_ & 0x00000001) == 0x00000001)) { - output.writeMessage(1, properties_); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - output.writeBytes(2, getMessageTypeBytes()); - } - getUnknownFields().writeTo(output); - } - - private int memoizedSerializedSize = -1; - public int getSerializedSize() { - int size = memoizedSerializedSize; - if (size != -1) return size; - - size = 0; - if (((bitField0_ & 0x00000001) == 0x00000001)) { - size += com.google.protobuf.CodedOutputStream - .computeMessageSize(1, properties_); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - size += com.google.protobuf.CodedOutputStream - .computeBytesSize(2, getMessageTypeBytes()); - } - size += getUnknownFields().getSerializedSize(); - memoizedSerializedSize = size; - return size; - } - - private static final long serialVersionUID = 0L; - @java.lang.Override - protected java.lang.Object writeReplace() - throws java.io.ObjectStreamException { - return super.writeReplace(); - } - - public static org.apache.hedwig.protocol.PubSubProtocol.MessageHeader parseFrom( - com.google.protobuf.ByteString data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.MessageHeader parseFrom( - com.google.protobuf.ByteString data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.MessageHeader parseFrom(byte[] data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.MessageHeader parseFrom( - byte[] data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.MessageHeader parseFrom(java.io.InputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.MessageHeader parseFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return newBuilder().mergeFrom(input, extensionRegistry) - .buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.MessageHeader parseDelimitedFrom(java.io.InputStream input) - throws java.io.IOException { - Builder builder = newBuilder(); - if (builder.mergeDelimitedFrom(input)) { - return builder.buildParsed(); - } else { - return null; - } - } - public static org.apache.hedwig.protocol.PubSubProtocol.MessageHeader parseDelimitedFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - Builder builder = newBuilder(); - if (builder.mergeDelimitedFrom(input, extensionRegistry)) { - return builder.buildParsed(); - } else { - return null; - } - } - public static org.apache.hedwig.protocol.PubSubProtocol.MessageHeader parseFrom( - com.google.protobuf.CodedInputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.MessageHeader parseFrom( - com.google.protobuf.CodedInputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return newBuilder().mergeFrom(input, extensionRegistry) - .buildParsed(); - } - - public static Builder newBuilder() { return Builder.create(); } - public Builder newBuilderForType() { return newBuilder(); } - public static Builder newBuilder(org.apache.hedwig.protocol.PubSubProtocol.MessageHeader prototype) { - return newBuilder().mergeFrom(prototype); - } - public Builder toBuilder() { return newBuilder(this); } - - @java.lang.Override - protected Builder newBuilderForType( - com.google.protobuf.GeneratedMessage.BuilderParent parent) { - Builder builder = new Builder(parent); - return builder; - } - public static final class Builder extends - com.google.protobuf.GeneratedMessage.Builder<Builder> - implements org.apache.hedwig.protocol.PubSubProtocol.MessageHeaderOrBuilder { - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return org.apache.hedwig.protocol.PubSubProtocol.internal_static_Hedwig_MessageHeader_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return org.apache.hedwig.protocol.PubSubProtocol.internal_static_Hedwig_MessageHeader_fieldAccessorTable; - } - - // Construct using org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.newBuilder() - private Builder() { - maybeForceBuilderInitialization(); - } - - private Builder(BuilderParent parent) { - super(parent); - maybeForceBuilderInitialization(); - } - private void maybeForceBuilderInitialization() { - if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { - getPropertiesFieldBuilder(); - } - } - private static Builder create() { - return new Builder(); - } - - public Builder clear() { - super.clear(); - if (propertiesBuilder_ == null) { - properties_ = org.apache.hedwig.protocol.PubSubProtocol.Map.getDefaultInstance(); - } else { - propertiesBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000001); - messageType_ = ""; - bitField0_ = (bitField0_ & ~0x00000002); - return this; - } - - public Builder clone() { - return create().mergeFrom(buildPartial()); - } - - public com.google.protobuf.Descriptors.Descriptor - getDescriptorForType() { - return org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.getDescriptor(); - } - - public org.apache.hedwig.protocol.PubSubProtocol.MessageHeader getDefaultInstanceForType() { - return org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.getDefaultInstance(); - } - - public org.apache.hedwig.protocol.PubSubProtocol.MessageHeader build() { - org.apache.hedwig.protocol.PubSubProtocol.MessageHeader result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException(result); - } - return result; - } - - private org.apache.hedwig.protocol.PubSubProtocol.MessageHeader buildParsed() - throws com.google.protobuf.InvalidProtocolBufferException { - org.apache.hedwig.protocol.PubSubProtocol.MessageHeader result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException( - result).asInvalidProtocolBufferException(); - } - return result; - } - - public org.apache.hedwig.protocol.PubSubProtocol.MessageHeader buildPartial() { - org.apache.hedwig.protocol.PubSubProtocol.MessageHeader result = new org.apache.hedwig.protocol.PubSubProtocol.MessageHeader(this); - int from_bitField0_ = bitField0_; - int to_bitField0_ = 0; - if (((from_bitField0_ & 0x00000001) == 0x00000001)) { - to_bitField0_ |= 0x00000001; - } - if (propertiesBuilder_ == null) { - result.properties_ = properties_; - } else { - result.properties_ = propertiesBuilder_.build(); - } - if (((from_bitField0_ & 0x00000002) == 0x00000002)) { - to_bitField0_ |= 0x00000002; - } - result.messageType_ = messageType_; - result.bitField0_ = to_bitField0_; - onBuilt(); - return result; - } - - public Builder mergeFrom(com.google.protobuf.Message other) { - if (other instanceof org.apache.hedwig.protocol.PubSubProtocol.MessageHeader) { - return mergeFrom((org.apache.hedwig.protocol.PubSubProtocol.MessageHeader)other); - } else { - super.mergeFrom(other); - return this; - } - } - - public Builder mergeFrom(org.apache.hedwig.protocol.PubSubProtocol.MessageHeader other) { - if (other == org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.getDefaultInstance()) return this; - if (other.hasProperties()) { - mergeProperties(other.getProperties()); - } - if (other.hasMessageType()) { - setMessageType(other.getMessageType()); - } - this.mergeUnknownFields(other.getUnknownFields()); - return this; - } - - public final boolean isInitialized() { - return true; - } - - public Builder mergeFrom( - com.google.protobuf.CodedInputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - com.google.protobuf.UnknownFieldSet.Builder unknownFields = - com.google.protobuf.UnknownFieldSet.newBuilder( - this.getUnknownFields()); - while (true) { - int tag = input.readTag(); - switch (tag) { - case 0: - this.setUnknownFields(unknownFields.build()); - onChanged(); - return this; - default: { - if (!parseUnknownField(input, unknownFields, - extensionRegistry, tag)) { - this.setUnknownFields(unknownFields.build()); - onChanged(); - return this; - } - break; - } - case 10: { - org.apache.hedwig.protocol.PubSubProtocol.Map.Builder subBuilder = org.apache.hedwig.protocol.PubSubProtocol.Map.newBuilder(); - if (hasProperties()) { - subBuilder.mergeFrom(getProperties()); - } - input.readMessage(subBuilder, extensionRegistry); - setProperties(subBuilder.buildPartial()); - break; - } - case 18: { - bitField0_ |= 0x00000002; - messageType_ = input.readBytes(); - break; - } - } - } - } - - private int bitField0_; - - // optional .Hedwig.Map properties = 1; - private org.apache.hedwig.protocol.PubSubProtocol.Map properties_ = org.apache.hedwig.protocol.PubSubProtocol.Map.getDefaultInstance(); - private com.google.protobuf.SingleFieldBuilder< - org.apache.hedwig.protocol.PubSubProtocol.Map, org.apache.hedwig.protocol.PubSubProtocol.Map.Builder, org.apache.hedwig.protocol.PubSubProtocol.MapOrBuilder> propertiesBuilder_; - public boolean hasProperties() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public org.apache.hedwig.protocol.PubSubProtocol.Map getProperties() { - if (propertiesBuilder_ == null) { - return properties_; - } else { - return propertiesBuilder_.getMessage(); - } - } - public Builder setProperties(org.apache.hedwig.protocol.PubSubProtocol.Map value) { - if (propertiesBuilder_ == null) { - if (value == null) { - throw new NullPointerException(); - } - properties_ = value; - onChanged(); - } else { - propertiesBuilder_.setMessage(value); - } - bitField0_ |= 0x00000001; - return this; - } - public Builder setProperties( - org.apache.hedwig.protocol.PubSubProtocol.Map.Builder builderForValue) { - if (propertiesBuilder_ == null) { - properties_ = builderForValue.build(); - onChanged(); - } else { - propertiesBuilder_.setMessage(builderForValue.build()); - } - bitField0_ |= 0x00000001; - return this; - } - public Builder mergeProperties(org.apache.hedwig.protocol.PubSubProtocol.Map value) { - if (propertiesBuilder_ == null) { - if (((bitField0_ & 0x00000001) == 0x00000001) && - properties_ != org.apache.hedwig.protocol.PubSubProtocol.Map.getDefaultInstance()) { - properties_ = - org.apache.hedwig.protocol.PubSubProtocol.Map.newBuilder(properties_).mergeFrom(value).buildPartial(); - } else { - properties_ = value; - } - onChanged(); - } else { - propertiesBuilder_.mergeFrom(value); - } - bitField0_ |= 0x00000001; - return this; - } - public Builder clearProperties() { - if (propertiesBuilder_ == null) { - properties_ = org.apache.hedwig.protocol.PubSubProtocol.Map.getDefaultInstance(); - onChanged(); - } else { - propertiesBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000001); - return this; - } - public org.apache.hedwig.protocol.PubSubProtocol.Map.Builder getPropertiesBuilder() { - bitField0_ |= 0x00000001; - onChanged(); - return getPropertiesFieldBuilder().getBuilder(); - } - public org.apache.hedwig.protocol.PubSubProtocol.MapOrBuilder getPropertiesOrBuilder() { - if (propertiesBuilder_ != null) { - return propertiesBuilder_.getMessageOrBuilder(); - } else { - return properties_; - } - } - private com.google.protobuf.SingleFieldBuilder< - org.apache.hedwig.protocol.PubSubProtocol.Map, org.apache.hedwig.protocol.PubSubProtocol.Map.Builder, org.apache.hedwig.protocol.PubSubProtocol.MapOrBuilder> - getPropertiesFieldBuilder() { - if (propertiesBuilder_ == null) { - propertiesBuilder_ = new com.google.protobuf.SingleFieldBuilder< - org.apache.hedwig.protocol.PubSubProtocol.Map, org.apache.hedwig.protocol.PubSubProtocol.Map.Builder, org.apache.hedwig.protocol.PubSubProtocol.MapOrBuilder>( - properties_, - getParentForChildren(), - isClean()); - properties_ = null; - } - return propertiesBuilder_; - } - - // optional string messageType = 2; - private java.lang.Object messageType_ = ""; - public boolean hasMessageType() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public String getMessageType() { - java.lang.Object ref = messageType_; - if (!(ref instanceof String)) { - String s = ((com.google.protobuf.ByteString) ref).toStringUtf8(); - messageType_ = s; - return s; - } else { - return (String) ref; - } - } - public Builder setMessageType(String value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000002; - messageType_ = value; - onChanged(); - return this; - } - public Builder clearMessageType() { - bitField0_ = (bitField0_ & ~0x00000002); - messageType_ = getDefaultInstance().getMessageType(); - onChanged(); - return this; - } - void setMessageType(com.google.protobuf.ByteString value) { - bitField0_ |= 0x00000002; - messageType_ = value; - onChanged(); - } - - // @@protoc_insertion_point(builder_scope:Hedwig.MessageHeader) - } - - static { - defaultInstance = new MessageHeader(true); - defaultInstance.initFields(); - } - - // @@protoc_insertion_point(class_scope:Hedwig.MessageHeader) - } - - public interface MessageOrBuilder - extends com.google.protobuf.MessageOrBuilder { - - // required bytes body = 1; - boolean hasBody(); - com.google.protobuf.ByteString getBody(); - - // optional bytes srcRegion = 2; - boolean hasSrcRegion(); - com.google.protobuf.ByteString getSrcRegion(); - - // optional .Hedwig.MessageSeqId msgId = 3; - boolean hasMsgId(); - org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId getMsgId(); - org.apache.hedwig.protocol.PubSubProtocol.MessageSeqIdOrBuilder getMsgIdOrBuilder(); - - // optional .Hedwig.MessageHeader header = 4; - boolean hasHeader(); - org.apache.hedwig.protocol.PubSubProtocol.MessageHeader getHeader(); - org.apache.hedwig.protocol.PubSubProtocol.MessageHeaderOrBuilder getHeaderOrBuilder(); - } - public static final class Message extends - com.google.protobuf.GeneratedMessage - implements MessageOrBuilder { - // Use Message.newBuilder() to construct. - private Message(Builder builder) { - super(builder); - } - private Message(boolean noInit) {} - - private static final Message defaultInstance; - public static Message getDefaultInstance() { - return defaultInstance; - } - - public Message getDefaultInstanceForType() { - return defaultInstance; - } - - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return org.apache.hedwig.protocol.PubSubProtocol.internal_static_Hedwig_Message_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return org.apache.hedwig.protocol.PubSubProtocol.internal_static_Hedwig_Message_fieldAccessorTable; - } - - private int bitField0_; - // required bytes body = 1; - public static final int BODY_FIELD_NUMBER = 1; - private com.google.protobuf.ByteString body_; - public boolean hasBody() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public com.google.protobuf.ByteString getBody() { - return body_; - } - - // optional bytes srcRegion = 2; - public static final int SRCREGION_FIELD_NUMBER = 2; - private com.google.protobuf.ByteString srcRegion_; - public boolean hasSrcRegion() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public com.google.protobuf.ByteString getSrcRegion() { - return srcRegion_; - } - - // optional .Hedwig.MessageSeqId msgId = 3; - public static final int MSGID_FIELD_NUMBER = 3; - private org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId msgId_; - public boolean hasMsgId() { - return ((bitField0_ & 0x00000004) == 0x00000004); - } - public org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId getMsgId() { - return msgId_; - } - public org.apache.hedwig.protocol.PubSubProtocol.MessageSeqIdOrBuilder getMsgIdOrBuilder() { - return msgId_; - } - - // optional .Hedwig.MessageHeader header = 4; - public static final int HEADER_FIELD_NUMBER = 4; - private org.apache.hedwig.protocol.PubSubProtocol.MessageHeader header_; - public boolean hasHeader() { - return ((bitField0_ & 0x00000008) == 0x00000008); - } - public org.apache.hedwig.protocol.PubSubProtocol.MessageHeader getHeader() { - return header_; - } - public org.apache.hedwig.protocol.PubSubProtocol.MessageHeaderOrBuilder getHeaderOrBuilder() { - return header_; - } - - private void initFields() { - body_ = com.google.protobuf.ByteString.EMPTY; - srcRegion_ = com.google.protobuf.ByteString.EMPTY; - msgId_ = org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.getDefaultInstance(); - header_ = org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.getDefaultInstance(); - } - private byte memoizedIsInitialized = -1; - public final boolean isInitialized() { - byte isInitialized = memoizedIsInitialized; - if (isInitialized != -1) return isInitialized == 1; - - if (!hasBody()) { - memoizedIsInitialized = 0; - return false; - } - if (hasMsgId()) { - if (!getMsgId().isInitialized()) { - memoizedIsInitialized = 0; - return false; - } - } - memoizedIsInitialized = 1; - return true; - } - - public void writeTo(com.google.protobuf.CodedOutputStream output) - throws java.io.IOException { - getSerializedSize(); - if (((bitField0_ & 0x00000001) == 0x00000001)) { - output.writeBytes(1, body_); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - output.writeBytes(2, srcRegion_); - } - if (((bitField0_ & 0x00000004) == 0x00000004)) { - output.writeMessage(3, msgId_); - } - if (((bitField0_ & 0x00000008) == 0x00000008)) { - output.writeMessage(4, header_); - } - getUnknownFields().writeTo(output); - } - - private int memoizedSerializedSize = -1; - public int getSerializedSize() { - int size = memoizedSerializedSize; - if (size != -1) return size; - - size = 0; - if (((bitField0_ & 0x00000001) == 0x00000001)) { - size += com.google.protobuf.CodedOutputStream - .computeBytesSize(1, body_); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - size += com.google.protobuf.CodedOutputStream - .computeBytesSize(2, srcRegion_); - } - if (((bitField0_ & 0x00000004) == 0x00000004)) { - size += com.google.protobuf.CodedOutputStream - .computeMessageSize(3, msgId_); - } - if (((bitField0_ & 0x00000008) == 0x00000008)) { - size += com.google.protobuf.CodedOutputStream - .computeMessageSize(4, header_); - } - size += getUnknownFields().getSerializedSize(); - memoizedSerializedSize = size; - return size; - } - - private static final long serialVersionUID = 0L; - @java.lang.Override - protected java.lang.Object writeReplace() - throws java.io.ObjectStreamException { - return super.writeReplace(); - } - - public static org.apache.hedwig.protocol.PubSubProtocol.Message parseFrom( - com.google.protobuf.ByteString data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.Message parseFrom( - com.google.protobuf.ByteString data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.Message parseFrom(byte[] data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.Message parseFrom( - byte[] data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.Message parseFrom(java.io.InputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.Message parseFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return newBuilder().mergeFrom(input, extensionRegistry) - .buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.Message parseDelimitedFrom(java.io.InputStream input) - throws java.io.IOException { - Builder builder = newBuilder(); - if (builder.mergeDelimitedFrom(input)) { - return builder.buildParsed(); - } else { - return null; - } - } - public static org.apache.hedwig.protocol.PubSubProtocol.Message parseDelimitedFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - Builder builder = newBuilder(); - if (builder.mergeDelimitedFrom(input, extensionRegistry)) { - return builder.buildParsed(); - } else { - return null; - } - } - public static org.apache.hedwig.protocol.PubSubProtocol.Message parseFrom( - com.google.protobuf.CodedInputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static org.apache.hedwig.protocol.PubSubProtocol.Message parseFrom( - com.google.protobuf.CodedInputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return newBuilder().mergeFrom(input, extensionRegistry) - .buildParsed(); - } - - public static Builder newBuilder() { return Builder.create(); } - public Builder newBuilderForType() { return newBuilder(); } - public static Builder newBuilder(org.apache.hedwig.protocol.PubSubProtocol.Message prototype) { - return newBuilder().mergeFrom(prototype); - } - public Builder toBuilder() { return newBuilder(this); } - - @java.lang.Override - protected Builder newBuilderForType( - com.google.protobuf.GeneratedMessage.BuilderParent parent) { - Builder builder = new Builder(parent); - return builder; - } - public static final class Builder extends - com.google.protobuf.GeneratedMessage.Builder<Builder> - implements org.apache.hedwig.protocol.PubSubProtocol.MessageOrBuilder { - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return org.apache.hedwig.protocol.PubSubProtocol.internal_static_Hedwig_Message_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return org.apache.hedwig.protocol.PubSubProtocol.internal_static_Hedwig_Message_fieldAccessorTable; - } - - // Construct using org.apache.hedwig.protocol.PubSubProtocol.Message.newBuilder() - private Builder() { - maybeForceBuilderInitialization(); - } - - private Builder(BuilderParent parent) { - super(parent); - maybeForceBuilderInitialization(); - } - private void maybeForceBuilderInitialization() { - if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { - getMsgIdFieldBuilder(); - getHeaderFieldBuilder(); - } - } - private static Builder create() { - return new Builder(); - } - - public Builder clear() { - super.clear(); - body_ = com.google.protobuf.ByteString.EMPTY; - bitField0_ = (bitField0_ & ~0x00000001); - srcRegion_ = com.google.protobuf.ByteString.EMPTY; - bitField0_ = (bitField0_ & ~0x00000002); - if (msgIdBuilder_ == null) { - msgId_ = org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.getDefaultInstance(); - } else { - msgIdBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000004); - if (headerBuilder_ == null) { - header_ = org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.getDefaultInstance(); - } else { - headerBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000008); - return this; - } - - public Builder clone() { - return create().mergeFrom(buildPartial()); - } - - public com.google.protobuf.Descriptors.Descriptor - getDescriptorForType() { - return org.apache.hedwig.protocol.PubSubProtocol.Message.getDescriptor(); - } - - public org.apache.hedwig.protocol.PubSubProtocol.Message getDefaultInstanceForType() { - return org.apache.hedwig.protocol.PubSubProtocol.Message.getDefaultInstance(); - } - - public org.apache.hedwig.protocol.PubSubProtocol.Message build() { - org.apache.hedwig.protocol.PubSubProtocol.Message result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException(result); - } - return result; - } - - private org.apache.hedwig.protocol.PubSubProtocol.Message buildParsed() - throws com.google.protobuf.InvalidProtocolBufferException { - org.apache.hedwig.protocol.PubSubProtocol.Message result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException( - result).asInvalidProtocolBufferException(); - } - return result; - } - - public org.apache.hedwig.protocol.PubSubProtocol.Message buildPartial() { - org.apache.hedwig.protocol.PubSubProtocol.Message result = new org.apache.hedwig.protocol.PubSubProtocol.Message(this); - int from_bitField0_ = bitField0_; - int to_bitField0_ = 0; - if (((from_bitField0_ & 0x00000001) == 0x00000001)) { - to_bitField0_ |= 0x00000001; - } - result.body_ = body_; - if (((from_bitField0_ & 0x00000002) == 0x00000002)) { - to_bitField0_ |= 0x00000002; - } - result.srcRegion_ = srcRegion_; - if (((from_bitField0_ & 0x00000004) == 0x00000004)) { - to_bitField0_ |= 0x00000004; - } - if (msgIdBuilder_ == null) { - result.msgId_ = msgId_; - } else { - result.msgId_ = msgIdBuilder_.build(); - } - if (((from_bitField0_ & 0x00000008) == 0x00000008)) { - to_bitField0_ |= 0x00000008; - } - if (headerBuilder_ == null) { - result.header_ = header_; - } else { - result.header_ = headerBuilder_.build(); - } - result.bitField0_ = to_bitField0_; - onBuilt(); - return result; - } - - public Builder mergeFrom(com.google.protobuf.Message other) { - if (other instanceof org.apache.hedwig.protocol.PubSubProtocol.Message) { - return mergeFrom((org.apache.hedwig.protocol.PubSubProtocol.Message)other); - } else { - super.mergeFrom(other); - return this; - } - } - - public Builder mergeFrom(org.apache.hedwig.protocol.PubSubProtocol.Message other) { - if (other == org.apache.hedwig.protocol.PubSubProtocol.Message.getDefaultInstance()) return this; - if (other.hasBody()) { - setBody(other.getBody()); - } - if (other.hasSrcRegion()) { - setSrcRegion(other.getSrcRegion()); - } - if (other.hasMsgId()) { - mergeMsgId(other.getMsgId()); - } - if (other.hasHeader()) { - mergeHeader(other.getHeader()); - } - this.mergeUnknownFields(other.getUnknownFields()); - return this; - } - - public final boolean isInitialized() { - if (!hasBody()) { - - return false; - } - if (hasMsgId()) { - if (!getMsgId().isInitialized()) { - - return false; - } - } - return true; - } - - public Builder mergeFrom( - com.google.protobuf.CodedInputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - com.google.protobuf.UnknownFieldSet.Builder unknownFields = - com.google.protobuf.UnknownFieldSet.newBuilder( - this.getUnknownFields()); - while (true) { - int tag = input.readTag(); - switch (tag) { - case 0: - this.setUnknownFields(unknownFields.build()); - onChanged(); - return this; - default: { - if (!parseUnknownField(input, unknownFields, - extensionRegistry, tag)) { - this.setUnknownFields(unknownFields.build()); - onChanged(); - return this; - } - break; - } - case 10: { - bitField0_ |= 0x00000001; - body_ = input.readBytes(); - break; - } - case 18: { - bitField0_ |= 0x00000002; - srcRegion_ = input.readBytes(); - break; - } - case 26: { - org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder subBuilder = org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.newBuilder(); - if (hasMsgId()) { - subBuilder.mergeFrom(getMsgId()); - } - input.readMessage(subBuilder, extensionRegistry); - setMsgId(subBuilder.buildPartial()); - break; - } - case 34: { - org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder subBuilder = org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.newBuilder(); - if (hasHeader()) { - subBuilder.mergeFrom(getHeader()); - } - input.readMessage(subBuilder, extensionRegistry); - setHeader(subBuilder.buildPartial()); - break; - } - } - } - } -
<TRUNCATED>
