diff options
Diffstat (limited to 'kamon-core/src/main/java/akka/remote/WireFormats.java')
| -rw-r--r-- | kamon-core/src/main/java/akka/remote/WireFormats.java | 7535 |
1 files changed, 0 insertions, 7535 deletions
diff --git a/kamon-core/src/main/java/akka/remote/WireFormats.java b/kamon-core/src/main/java/akka/remote/WireFormats.java deleted file mode 100644 index 32dcb256..00000000 --- a/kamon-core/src/main/java/akka/remote/WireFormats.java +++ /dev/null @@ -1,7535 +0,0 @@ -// Generated by the protocol buffer compiler. DO NOT EDIT! -// source: WireFormats.proto - -package akka.remote; - -public final class WireFormats { - private WireFormats() {} - public static void registerAllExtensions( - com.google.protobuf.ExtensionRegistry registry) { - } - public enum CommandType - implements com.google.protobuf.ProtocolMessageEnum { - ASSOCIATE(0, 1), - DISASSOCIATE(1, 2), - HEARTBEAT(2, 3), - DISASSOCIATE_SHUTTING_DOWN(3, 4), - DISASSOCIATE_QUARANTINED(4, 5), - ; - - public static final int ASSOCIATE_VALUE = 1; - public static final int DISASSOCIATE_VALUE = 2; - public static final int HEARTBEAT_VALUE = 3; - public static final int DISASSOCIATE_SHUTTING_DOWN_VALUE = 4; - public static final int DISASSOCIATE_QUARANTINED_VALUE = 5; - - - public final int getNumber() { return value; } - - public static CommandType valueOf(int value) { - switch (value) { - case 1: return ASSOCIATE; - case 2: return DISASSOCIATE; - case 3: return HEARTBEAT; - case 4: return DISASSOCIATE_SHUTTING_DOWN; - case 5: return DISASSOCIATE_QUARANTINED; - default: return null; - } - } - - public static com.google.protobuf.Internal.EnumLiteMap<CommandType> - internalGetValueMap() { - return internalValueMap; - } - private static com.google.protobuf.Internal.EnumLiteMap<CommandType> - internalValueMap = - new com.google.protobuf.Internal.EnumLiteMap<CommandType>() { - public CommandType findValueByNumber(int number) { - return CommandType.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 akka.remote.WireFormats.getDescriptor().getEnumTypes().get(0); - } - - private static final CommandType[] VALUES = { - ASSOCIATE, DISASSOCIATE, HEARTBEAT, DISASSOCIATE_SHUTTING_DOWN, DISASSOCIATE_QUARANTINED, - }; - - public static CommandType 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 CommandType(int index, int value) { - this.index = index; - this.value = value; - } - - // @@protoc_insertion_point(enum_scope:CommandType) - } - - public interface AckAndEnvelopeContainerOrBuilder - extends com.google.protobuf.MessageOrBuilder { - - // optional .AcknowledgementInfo ack = 1; - boolean hasAck(); - akka.remote.WireFormats.AcknowledgementInfo getAck(); - akka.remote.WireFormats.AcknowledgementInfoOrBuilder getAckOrBuilder(); - - // optional .RemoteEnvelope envelope = 2; - boolean hasEnvelope(); - akka.remote.WireFormats.RemoteEnvelope getEnvelope(); - akka.remote.WireFormats.RemoteEnvelopeOrBuilder getEnvelopeOrBuilder(); - } - public static final class AckAndEnvelopeContainer extends - com.google.protobuf.GeneratedMessage - implements AckAndEnvelopeContainerOrBuilder { - // Use AckAndEnvelopeContainer.newBuilder() to construct. - private AckAndEnvelopeContainer(Builder builder) { - super(builder); - } - private AckAndEnvelopeContainer(boolean noInit) {} - - private static final AckAndEnvelopeContainer defaultInstance; - public static AckAndEnvelopeContainer getDefaultInstance() { - return defaultInstance; - } - - public AckAndEnvelopeContainer getDefaultInstanceForType() { - return defaultInstance; - } - - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return akka.remote.WireFormats.internal_static_AckAndEnvelopeContainer_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return akka.remote.WireFormats.internal_static_AckAndEnvelopeContainer_fieldAccessorTable; - } - - private int bitField0_; - // optional .AcknowledgementInfo ack = 1; - public static final int ACK_FIELD_NUMBER = 1; - private akka.remote.WireFormats.AcknowledgementInfo ack_; - public boolean hasAck() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public akka.remote.WireFormats.AcknowledgementInfo getAck() { - return ack_; - } - public akka.remote.WireFormats.AcknowledgementInfoOrBuilder getAckOrBuilder() { - return ack_; - } - - // optional .RemoteEnvelope envelope = 2; - public static final int ENVELOPE_FIELD_NUMBER = 2; - private akka.remote.WireFormats.RemoteEnvelope envelope_; - public boolean hasEnvelope() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public akka.remote.WireFormats.RemoteEnvelope getEnvelope() { - return envelope_; - } - public akka.remote.WireFormats.RemoteEnvelopeOrBuilder getEnvelopeOrBuilder() { - return envelope_; - } - - private void initFields() { - ack_ = akka.remote.WireFormats.AcknowledgementInfo.getDefaultInstance(); - envelope_ = akka.remote.WireFormats.RemoteEnvelope.getDefaultInstance(); - } - private byte memoizedIsInitialized = -1; - public final boolean isInitialized() { - byte isInitialized = memoizedIsInitialized; - if (isInitialized != -1) return isInitialized == 1; - - if (hasAck()) { - if (!getAck().isInitialized()) { - memoizedIsInitialized = 0; - return false; - } - } - if (hasEnvelope()) { - if (!getEnvelope().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.writeMessage(1, ack_); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - output.writeMessage(2, envelope_); - } - 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, ack_); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - size += com.google.protobuf.CodedOutputStream - .computeMessageSize(2, envelope_); - } - 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 akka.remote.WireFormats.AckAndEnvelopeContainer parseFrom( - com.google.protobuf.ByteString data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static akka.remote.WireFormats.AckAndEnvelopeContainer parseFrom( - com.google.protobuf.ByteString data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.AckAndEnvelopeContainer parseFrom(byte[] data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static akka.remote.WireFormats.AckAndEnvelopeContainer parseFrom( - byte[] data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.AckAndEnvelopeContainer parseFrom(java.io.InputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static akka.remote.WireFormats.AckAndEnvelopeContainer parseFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return newBuilder().mergeFrom(input, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.AckAndEnvelopeContainer parseDelimitedFrom(java.io.InputStream input) - throws java.io.IOException { - Builder builder = newBuilder(); - if (builder.mergeDelimitedFrom(input)) { - return builder.buildParsed(); - } else { - return null; - } - } - public static akka.remote.WireFormats.AckAndEnvelopeContainer 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 akka.remote.WireFormats.AckAndEnvelopeContainer parseFrom( - com.google.protobuf.CodedInputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static akka.remote.WireFormats.AckAndEnvelopeContainer 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(akka.remote.WireFormats.AckAndEnvelopeContainer 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 akka.remote.WireFormats.AckAndEnvelopeContainerOrBuilder { - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return akka.remote.WireFormats.internal_static_AckAndEnvelopeContainer_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return akka.remote.WireFormats.internal_static_AckAndEnvelopeContainer_fieldAccessorTable; - } - - // Construct using akka.remote.WireFormats.AckAndEnvelopeContainer.newBuilder() - private Builder() { - maybeForceBuilderInitialization(); - } - - private Builder(BuilderParent parent) { - super(parent); - maybeForceBuilderInitialization(); - } - private void maybeForceBuilderInitialization() { - if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { - getAckFieldBuilder(); - getEnvelopeFieldBuilder(); - } - } - private static Builder create() { - return new Builder(); - } - - public Builder clear() { - super.clear(); - if (ackBuilder_ == null) { - ack_ = akka.remote.WireFormats.AcknowledgementInfo.getDefaultInstance(); - } else { - ackBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000001); - if (envelopeBuilder_ == null) { - envelope_ = akka.remote.WireFormats.RemoteEnvelope.getDefaultInstance(); - } else { - envelopeBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000002); - return this; - } - - public Builder clone() { - return create().mergeFrom(buildPartial()); - } - - public com.google.protobuf.Descriptors.Descriptor - getDescriptorForType() { - return akka.remote.WireFormats.AckAndEnvelopeContainer.getDescriptor(); - } - - public akka.remote.WireFormats.AckAndEnvelopeContainer getDefaultInstanceForType() { - return akka.remote.WireFormats.AckAndEnvelopeContainer.getDefaultInstance(); - } - - public akka.remote.WireFormats.AckAndEnvelopeContainer build() { - akka.remote.WireFormats.AckAndEnvelopeContainer result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException(result); - } - return result; - } - - private akka.remote.WireFormats.AckAndEnvelopeContainer buildParsed() - throws com.google.protobuf.InvalidProtocolBufferException { - akka.remote.WireFormats.AckAndEnvelopeContainer result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException( - result).asInvalidProtocolBufferException(); - } - return result; - } - - public akka.remote.WireFormats.AckAndEnvelopeContainer buildPartial() { - akka.remote.WireFormats.AckAndEnvelopeContainer result = new akka.remote.WireFormats.AckAndEnvelopeContainer(this); - int from_bitField0_ = bitField0_; - int to_bitField0_ = 0; - if (((from_bitField0_ & 0x00000001) == 0x00000001)) { - to_bitField0_ |= 0x00000001; - } - if (ackBuilder_ == null) { - result.ack_ = ack_; - } else { - result.ack_ = ackBuilder_.build(); - } - if (((from_bitField0_ & 0x00000002) == 0x00000002)) { - to_bitField0_ |= 0x00000002; - } - if (envelopeBuilder_ == null) { - result.envelope_ = envelope_; - } else { - result.envelope_ = envelopeBuilder_.build(); - } - result.bitField0_ = to_bitField0_; - onBuilt(); - return result; - } - - public Builder mergeFrom(com.google.protobuf.Message other) { - if (other instanceof akka.remote.WireFormats.AckAndEnvelopeContainer) { - return mergeFrom((akka.remote.WireFormats.AckAndEnvelopeContainer)other); - } else { - super.mergeFrom(other); - return this; - } - } - - public Builder mergeFrom(akka.remote.WireFormats.AckAndEnvelopeContainer other) { - if (other == akka.remote.WireFormats.AckAndEnvelopeContainer.getDefaultInstance()) return this; - if (other.hasAck()) { - mergeAck(other.getAck()); - } - if (other.hasEnvelope()) { - mergeEnvelope(other.getEnvelope()); - } - this.mergeUnknownFields(other.getUnknownFields()); - return this; - } - - public final boolean isInitialized() { - if (hasAck()) { - if (!getAck().isInitialized()) { - - return false; - } - } - if (hasEnvelope()) { - if (!getEnvelope().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: { - akka.remote.WireFormats.AcknowledgementInfo.Builder subBuilder = akka.remote.WireFormats.AcknowledgementInfo.newBuilder(); - if (hasAck()) { - subBuilder.mergeFrom(getAck()); - } - input.readMessage(subBuilder, extensionRegistry); - setAck(subBuilder.buildPartial()); - break; - } - case 18: { - akka.remote.WireFormats.RemoteEnvelope.Builder subBuilder = akka.remote.WireFormats.RemoteEnvelope.newBuilder(); - if (hasEnvelope()) { - subBuilder.mergeFrom(getEnvelope()); - } - input.readMessage(subBuilder, extensionRegistry); - setEnvelope(subBuilder.buildPartial()); - break; - } - } - } - } - - private int bitField0_; - - // optional .AcknowledgementInfo ack = 1; - private akka.remote.WireFormats.AcknowledgementInfo ack_ = akka.remote.WireFormats.AcknowledgementInfo.getDefaultInstance(); - private com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.AcknowledgementInfo, akka.remote.WireFormats.AcknowledgementInfo.Builder, akka.remote.WireFormats.AcknowledgementInfoOrBuilder> ackBuilder_; - public boolean hasAck() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public akka.remote.WireFormats.AcknowledgementInfo getAck() { - if (ackBuilder_ == null) { - return ack_; - } else { - return ackBuilder_.getMessage(); - } - } - public Builder setAck(akka.remote.WireFormats.AcknowledgementInfo value) { - if (ackBuilder_ == null) { - if (value == null) { - throw new NullPointerException(); - } - ack_ = value; - onChanged(); - } else { - ackBuilder_.setMessage(value); - } - bitField0_ |= 0x00000001; - return this; - } - public Builder setAck( - akka.remote.WireFormats.AcknowledgementInfo.Builder builderForValue) { - if (ackBuilder_ == null) { - ack_ = builderForValue.build(); - onChanged(); - } else { - ackBuilder_.setMessage(builderForValue.build()); - } - bitField0_ |= 0x00000001; - return this; - } - public Builder mergeAck(akka.remote.WireFormats.AcknowledgementInfo value) { - if (ackBuilder_ == null) { - if (((bitField0_ & 0x00000001) == 0x00000001) && - ack_ != akka.remote.WireFormats.AcknowledgementInfo.getDefaultInstance()) { - ack_ = - akka.remote.WireFormats.AcknowledgementInfo.newBuilder(ack_).mergeFrom(value).buildPartial(); - } else { - ack_ = value; - } - onChanged(); - } else { - ackBuilder_.mergeFrom(value); - } - bitField0_ |= 0x00000001; - return this; - } - public Builder clearAck() { - if (ackBuilder_ == null) { - ack_ = akka.remote.WireFormats.AcknowledgementInfo.getDefaultInstance(); - onChanged(); - } else { - ackBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000001); - return this; - } - public akka.remote.WireFormats.AcknowledgementInfo.Builder getAckBuilder() { - bitField0_ |= 0x00000001; - onChanged(); - return getAckFieldBuilder().getBuilder(); - } - public akka.remote.WireFormats.AcknowledgementInfoOrBuilder getAckOrBuilder() { - if (ackBuilder_ != null) { - return ackBuilder_.getMessageOrBuilder(); - } else { - return ack_; - } - } - private com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.AcknowledgementInfo, akka.remote.WireFormats.AcknowledgementInfo.Builder, akka.remote.WireFormats.AcknowledgementInfoOrBuilder> - getAckFieldBuilder() { - if (ackBuilder_ == null) { - ackBuilder_ = new com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.AcknowledgementInfo, akka.remote.WireFormats.AcknowledgementInfo.Builder, akka.remote.WireFormats.AcknowledgementInfoOrBuilder>( - ack_, - getParentForChildren(), - isClean()); - ack_ = null; - } - return ackBuilder_; - } - - // optional .RemoteEnvelope envelope = 2; - private akka.remote.WireFormats.RemoteEnvelope envelope_ = akka.remote.WireFormats.RemoteEnvelope.getDefaultInstance(); - private com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.RemoteEnvelope, akka.remote.WireFormats.RemoteEnvelope.Builder, akka.remote.WireFormats.RemoteEnvelopeOrBuilder> envelopeBuilder_; - public boolean hasEnvelope() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public akka.remote.WireFormats.RemoteEnvelope getEnvelope() { - if (envelopeBuilder_ == null) { - return envelope_; - } else { - return envelopeBuilder_.getMessage(); - } - } - public Builder setEnvelope(akka.remote.WireFormats.RemoteEnvelope value) { - if (envelopeBuilder_ == null) { - if (value == null) { - throw new NullPointerException(); - } - envelope_ = value; - onChanged(); - } else { - envelopeBuilder_.setMessage(value); - } - bitField0_ |= 0x00000002; - return this; - } - public Builder setEnvelope( - akka.remote.WireFormats.RemoteEnvelope.Builder builderForValue) { - if (envelopeBuilder_ == null) { - envelope_ = builderForValue.build(); - onChanged(); - } else { - envelopeBuilder_.setMessage(builderForValue.build()); - } - bitField0_ |= 0x00000002; - return this; - } - public Builder mergeEnvelope(akka.remote.WireFormats.RemoteEnvelope value) { - if (envelopeBuilder_ == null) { - if (((bitField0_ & 0x00000002) == 0x00000002) && - envelope_ != akka.remote.WireFormats.RemoteEnvelope.getDefaultInstance()) { - envelope_ = - akka.remote.WireFormats.RemoteEnvelope.newBuilder(envelope_).mergeFrom(value).buildPartial(); - } else { - envelope_ = value; - } - onChanged(); - } else { - envelopeBuilder_.mergeFrom(value); - } - bitField0_ |= 0x00000002; - return this; - } - public Builder clearEnvelope() { - if (envelopeBuilder_ == null) { - envelope_ = akka.remote.WireFormats.RemoteEnvelope.getDefaultInstance(); - onChanged(); - } else { - envelopeBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000002); - return this; - } - public akka.remote.WireFormats.RemoteEnvelope.Builder getEnvelopeBuilder() { - bitField0_ |= 0x00000002; - onChanged(); - return getEnvelopeFieldBuilder().getBuilder(); - } - public akka.remote.WireFormats.RemoteEnvelopeOrBuilder getEnvelopeOrBuilder() { - if (envelopeBuilder_ != null) { - return envelopeBuilder_.getMessageOrBuilder(); - } else { - return envelope_; - } - } - private com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.RemoteEnvelope, akka.remote.WireFormats.RemoteEnvelope.Builder, akka.remote.WireFormats.RemoteEnvelopeOrBuilder> - getEnvelopeFieldBuilder() { - if (envelopeBuilder_ == null) { - envelopeBuilder_ = new com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.RemoteEnvelope, akka.remote.WireFormats.RemoteEnvelope.Builder, akka.remote.WireFormats.RemoteEnvelopeOrBuilder>( - envelope_, - getParentForChildren(), - isClean()); - envelope_ = null; - } - return envelopeBuilder_; - } - - // @@protoc_insertion_point(builder_scope:AckAndEnvelopeContainer) - } - - static { - defaultInstance = new AckAndEnvelopeContainer(true); - defaultInstance.initFields(); - } - - // @@protoc_insertion_point(class_scope:AckAndEnvelopeContainer) - } - - public interface RemoteEnvelopeOrBuilder - extends com.google.protobuf.MessageOrBuilder { - - // required .ActorRefData recipient = 1; - boolean hasRecipient(); - akka.remote.WireFormats.ActorRefData getRecipient(); - akka.remote.WireFormats.ActorRefDataOrBuilder getRecipientOrBuilder(); - - // required .SerializedMessage message = 2; - boolean hasMessage(); - akka.remote.WireFormats.SerializedMessage getMessage(); - akka.remote.WireFormats.SerializedMessageOrBuilder getMessageOrBuilder(); - - // optional .ActorRefData sender = 4; - boolean hasSender(); - akka.remote.WireFormats.ActorRefData getSender(); - akka.remote.WireFormats.ActorRefDataOrBuilder getSenderOrBuilder(); - - // optional fixed64 seq = 5; - boolean hasSeq(); - long getSeq(); - } - public static final class RemoteEnvelope extends - com.google.protobuf.GeneratedMessage - implements RemoteEnvelopeOrBuilder { - // Use RemoteEnvelope.newBuilder() to construct. - private RemoteEnvelope(Builder builder) { - super(builder); - } - private RemoteEnvelope(boolean noInit) {} - - private static final RemoteEnvelope defaultInstance; - public static RemoteEnvelope getDefaultInstance() { - return defaultInstance; - } - - public RemoteEnvelope getDefaultInstanceForType() { - return defaultInstance; - } - - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return akka.remote.WireFormats.internal_static_RemoteEnvelope_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return akka.remote.WireFormats.internal_static_RemoteEnvelope_fieldAccessorTable; - } - - private int bitField0_; - // required .ActorRefData recipient = 1; - public static final int RECIPIENT_FIELD_NUMBER = 1; - private akka.remote.WireFormats.ActorRefData recipient_; - public boolean hasRecipient() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public akka.remote.WireFormats.ActorRefData getRecipient() { - return recipient_; - } - public akka.remote.WireFormats.ActorRefDataOrBuilder getRecipientOrBuilder() { - return recipient_; - } - - // required .SerializedMessage message = 2; - public static final int MESSAGE_FIELD_NUMBER = 2; - private akka.remote.WireFormats.SerializedMessage message_; - public boolean hasMessage() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public akka.remote.WireFormats.SerializedMessage getMessage() { - return message_; - } - public akka.remote.WireFormats.SerializedMessageOrBuilder getMessageOrBuilder() { - return message_; - } - - // optional .ActorRefData sender = 4; - public static final int SENDER_FIELD_NUMBER = 4; - private akka.remote.WireFormats.ActorRefData sender_; - public boolean hasSender() { - return ((bitField0_ & 0x00000004) == 0x00000004); - } - public akka.remote.WireFormats.ActorRefData getSender() { - return sender_; - } - public akka.remote.WireFormats.ActorRefDataOrBuilder getSenderOrBuilder() { - return sender_; - } - - // optional fixed64 seq = 5; - public static final int SEQ_FIELD_NUMBER = 5; - private long seq_; - public boolean hasSeq() { - return ((bitField0_ & 0x00000008) == 0x00000008); - } - public long getSeq() { - return seq_; - } - - private void initFields() { - recipient_ = akka.remote.WireFormats.ActorRefData.getDefaultInstance(); - message_ = akka.remote.WireFormats.SerializedMessage.getDefaultInstance(); - sender_ = akka.remote.WireFormats.ActorRefData.getDefaultInstance(); - seq_ = 0L; - } - private byte memoizedIsInitialized = -1; - public final boolean isInitialized() { - byte isInitialized = memoizedIsInitialized; - if (isInitialized != -1) return isInitialized == 1; - - if (!hasRecipient()) { - memoizedIsInitialized = 0; - return false; - } - if (!hasMessage()) { - memoizedIsInitialized = 0; - return false; - } - if (!getRecipient().isInitialized()) { - memoizedIsInitialized = 0; - return false; - } - if (!getMessage().isInitialized()) { - memoizedIsInitialized = 0; - return false; - } - if (hasSender()) { - if (!getSender().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.writeMessage(1, recipient_); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - output.writeMessage(2, message_); - } - if (((bitField0_ & 0x00000004) == 0x00000004)) { - output.writeMessage(4, sender_); - } - if (((bitField0_ & 0x00000008) == 0x00000008)) { - output.writeFixed64(5, seq_); - } - 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, recipient_); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - size += com.google.protobuf.CodedOutputStream - .computeMessageSize(2, message_); - } - if (((bitField0_ & 0x00000004) == 0x00000004)) { - size += com.google.protobuf.CodedOutputStream - .computeMessageSize(4, sender_); - } - if (((bitField0_ & 0x00000008) == 0x00000008)) { - size += com.google.protobuf.CodedOutputStream - .computeFixed64Size(5, seq_); - } - 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 akka.remote.WireFormats.RemoteEnvelope parseFrom( - com.google.protobuf.ByteString data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static akka.remote.WireFormats.RemoteEnvelope parseFrom( - com.google.protobuf.ByteString data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.RemoteEnvelope parseFrom(byte[] data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static akka.remote.WireFormats.RemoteEnvelope parseFrom( - byte[] data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.RemoteEnvelope parseFrom(java.io.InputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static akka.remote.WireFormats.RemoteEnvelope parseFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return newBuilder().mergeFrom(input, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.RemoteEnvelope parseDelimitedFrom(java.io.InputStream input) - throws java.io.IOException { - Builder builder = newBuilder(); - if (builder.mergeDelimitedFrom(input)) { - return builder.buildParsed(); - } else { - return null; - } - } - public static akka.remote.WireFormats.RemoteEnvelope 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 akka.remote.WireFormats.RemoteEnvelope parseFrom( - com.google.protobuf.CodedInputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static akka.remote.WireFormats.RemoteEnvelope 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(akka.remote.WireFormats.RemoteEnvelope 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 akka.remote.WireFormats.RemoteEnvelopeOrBuilder { - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return akka.remote.WireFormats.internal_static_RemoteEnvelope_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return akka.remote.WireFormats.internal_static_RemoteEnvelope_fieldAccessorTable; - } - - // Construct using akka.remote.WireFormats.RemoteEnvelope.newBuilder() - private Builder() { - maybeForceBuilderInitialization(); - } - - private Builder(BuilderParent parent) { - super(parent); - maybeForceBuilderInitialization(); - } - private void maybeForceBuilderInitialization() { - if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { - getRecipientFieldBuilder(); - getMessageFieldBuilder(); - getSenderFieldBuilder(); - } - } - private static Builder create() { - return new Builder(); - } - - public Builder clear() { - super.clear(); - if (recipientBuilder_ == null) { - recipient_ = akka.remote.WireFormats.ActorRefData.getDefaultInstance(); - } else { - recipientBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000001); - if (messageBuilder_ == null) { - message_ = akka.remote.WireFormats.SerializedMessage.getDefaultInstance(); - } else { - messageBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000002); - if (senderBuilder_ == null) { - sender_ = akka.remote.WireFormats.ActorRefData.getDefaultInstance(); - } else { - senderBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000004); - seq_ = 0L; - bitField0_ = (bitField0_ & ~0x00000008); - return this; - } - - public Builder clone() { - return create().mergeFrom(buildPartial()); - } - - public com.google.protobuf.Descriptors.Descriptor - getDescriptorForType() { - return akka.remote.WireFormats.RemoteEnvelope.getDescriptor(); - } - - public akka.remote.WireFormats.RemoteEnvelope getDefaultInstanceForType() { - return akka.remote.WireFormats.RemoteEnvelope.getDefaultInstance(); - } - - public akka.remote.WireFormats.RemoteEnvelope build() { - akka.remote.WireFormats.RemoteEnvelope result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException(result); - } - return result; - } - - private akka.remote.WireFormats.RemoteEnvelope buildParsed() - throws com.google.protobuf.InvalidProtocolBufferException { - akka.remote.WireFormats.RemoteEnvelope result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException( - result).asInvalidProtocolBufferException(); - } - return result; - } - - public akka.remote.WireFormats.RemoteEnvelope buildPartial() { - akka.remote.WireFormats.RemoteEnvelope result = new akka.remote.WireFormats.RemoteEnvelope(this); - int from_bitField0_ = bitField0_; - int to_bitField0_ = 0; - if (((from_bitField0_ & 0x00000001) == 0x00000001)) { - to_bitField0_ |= 0x00000001; - } - if (recipientBuilder_ == null) { - result.recipient_ = recipient_; - } else { - result.recipient_ = recipientBuilder_.build(); - } - if (((from_bitField0_ & 0x00000002) == 0x00000002)) { - to_bitField0_ |= 0x00000002; - } - if (messageBuilder_ == null) { - result.message_ = message_; - } else { - result.message_ = messageBuilder_.build(); - } - if (((from_bitField0_ & 0x00000004) == 0x00000004)) { - to_bitField0_ |= 0x00000004; - } - if (senderBuilder_ == null) { - result.sender_ = sender_; - } else { - result.sender_ = senderBuilder_.build(); - } - if (((from_bitField0_ & 0x00000008) == 0x00000008)) { - to_bitField0_ |= 0x00000008; - } - result.seq_ = seq_; - result.bitField0_ = to_bitField0_; - onBuilt(); - return result; - } - - public Builder mergeFrom(com.google.protobuf.Message other) { - if (other instanceof akka.remote.WireFormats.RemoteEnvelope) { - return mergeFrom((akka.remote.WireFormats.RemoteEnvelope)other); - } else { - super.mergeFrom(other); - return this; - } - } - - public Builder mergeFrom(akka.remote.WireFormats.RemoteEnvelope other) { - if (other == akka.remote.WireFormats.RemoteEnvelope.getDefaultInstance()) return this; - if (other.hasRecipient()) { - mergeRecipient(other.getRecipient()); - } - if (other.hasMessage()) { - mergeMessage(other.getMessage()); - } - if (other.hasSender()) { - mergeSender(other.getSender()); - } - if (other.hasSeq()) { - setSeq(other.getSeq()); - } - this.mergeUnknownFields(other.getUnknownFields()); - return this; - } - - public final boolean isInitialized() { - if (!hasRecipient()) { - - return false; - } - if (!hasMessage()) { - - return false; - } - if (!getRecipient().isInitialized()) { - - return false; - } - if (!getMessage().isInitialized()) { - - return false; - } - if (hasSender()) { - if (!getSender().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: { - akka.remote.WireFormats.ActorRefData.Builder subBuilder = akka.remote.WireFormats.ActorRefData.newBuilder(); - if (hasRecipient()) { - subBuilder.mergeFrom(getRecipient()); - } - input.readMessage(subBuilder, extensionRegistry); - setRecipient(subBuilder.buildPartial()); - break; - } - case 18: { - akka.remote.WireFormats.SerializedMessage.Builder subBuilder = akka.remote.WireFormats.SerializedMessage.newBuilder(); - if (hasMessage()) { - subBuilder.mergeFrom(getMessage()); - } - input.readMessage(subBuilder, extensionRegistry); - setMessage(subBuilder.buildPartial()); - break; - } - case 34: { - akka.remote.WireFormats.ActorRefData.Builder subBuilder = akka.remote.WireFormats.ActorRefData.newBuilder(); - if (hasSender()) { - subBuilder.mergeFrom(getSender()); - } - input.readMessage(subBuilder, extensionRegistry); - setSender(subBuilder.buildPartial()); - break; - } - case 41: { - bitField0_ |= 0x00000008; - seq_ = input.readFixed64(); - break; - } - } - } - } - - private int bitField0_; - - // required .ActorRefData recipient = 1; - private akka.remote.WireFormats.ActorRefData recipient_ = akka.remote.WireFormats.ActorRefData.getDefaultInstance(); - private com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.ActorRefData, akka.remote.WireFormats.ActorRefData.Builder, akka.remote.WireFormats.ActorRefDataOrBuilder> recipientBuilder_; - public boolean hasRecipient() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public akka.remote.WireFormats.ActorRefData getRecipient() { - if (recipientBuilder_ == null) { - return recipient_; - } else { - return recipientBuilder_.getMessage(); - } - } - public Builder setRecipient(akka.remote.WireFormats.ActorRefData value) { - if (recipientBuilder_ == null) { - if (value == null) { - throw new NullPointerException(); - } - recipient_ = value; - onChanged(); - } else { - recipientBuilder_.setMessage(value); - } - bitField0_ |= 0x00000001; - return this; - } - public Builder setRecipient( - akka.remote.WireFormats.ActorRefData.Builder builderForValue) { - if (recipientBuilder_ == null) { - recipient_ = builderForValue.build(); - onChanged(); - } else { - recipientBuilder_.setMessage(builderForValue.build()); - } - bitField0_ |= 0x00000001; - return this; - } - public Builder mergeRecipient(akka.remote.WireFormats.ActorRefData value) { - if (recipientBuilder_ == null) { - if (((bitField0_ & 0x00000001) == 0x00000001) && - recipient_ != akka.remote.WireFormats.ActorRefData.getDefaultInstance()) { - recipient_ = - akka.remote.WireFormats.ActorRefData.newBuilder(recipient_).mergeFrom(value).buildPartial(); - } else { - recipient_ = value; - } - onChanged(); - } else { - recipientBuilder_.mergeFrom(value); - } - bitField0_ |= 0x00000001; - return this; - } - public Builder clearRecipient() { - if (recipientBuilder_ == null) { - recipient_ = akka.remote.WireFormats.ActorRefData.getDefaultInstance(); - onChanged(); - } else { - recipientBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000001); - return this; - } - public akka.remote.WireFormats.ActorRefData.Builder getRecipientBuilder() { - bitField0_ |= 0x00000001; - onChanged(); - return getRecipientFieldBuilder().getBuilder(); - } - public akka.remote.WireFormats.ActorRefDataOrBuilder getRecipientOrBuilder() { - if (recipientBuilder_ != null) { - return recipientBuilder_.getMessageOrBuilder(); - } else { - return recipient_; - } - } - private com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.ActorRefData, akka.remote.WireFormats.ActorRefData.Builder, akka.remote.WireFormats.ActorRefDataOrBuilder> - getRecipientFieldBuilder() { - if (recipientBuilder_ == null) { - recipientBuilder_ = new com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.ActorRefData, akka.remote.WireFormats.ActorRefData.Builder, akka.remote.WireFormats.ActorRefDataOrBuilder>( - recipient_, - getParentForChildren(), - isClean()); - recipient_ = null; - } - return recipientBuilder_; - } - - // required .SerializedMessage message = 2; - private akka.remote.WireFormats.SerializedMessage message_ = akka.remote.WireFormats.SerializedMessage.getDefaultInstance(); - private com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.SerializedMessage, akka.remote.WireFormats.SerializedMessage.Builder, akka.remote.WireFormats.SerializedMessageOrBuilder> messageBuilder_; - public boolean hasMessage() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public akka.remote.WireFormats.SerializedMessage getMessage() { - if (messageBuilder_ == null) { - return message_; - } else { - return messageBuilder_.getMessage(); - } - } - public Builder setMessage(akka.remote.WireFormats.SerializedMessage value) { - if (messageBuilder_ == null) { - if (value == null) { - throw new NullPointerException(); - } - message_ = value; - onChanged(); - } else { - messageBuilder_.setMessage(value); - } - bitField0_ |= 0x00000002; - return this; - } - public Builder setMessage( - akka.remote.WireFormats.SerializedMessage.Builder builderForValue) { - if (messageBuilder_ == null) { - message_ = builderForValue.build(); - onChanged(); - } else { - messageBuilder_.setMessage(builderForValue.build()); - } - bitField0_ |= 0x00000002; - return this; - } - public Builder mergeMessage(akka.remote.WireFormats.SerializedMessage value) { - if (messageBuilder_ == null) { - if (((bitField0_ & 0x00000002) == 0x00000002) && - message_ != akka.remote.WireFormats.SerializedMessage.getDefaultInstance()) { - message_ = - akka.remote.WireFormats.SerializedMessage.newBuilder(message_).mergeFrom(value).buildPartial(); - } else { - message_ = value; - } - onChanged(); - } else { - messageBuilder_.mergeFrom(value); - } - bitField0_ |= 0x00000002; - return this; - } - public Builder clearMessage() { - if (messageBuilder_ == null) { - message_ = akka.remote.WireFormats.SerializedMessage.getDefaultInstance(); - onChanged(); - } else { - messageBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000002); - return this; - } - public akka.remote.WireFormats.SerializedMessage.Builder getMessageBuilder() { - bitField0_ |= 0x00000002; - onChanged(); - return getMessageFieldBuilder().getBuilder(); - } - public akka.remote.WireFormats.SerializedMessageOrBuilder getMessageOrBuilder() { - if (messageBuilder_ != null) { - return messageBuilder_.getMessageOrBuilder(); - } else { - return message_; - } - } - private com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.SerializedMessage, akka.remote.WireFormats.SerializedMessage.Builder, akka.remote.WireFormats.SerializedMessageOrBuilder> - getMessageFieldBuilder() { - if (messageBuilder_ == null) { - messageBuilder_ = new com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.SerializedMessage, akka.remote.WireFormats.SerializedMessage.Builder, akka.remote.WireFormats.SerializedMessageOrBuilder>( - message_, - getParentForChildren(), - isClean()); - message_ = null; - } - return messageBuilder_; - } - - // optional .ActorRefData sender = 4; - private akka.remote.WireFormats.ActorRefData sender_ = akka.remote.WireFormats.ActorRefData.getDefaultInstance(); - private com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.ActorRefData, akka.remote.WireFormats.ActorRefData.Builder, akka.remote.WireFormats.ActorRefDataOrBuilder> senderBuilder_; - public boolean hasSender() { - return ((bitField0_ & 0x00000004) == 0x00000004); - } - public akka.remote.WireFormats.ActorRefData getSender() { - if (senderBuilder_ == null) { - return sender_; - } else { - return senderBuilder_.getMessage(); - } - } - public Builder setSender(akka.remote.WireFormats.ActorRefData value) { - if (senderBuilder_ == null) { - if (value == null) { - throw new NullPointerException(); - } - sender_ = value; - onChanged(); - } else { - senderBuilder_.setMessage(value); - } - bitField0_ |= 0x00000004; - return this; - } - public Builder setSender( - akka.remote.WireFormats.ActorRefData.Builder builderForValue) { - if (senderBuilder_ == null) { - sender_ = builderForValue.build(); - onChanged(); - } else { - senderBuilder_.setMessage(builderForValue.build()); - } - bitField0_ |= 0x00000004; - return this; - } - public Builder mergeSender(akka.remote.WireFormats.ActorRefData value) { - if (senderBuilder_ == null) { - if (((bitField0_ & 0x00000004) == 0x00000004) && - sender_ != akka.remote.WireFormats.ActorRefData.getDefaultInstance()) { - sender_ = - akka.remote.WireFormats.ActorRefData.newBuilder(sender_).mergeFrom(value).buildPartial(); - } else { - sender_ = value; - } - onChanged(); - } else { - senderBuilder_.mergeFrom(value); - } - bitField0_ |= 0x00000004; - return this; - } - public Builder clearSender() { - if (senderBuilder_ == null) { - sender_ = akka.remote.WireFormats.ActorRefData.getDefaultInstance(); - onChanged(); - } else { - senderBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000004); - return this; - } - public akka.remote.WireFormats.ActorRefData.Builder getSenderBuilder() { - bitField0_ |= 0x00000004; - onChanged(); - return getSenderFieldBuilder().getBuilder(); - } - public akka.remote.WireFormats.ActorRefDataOrBuilder getSenderOrBuilder() { - if (senderBuilder_ != null) { - return senderBuilder_.getMessageOrBuilder(); - } else { - return sender_; - } - } - private com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.ActorRefData, akka.remote.WireFormats.ActorRefData.Builder, akka.remote.WireFormats.ActorRefDataOrBuilder> - getSenderFieldBuilder() { - if (senderBuilder_ == null) { - senderBuilder_ = new com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.ActorRefData, akka.remote.WireFormats.ActorRefData.Builder, akka.remote.WireFormats.ActorRefDataOrBuilder>( - sender_, - getParentForChildren(), - isClean()); - sender_ = null; - } - return senderBuilder_; - } - - // optional fixed64 seq = 5; - private long seq_ ; - public boolean hasSeq() { - return ((bitField0_ & 0x00000008) == 0x00000008); - } - public long getSeq() { - return seq_; - } - public Builder setSeq(long value) { - bitField0_ |= 0x00000008; - seq_ = value; - onChanged(); - return this; - } - public Builder clearSeq() { - bitField0_ = (bitField0_ & ~0x00000008); - seq_ = 0L; - onChanged(); - return this; - } - - // @@protoc_insertion_point(builder_scope:RemoteEnvelope) - } - - static { - defaultInstance = new RemoteEnvelope(true); - defaultInstance.initFields(); - } - - // @@protoc_insertion_point(class_scope:RemoteEnvelope) - } - - public interface AcknowledgementInfoOrBuilder - extends com.google.protobuf.MessageOrBuilder { - - // required fixed64 cumulativeAck = 1; - boolean hasCumulativeAck(); - long getCumulativeAck(); - - // repeated fixed64 nacks = 2; - java.util.List<java.lang.Long> getNacksList(); - int getNacksCount(); - long getNacks(int index); - } - public static final class AcknowledgementInfo extends - com.google.protobuf.GeneratedMessage - implements AcknowledgementInfoOrBuilder { - // Use AcknowledgementInfo.newBuilder() to construct. - private AcknowledgementInfo(Builder builder) { - super(builder); - } - private AcknowledgementInfo(boolean noInit) {} - - private static final AcknowledgementInfo defaultInstance; - public static AcknowledgementInfo getDefaultInstance() { - return defaultInstance; - } - - public AcknowledgementInfo getDefaultInstanceForType() { - return defaultInstance; - } - - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return akka.remote.WireFormats.internal_static_AcknowledgementInfo_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return akka.remote.WireFormats.internal_static_AcknowledgementInfo_fieldAccessorTable; - } - - private int bitField0_; - // required fixed64 cumulativeAck = 1; - public static final int CUMULATIVEACK_FIELD_NUMBER = 1; - private long cumulativeAck_; - public boolean hasCumulativeAck() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public long getCumulativeAck() { - return cumulativeAck_; - } - - // repeated fixed64 nacks = 2; - public static final int NACKS_FIELD_NUMBER = 2; - private java.util.List<java.lang.Long> nacks_; - public java.util.List<java.lang.Long> - getNacksList() { - return nacks_; - } - public int getNacksCount() { - return nacks_.size(); - } - public long getNacks(int index) { - return nacks_.get(index); - } - - private void initFields() { - cumulativeAck_ = 0L; - nacks_ = java.util.Collections.emptyList();; - } - private byte memoizedIsInitialized = -1; - public final boolean isInitialized() { - byte isInitialized = memoizedIsInitialized; - if (isInitialized != -1) return isInitialized == 1; - - if (!hasCumulativeAck()) { - 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.writeFixed64(1, cumulativeAck_); - } - for (int i = 0; i < nacks_.size(); i++) { - output.writeFixed64(2, nacks_.get(i)); - } - 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 - .computeFixed64Size(1, cumulativeAck_); - } - { - int dataSize = 0; - dataSize = 8 * getNacksList().size(); - size += dataSize; - size += 1 * getNacksList().size(); - } - 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 akka.remote.WireFormats.AcknowledgementInfo parseFrom( - com.google.protobuf.ByteString data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static akka.remote.WireFormats.AcknowledgementInfo parseFrom( - com.google.protobuf.ByteString data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.AcknowledgementInfo parseFrom(byte[] data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static akka.remote.WireFormats.AcknowledgementInfo parseFrom( - byte[] data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.AcknowledgementInfo parseFrom(java.io.InputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static akka.remote.WireFormats.AcknowledgementInfo parseFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return newBuilder().mergeFrom(input, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.AcknowledgementInfo parseDelimitedFrom(java.io.InputStream input) - throws java.io.IOException { - Builder builder = newBuilder(); - if (builder.mergeDelimitedFrom(input)) { - return builder.buildParsed(); - } else { - return null; - } - } - public static akka.remote.WireFormats.AcknowledgementInfo 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 akka.remote.WireFormats.AcknowledgementInfo parseFrom( - com.google.protobuf.CodedInputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static akka.remote.WireFormats.AcknowledgementInfo 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(akka.remote.WireFormats.AcknowledgementInfo 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 akka.remote.WireFormats.AcknowledgementInfoOrBuilder { - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return akka.remote.WireFormats.internal_static_AcknowledgementInfo_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return akka.remote.WireFormats.internal_static_AcknowledgementInfo_fieldAccessorTable; - } - - // Construct using akka.remote.WireFormats.AcknowledgementInfo.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(); - cumulativeAck_ = 0L; - bitField0_ = (bitField0_ & ~0x00000001); - nacks_ = java.util.Collections.emptyList();; - bitField0_ = (bitField0_ & ~0x00000002); - return this; - } - - public Builder clone() { - return create().mergeFrom(buildPartial()); - } - - public com.google.protobuf.Descriptors.Descriptor - getDescriptorForType() { - return akka.remote.WireFormats.AcknowledgementInfo.getDescriptor(); - } - - public akka.remote.WireFormats.AcknowledgementInfo getDefaultInstanceForType() { - return akka.remote.WireFormats.AcknowledgementInfo.getDefaultInstance(); - } - - public akka.remote.WireFormats.AcknowledgementInfo build() { - akka.remote.WireFormats.AcknowledgementInfo result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException(result); - } - return result; - } - - private akka.remote.WireFormats.AcknowledgementInfo buildParsed() - throws com.google.protobuf.InvalidProtocolBufferException { - akka.remote.WireFormats.AcknowledgementInfo result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException( - result).asInvalidProtocolBufferException(); - } - return result; - } - - public akka.remote.WireFormats.AcknowledgementInfo buildPartial() { - akka.remote.WireFormats.AcknowledgementInfo result = new akka.remote.WireFormats.AcknowledgementInfo(this); - int from_bitField0_ = bitField0_; - int to_bitField0_ = 0; - if (((from_bitField0_ & 0x00000001) == 0x00000001)) { - to_bitField0_ |= 0x00000001; - } - result.cumulativeAck_ = cumulativeAck_; - if (((bitField0_ & 0x00000002) == 0x00000002)) { - nacks_ = java.util.Collections.unmodifiableList(nacks_); - bitField0_ = (bitField0_ & ~0x00000002); - } - result.nacks_ = nacks_; - result.bitField0_ = to_bitField0_; - onBuilt(); - return result; - } - - public Builder mergeFrom(com.google.protobuf.Message other) { - if (other instanceof akka.remote.WireFormats.AcknowledgementInfo) { - return mergeFrom((akka.remote.WireFormats.AcknowledgementInfo)other); - } else { - super.mergeFrom(other); - return this; - } - } - - public Builder mergeFrom(akka.remote.WireFormats.AcknowledgementInfo other) { - if (other == akka.remote.WireFormats.AcknowledgementInfo.getDefaultInstance()) return this; - if (other.hasCumulativeAck()) { - setCumulativeAck(other.getCumulativeAck()); - } - if (!other.nacks_.isEmpty()) { - if (nacks_.isEmpty()) { - nacks_ = other.nacks_; - bitField0_ = (bitField0_ & ~0x00000002); - } else { - ensureNacksIsMutable(); - nacks_.addAll(other.nacks_); - } - onChanged(); - } - this.mergeUnknownFields(other.getUnknownFields()); - return this; - } - - public final boolean isInitialized() { - if (!hasCumulativeAck()) { - - 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 9: { - bitField0_ |= 0x00000001; - cumulativeAck_ = input.readFixed64(); - break; - } - case 17: { - ensureNacksIsMutable(); - nacks_.add(input.readFixed64()); - break; - } - case 18: { - int length = input.readRawVarint32(); - int limit = input.pushLimit(length); - while (input.getBytesUntilLimit() > 0) { - addNacks(input.readFixed64()); - } - input.popLimit(limit); - break; - } - } - } - } - - private int bitField0_; - - // required fixed64 cumulativeAck = 1; - private long cumulativeAck_ ; - public boolean hasCumulativeAck() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public long getCumulativeAck() { - return cumulativeAck_; - } - public Builder setCumulativeAck(long value) { - bitField0_ |= 0x00000001; - cumulativeAck_ = value; - onChanged(); - return this; - } - public Builder clearCumulativeAck() { - bitField0_ = (bitField0_ & ~0x00000001); - cumulativeAck_ = 0L; - onChanged(); - return this; - } - - // repeated fixed64 nacks = 2; - private java.util.List<java.lang.Long> nacks_ = java.util.Collections.emptyList();; - private void ensureNacksIsMutable() { - if (!((bitField0_ & 0x00000002) == 0x00000002)) { - nacks_ = new java.util.ArrayList<java.lang.Long>(nacks_); - bitField0_ |= 0x00000002; - } - } - public java.util.List<java.lang.Long> - getNacksList() { - return java.util.Collections.unmodifiableList(nacks_); - } - public int getNacksCount() { - return nacks_.size(); - } - public long getNacks(int index) { - return nacks_.get(index); - } - public Builder setNacks( - int index, long value) { - ensureNacksIsMutable(); - nacks_.set(index, value); - onChanged(); - return this; - } - public Builder addNacks(long value) { - ensureNacksIsMutable(); - nacks_.add(value); - onChanged(); - return this; - } - public Builder addAllNacks( - java.lang.Iterable<? extends java.lang.Long> values) { - ensureNacksIsMutable(); - super.addAll(values, nacks_); - onChanged(); - return this; - } - public Builder clearNacks() { - nacks_ = java.util.Collections.emptyList();; - bitField0_ = (bitField0_ & ~0x00000002); - onChanged(); - return this; - } - - // @@protoc_insertion_point(builder_scope:AcknowledgementInfo) - } - - static { - defaultInstance = new AcknowledgementInfo(true); - defaultInstance.initFields(); - } - - // @@protoc_insertion_point(class_scope:AcknowledgementInfo) - } - - public interface ActorRefDataOrBuilder - extends com.google.protobuf.MessageOrBuilder { - - // required string path = 1; - boolean hasPath(); - String getPath(); - } - public static final class ActorRefData extends - com.google.protobuf.GeneratedMessage - implements ActorRefDataOrBuilder { - // Use ActorRefData.newBuilder() to construct. - private ActorRefData(Builder builder) { - super(builder); - } - private ActorRefData(boolean noInit) {} - - private static final ActorRefData defaultInstance; - public static ActorRefData getDefaultInstance() { - return defaultInstance; - } - - public ActorRefData getDefaultInstanceForType() { - return defaultInstance; - } - - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return akka.remote.WireFormats.internal_static_ActorRefData_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return akka.remote.WireFormats.internal_static_ActorRefData_fieldAccessorTable; - } - - private int bitField0_; - // required string path = 1; - public static final int PATH_FIELD_NUMBER = 1; - private java.lang.Object path_; - public boolean hasPath() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public String getPath() { - java.lang.Object ref = path_; - 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)) { - path_ = s; - } - return s; - } - } - private com.google.protobuf.ByteString getPathBytes() { - java.lang.Object ref = path_; - if (ref instanceof String) { - com.google.protobuf.ByteString b = - com.google.protobuf.ByteString.copyFromUtf8((String) ref); - path_ = b; - return b; - } else { - return (com.google.protobuf.ByteString) ref; - } - } - - private void initFields() { - path_ = ""; - } - private byte memoizedIsInitialized = -1; - public final boolean isInitialized() { - byte isInitialized = memoizedIsInitialized; - if (isInitialized != -1) return isInitialized == 1; - - if (!hasPath()) { - 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, getPathBytes()); - } - 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, getPathBytes()); - } - 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 akka.remote.WireFormats.ActorRefData parseFrom( - com.google.protobuf.ByteString data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static akka.remote.WireFormats.ActorRefData parseFrom( - com.google.protobuf.ByteString data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.ActorRefData parseFrom(byte[] data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static akka.remote.WireFormats.ActorRefData parseFrom( - byte[] data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.ActorRefData parseFrom(java.io.InputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static akka.remote.WireFormats.ActorRefData parseFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return newBuilder().mergeFrom(input, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.ActorRefData parseDelimitedFrom(java.io.InputStream input) - throws java.io.IOException { - Builder builder = newBuilder(); - if (builder.mergeDelimitedFrom(input)) { - return builder.buildParsed(); - } else { - return null; - } - } - public static akka.remote.WireFormats.ActorRefData 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 akka.remote.WireFormats.ActorRefData parseFrom( - com.google.protobuf.CodedInputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static akka.remote.WireFormats.ActorRefData 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(akka.remote.WireFormats.ActorRefData 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 akka.remote.WireFormats.ActorRefDataOrBuilder { - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return akka.remote.WireFormats.internal_static_ActorRefData_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return akka.remote.WireFormats.internal_static_ActorRefData_fieldAccessorTable; - } - - // Construct using akka.remote.WireFormats.ActorRefData.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(); - path_ = ""; - bitField0_ = (bitField0_ & ~0x00000001); - return this; - } - - public Builder clone() { - return create().mergeFrom(buildPartial()); - } - - public com.google.protobuf.Descriptors.Descriptor - getDescriptorForType() { - return akka.remote.WireFormats.ActorRefData.getDescriptor(); - } - - public akka.remote.WireFormats.ActorRefData getDefaultInstanceForType() { - return akka.remote.WireFormats.ActorRefData.getDefaultInstance(); - } - - public akka.remote.WireFormats.ActorRefData build() { - akka.remote.WireFormats.ActorRefData result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException(result); - } - return result; - } - - private akka.remote.WireFormats.ActorRefData buildParsed() - throws com.google.protobuf.InvalidProtocolBufferException { - akka.remote.WireFormats.ActorRefData result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException( - result).asInvalidProtocolBufferException(); - } - return result; - } - - public akka.remote.WireFormats.ActorRefData buildPartial() { - akka.remote.WireFormats.ActorRefData result = new akka.remote.WireFormats.ActorRefData(this); - int from_bitField0_ = bitField0_; - int to_bitField0_ = 0; - if (((from_bitField0_ & 0x00000001) == 0x00000001)) { - to_bitField0_ |= 0x00000001; - } - result.path_ = path_; - result.bitField0_ = to_bitField0_; - onBuilt(); - return result; - } - - public Builder mergeFrom(com.google.protobuf.Message other) { - if (other instanceof akka.remote.WireFormats.ActorRefData) { - return mergeFrom((akka.remote.WireFormats.ActorRefData)other); - } else { - super.mergeFrom(other); - return this; - } - } - - public Builder mergeFrom(akka.remote.WireFormats.ActorRefData other) { - if (other == akka.remote.WireFormats.ActorRefData.getDefaultInstance()) return this; - if (other.hasPath()) { - setPath(other.getPath()); - } - this.mergeUnknownFields(other.getUnknownFields()); - return this; - } - - public final boolean isInitialized() { - if (!hasPath()) { - - 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; - path_ = input.readBytes(); - break; - } - } - } - } - - private int bitField0_; - - // required string path = 1; - private java.lang.Object path_ = ""; - public boolean hasPath() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public String getPath() { - java.lang.Object ref = path_; - if (!(ref instanceof String)) { - String s = ((com.google.protobuf.ByteString) ref).toStringUtf8(); - path_ = s; - return s; - } else { - return (String) ref; - } - } - public Builder setPath(String value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000001; - path_ = value; - onChanged(); - return this; - } - public Builder clearPath() { - bitField0_ = (bitField0_ & ~0x00000001); - path_ = getDefaultInstance().getPath(); - onChanged(); - return this; - } - void setPath(com.google.protobuf.ByteString value) { - bitField0_ |= 0x00000001; - path_ = value; - onChanged(); - } - - // @@protoc_insertion_point(builder_scope:ActorRefData) - } - - static { - defaultInstance = new ActorRefData(true); - defaultInstance.initFields(); - } - - // @@protoc_insertion_point(class_scope:ActorRefData) - } - - public interface SerializedMessageOrBuilder - extends com.google.protobuf.MessageOrBuilder { - - // required bytes message = 1; - boolean hasMessage(); - com.google.protobuf.ByteString getMessage(); - - // required int32 serializerId = 2; - boolean hasSerializerId(); - int getSerializerId(); - - // optional bytes messageManifest = 3; - boolean hasMessageManifest(); - com.google.protobuf.ByteString getMessageManifest(); - } - public static final class SerializedMessage extends - com.google.protobuf.GeneratedMessage - implements SerializedMessageOrBuilder { - // Use SerializedMessage.newBuilder() to construct. - private SerializedMessage(Builder builder) { - super(builder); - } - private SerializedMessage(boolean noInit) {} - - private static final SerializedMessage defaultInstance; - public static SerializedMessage getDefaultInstance() { - return defaultInstance; - } - - public SerializedMessage getDefaultInstanceForType() { - return defaultInstance; - } - - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return akka.remote.WireFormats.internal_static_SerializedMessage_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return akka.remote.WireFormats.internal_static_SerializedMessage_fieldAccessorTable; - } - - private int bitField0_; - // required bytes message = 1; - public static final int MESSAGE_FIELD_NUMBER = 1; - private com.google.protobuf.ByteString message_; - public boolean hasMessage() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public com.google.protobuf.ByteString getMessage() { - return message_; - } - - // required int32 serializerId = 2; - public static final int SERIALIZERID_FIELD_NUMBER = 2; - private int serializerId_; - public boolean hasSerializerId() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public int getSerializerId() { - return serializerId_; - } - - // optional bytes messageManifest = 3; - public static final int MESSAGEMANIFEST_FIELD_NUMBER = 3; - private com.google.protobuf.ByteString messageManifest_; - public boolean hasMessageManifest() { - return ((bitField0_ & 0x00000004) == 0x00000004); - } - public com.google.protobuf.ByteString getMessageManifest() { - return messageManifest_; - } - - private void initFields() { - message_ = com.google.protobuf.ByteString.EMPTY; - serializerId_ = 0; - messageManifest_ = com.google.protobuf.ByteString.EMPTY; - } - private byte memoizedIsInitialized = -1; - public final boolean isInitialized() { - byte isInitialized = memoizedIsInitialized; - if (isInitialized != -1) return isInitialized == 1; - - if (!hasMessage()) { - memoizedIsInitialized = 0; - return false; - } - if (!hasSerializerId()) { - 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, message_); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - output.writeInt32(2, serializerId_); - } - if (((bitField0_ & 0x00000004) == 0x00000004)) { - output.writeBytes(3, messageManifest_); - } - 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, message_); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - size += com.google.protobuf.CodedOutputStream - .computeInt32Size(2, serializerId_); - } - if (((bitField0_ & 0x00000004) == 0x00000004)) { - size += com.google.protobuf.CodedOutputStream - .computeBytesSize(3, messageManifest_); - } - 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 akka.remote.WireFormats.SerializedMessage parseFrom( - com.google.protobuf.ByteString data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static akka.remote.WireFormats.SerializedMessage parseFrom( - com.google.protobuf.ByteString data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.SerializedMessage parseFrom(byte[] data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static akka.remote.WireFormats.SerializedMessage parseFrom( - byte[] data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.SerializedMessage parseFrom(java.io.InputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static akka.remote.WireFormats.SerializedMessage parseFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return newBuilder().mergeFrom(input, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.SerializedMessage parseDelimitedFrom(java.io.InputStream input) - throws java.io.IOException { - Builder builder = newBuilder(); - if (builder.mergeDelimitedFrom(input)) { - return builder.buildParsed(); - } else { - return null; - } - } - public static akka.remote.WireFormats.SerializedMessage 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 akka.remote.WireFormats.SerializedMessage parseFrom( - com.google.protobuf.CodedInputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static akka.remote.WireFormats.SerializedMessage 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(akka.remote.WireFormats.SerializedMessage 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 akka.remote.WireFormats.SerializedMessageOrBuilder { - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return akka.remote.WireFormats.internal_static_SerializedMessage_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return akka.remote.WireFormats.internal_static_SerializedMessage_fieldAccessorTable; - } - - // Construct using akka.remote.WireFormats.SerializedMessage.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(); - message_ = com.google.protobuf.ByteString.EMPTY; - bitField0_ = (bitField0_ & ~0x00000001); - serializerId_ = 0; - bitField0_ = (bitField0_ & ~0x00000002); - messageManifest_ = com.google.protobuf.ByteString.EMPTY; - bitField0_ = (bitField0_ & ~0x00000004); - return this; - } - - public Builder clone() { - return create().mergeFrom(buildPartial()); - } - - public com.google.protobuf.Descriptors.Descriptor - getDescriptorForType() { - return akka.remote.WireFormats.SerializedMessage.getDescriptor(); - } - - public akka.remote.WireFormats.SerializedMessage getDefaultInstanceForType() { - return akka.remote.WireFormats.SerializedMessage.getDefaultInstance(); - } - - public akka.remote.WireFormats.SerializedMessage build() { - akka.remote.WireFormats.SerializedMessage result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException(result); - } - return result; - } - - private akka.remote.WireFormats.SerializedMessage buildParsed() - throws com.google.protobuf.InvalidProtocolBufferException { - akka.remote.WireFormats.SerializedMessage result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException( - result).asInvalidProtocolBufferException(); - } - return result; - } - - public akka.remote.WireFormats.SerializedMessage buildPartial() { - akka.remote.WireFormats.SerializedMessage result = new akka.remote.WireFormats.SerializedMessage(this); - int from_bitField0_ = bitField0_; - int to_bitField0_ = 0; - if (((from_bitField0_ & 0x00000001) == 0x00000001)) { - to_bitField0_ |= 0x00000001; - } - result.message_ = message_; - if (((from_bitField0_ & 0x00000002) == 0x00000002)) { - to_bitField0_ |= 0x00000002; - } - result.serializerId_ = serializerId_; - if (((from_bitField0_ & 0x00000004) == 0x00000004)) { - to_bitField0_ |= 0x00000004; - } - result.messageManifest_ = messageManifest_; - result.bitField0_ = to_bitField0_; - onBuilt(); - return result; - } - - public Builder mergeFrom(com.google.protobuf.Message other) { - if (other instanceof akka.remote.WireFormats.SerializedMessage) { - return mergeFrom((akka.remote.WireFormats.SerializedMessage)other); - } else { - super.mergeFrom(other); - return this; - } - } - - public Builder mergeFrom(akka.remote.WireFormats.SerializedMessage other) { - if (other == akka.remote.WireFormats.SerializedMessage.getDefaultInstance()) return this; - if (other.hasMessage()) { - setMessage(other.getMessage()); - } - if (other.hasSerializerId()) { - setSerializerId(other.getSerializerId()); - } - if (other.hasMessageManifest()) { - setMessageManifest(other.getMessageManifest()); - } - this.mergeUnknownFields(other.getUnknownFields()); - return this; - } - - public final boolean isInitialized() { - if (!hasMessage()) { - - return false; - } - if (!hasSerializerId()) { - - 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; - message_ = input.readBytes(); - break; - } - case 16: { - bitField0_ |= 0x00000002; - serializerId_ = input.readInt32(); - break; - } - case 26: { - bitField0_ |= 0x00000004; - messageManifest_ = input.readBytes(); - break; - } - } - } - } - - private int bitField0_; - - // required bytes message = 1; - private com.google.protobuf.ByteString message_ = com.google.protobuf.ByteString.EMPTY; - public boolean hasMessage() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public com.google.protobuf.ByteString getMessage() { - return message_; - } - public Builder setMessage(com.google.protobuf.ByteString value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000001; - message_ = value; - onChanged(); - return this; - } - public Builder clearMessage() { - bitField0_ = (bitField0_ & ~0x00000001); - message_ = getDefaultInstance().getMessage(); - onChanged(); - return this; - } - - // required int32 serializerId = 2; - private int serializerId_ ; - public boolean hasSerializerId() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public int getSerializerId() { - return serializerId_; - } - public Builder setSerializerId(int value) { - bitField0_ |= 0x00000002; - serializerId_ = value; - onChanged(); - return this; - } - public Builder clearSerializerId() { - bitField0_ = (bitField0_ & ~0x00000002); - serializerId_ = 0; - onChanged(); - return this; - } - - // optional bytes messageManifest = 3; - private com.google.protobuf.ByteString messageManifest_ = com.google.protobuf.ByteString.EMPTY; - public boolean hasMessageManifest() { - return ((bitField0_ & 0x00000004) == 0x00000004); - } - public com.google.protobuf.ByteString getMessageManifest() { - return messageManifest_; - } - public Builder setMessageManifest(com.google.protobuf.ByteString value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000004; - messageManifest_ = value; - onChanged(); - return this; - } - public Builder clearMessageManifest() { - bitField0_ = (bitField0_ & ~0x00000004); - messageManifest_ = getDefaultInstance().getMessageManifest(); - onChanged(); - return this; - } - - // @@protoc_insertion_point(builder_scope:SerializedMessage) - } - - static { - defaultInstance = new SerializedMessage(true); - defaultInstance.initFields(); - } - - // @@protoc_insertion_point(class_scope:SerializedMessage) - } - - public interface DaemonMsgCreateDataOrBuilder - extends com.google.protobuf.MessageOrBuilder { - - // required .PropsData props = 1; - boolean hasProps(); - akka.remote.WireFormats.PropsData getProps(); - akka.remote.WireFormats.PropsDataOrBuilder getPropsOrBuilder(); - - // required .DeployData deploy = 2; - boolean hasDeploy(); - akka.remote.WireFormats.DeployData getDeploy(); - akka.remote.WireFormats.DeployDataOrBuilder getDeployOrBuilder(); - - // required string path = 3; - boolean hasPath(); - String getPath(); - - // required .ActorRefData supervisor = 4; - boolean hasSupervisor(); - akka.remote.WireFormats.ActorRefData getSupervisor(); - akka.remote.WireFormats.ActorRefDataOrBuilder getSupervisorOrBuilder(); - } - public static final class DaemonMsgCreateData extends - com.google.protobuf.GeneratedMessage - implements DaemonMsgCreateDataOrBuilder { - // Use DaemonMsgCreateData.newBuilder() to construct. - private DaemonMsgCreateData(Builder builder) { - super(builder); - } - private DaemonMsgCreateData(boolean noInit) {} - - private static final DaemonMsgCreateData defaultInstance; - public static DaemonMsgCreateData getDefaultInstance() { - return defaultInstance; - } - - public DaemonMsgCreateData getDefaultInstanceForType() { - return defaultInstance; - } - - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return akka.remote.WireFormats.internal_static_DaemonMsgCreateData_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return akka.remote.WireFormats.internal_static_DaemonMsgCreateData_fieldAccessorTable; - } - - private int bitField0_; - // required .PropsData props = 1; - public static final int PROPS_FIELD_NUMBER = 1; - private akka.remote.WireFormats.PropsData props_; - public boolean hasProps() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public akka.remote.WireFormats.PropsData getProps() { - return props_; - } - public akka.remote.WireFormats.PropsDataOrBuilder getPropsOrBuilder() { - return props_; - } - - // required .DeployData deploy = 2; - public static final int DEPLOY_FIELD_NUMBER = 2; - private akka.remote.WireFormats.DeployData deploy_; - public boolean hasDeploy() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public akka.remote.WireFormats.DeployData getDeploy() { - return deploy_; - } - public akka.remote.WireFormats.DeployDataOrBuilder getDeployOrBuilder() { - return deploy_; - } - - // required string path = 3; - public static final int PATH_FIELD_NUMBER = 3; - private java.lang.Object path_; - public boolean hasPath() { - return ((bitField0_ & 0x00000004) == 0x00000004); - } - public String getPath() { - java.lang.Object ref = path_; - 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)) { - path_ = s; - } - return s; - } - } - private com.google.protobuf.ByteString getPathBytes() { - java.lang.Object ref = path_; - if (ref instanceof String) { - com.google.protobuf.ByteString b = - com.google.protobuf.ByteString.copyFromUtf8((String) ref); - path_ = b; - return b; - } else { - return (com.google.protobuf.ByteString) ref; - } - } - - // required .ActorRefData supervisor = 4; - public static final int SUPERVISOR_FIELD_NUMBER = 4; - private akka.remote.WireFormats.ActorRefData supervisor_; - public boolean hasSupervisor() { - return ((bitField0_ & 0x00000008) == 0x00000008); - } - public akka.remote.WireFormats.ActorRefData getSupervisor() { - return supervisor_; - } - public akka.remote.WireFormats.ActorRefDataOrBuilder getSupervisorOrBuilder() { - return supervisor_; - } - - private void initFields() { - props_ = akka.remote.WireFormats.PropsData.getDefaultInstance(); - deploy_ = akka.remote.WireFormats.DeployData.getDefaultInstance(); - path_ = ""; - supervisor_ = akka.remote.WireFormats.ActorRefData.getDefaultInstance(); - } - private byte memoizedIsInitialized = -1; - public final boolean isInitialized() { - byte isInitialized = memoizedIsInitialized; - if (isInitialized != -1) return isInitialized == 1; - - if (!hasProps()) { - memoizedIsInitialized = 0; - return false; - } - if (!hasDeploy()) { - memoizedIsInitialized = 0; - return false; - } - if (!hasPath()) { - memoizedIsInitialized = 0; - return false; - } - if (!hasSupervisor()) { - memoizedIsInitialized = 0; - return false; - } - if (!getProps().isInitialized()) { - memoizedIsInitialized = 0; - return false; - } - if (!getDeploy().isInitialized()) { - memoizedIsInitialized = 0; - return false; - } - if (!getSupervisor().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.writeMessage(1, props_); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - output.writeMessage(2, deploy_); - } - if (((bitField0_ & 0x00000004) == 0x00000004)) { - output.writeBytes(3, getPathBytes()); - } - if (((bitField0_ & 0x00000008) == 0x00000008)) { - output.writeMessage(4, supervisor_); - } - 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, props_); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - size += com.google.protobuf.CodedOutputStream - .computeMessageSize(2, deploy_); - } - if (((bitField0_ & 0x00000004) == 0x00000004)) { - size += com.google.protobuf.CodedOutputStream - .computeBytesSize(3, getPathBytes()); - } - if (((bitField0_ & 0x00000008) == 0x00000008)) { - size += com.google.protobuf.CodedOutputStream - .computeMessageSize(4, supervisor_); - } - 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 akka.remote.WireFormats.DaemonMsgCreateData parseFrom( - com.google.protobuf.ByteString data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static akka.remote.WireFormats.DaemonMsgCreateData parseFrom( - com.google.protobuf.ByteString data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.DaemonMsgCreateData parseFrom(byte[] data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static akka.remote.WireFormats.DaemonMsgCreateData parseFrom( - byte[] data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.DaemonMsgCreateData parseFrom(java.io.InputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static akka.remote.WireFormats.DaemonMsgCreateData parseFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return newBuilder().mergeFrom(input, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.DaemonMsgCreateData parseDelimitedFrom(java.io.InputStream input) - throws java.io.IOException { - Builder builder = newBuilder(); - if (builder.mergeDelimitedFrom(input)) { - return builder.buildParsed(); - } else { - return null; - } - } - public static akka.remote.WireFormats.DaemonMsgCreateData 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 akka.remote.WireFormats.DaemonMsgCreateData parseFrom( - com.google.protobuf.CodedInputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static akka.remote.WireFormats.DaemonMsgCreateData 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(akka.remote.WireFormats.DaemonMsgCreateData 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 akka.remote.WireFormats.DaemonMsgCreateDataOrBuilder { - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return akka.remote.WireFormats.internal_static_DaemonMsgCreateData_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return akka.remote.WireFormats.internal_static_DaemonMsgCreateData_fieldAccessorTable; - } - - // Construct using akka.remote.WireFormats.DaemonMsgCreateData.newBuilder() - private Builder() { - maybeForceBuilderInitialization(); - } - - private Builder(BuilderParent parent) { - super(parent); - maybeForceBuilderInitialization(); - } - private void maybeForceBuilderInitialization() { - if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { - getPropsFieldBuilder(); - getDeployFieldBuilder(); - getSupervisorFieldBuilder(); - } - } - private static Builder create() { - return new Builder(); - } - - public Builder clear() { - super.clear(); - if (propsBuilder_ == null) { - props_ = akka.remote.WireFormats.PropsData.getDefaultInstance(); - } else { - propsBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000001); - if (deployBuilder_ == null) { - deploy_ = akka.remote.WireFormats.DeployData.getDefaultInstance(); - } else { - deployBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000002); - path_ = ""; - bitField0_ = (bitField0_ & ~0x00000004); - if (supervisorBuilder_ == null) { - supervisor_ = akka.remote.WireFormats.ActorRefData.getDefaultInstance(); - } else { - supervisorBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000008); - return this; - } - - public Builder clone() { - return create().mergeFrom(buildPartial()); - } - - public com.google.protobuf.Descriptors.Descriptor - getDescriptorForType() { - return akka.remote.WireFormats.DaemonMsgCreateData.getDescriptor(); - } - - public akka.remote.WireFormats.DaemonMsgCreateData getDefaultInstanceForType() { - return akka.remote.WireFormats.DaemonMsgCreateData.getDefaultInstance(); - } - - public akka.remote.WireFormats.DaemonMsgCreateData build() { - akka.remote.WireFormats.DaemonMsgCreateData result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException(result); - } - return result; - } - - private akka.remote.WireFormats.DaemonMsgCreateData buildParsed() - throws com.google.protobuf.InvalidProtocolBufferException { - akka.remote.WireFormats.DaemonMsgCreateData result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException( - result).asInvalidProtocolBufferException(); - } - return result; - } - - public akka.remote.WireFormats.DaemonMsgCreateData buildPartial() { - akka.remote.WireFormats.DaemonMsgCreateData result = new akka.remote.WireFormats.DaemonMsgCreateData(this); - int from_bitField0_ = bitField0_; - int to_bitField0_ = 0; - if (((from_bitField0_ & 0x00000001) == 0x00000001)) { - to_bitField0_ |= 0x00000001; - } - if (propsBuilder_ == null) { - result.props_ = props_; - } else { - result.props_ = propsBuilder_.build(); - } - if (((from_bitField0_ & 0x00000002) == 0x00000002)) { - to_bitField0_ |= 0x00000002; - } - if (deployBuilder_ == null) { - result.deploy_ = deploy_; - } else { - result.deploy_ = deployBuilder_.build(); - } - if (((from_bitField0_ & 0x00000004) == 0x00000004)) { - to_bitField0_ |= 0x00000004; - } - result.path_ = path_; - if (((from_bitField0_ & 0x00000008) == 0x00000008)) { - to_bitField0_ |= 0x00000008; - } - if (supervisorBuilder_ == null) { - result.supervisor_ = supervisor_; - } else { - result.supervisor_ = supervisorBuilder_.build(); - } - result.bitField0_ = to_bitField0_; - onBuilt(); - return result; - } - - public Builder mergeFrom(com.google.protobuf.Message other) { - if (other instanceof akka.remote.WireFormats.DaemonMsgCreateData) { - return mergeFrom((akka.remote.WireFormats.DaemonMsgCreateData)other); - } else { - super.mergeFrom(other); - return this; - } - } - - public Builder mergeFrom(akka.remote.WireFormats.DaemonMsgCreateData other) { - if (other == akka.remote.WireFormats.DaemonMsgCreateData.getDefaultInstance()) return this; - if (other.hasProps()) { - mergeProps(other.getProps()); - } - if (other.hasDeploy()) { - mergeDeploy(other.getDeploy()); - } - if (other.hasPath()) { - setPath(other.getPath()); - } - if (other.hasSupervisor()) { - mergeSupervisor(other.getSupervisor()); - } - this.mergeUnknownFields(other.getUnknownFields()); - return this; - } - - public final boolean isInitialized() { - if (!hasProps()) { - - return false; - } - if (!hasDeploy()) { - - return false; - } - if (!hasPath()) { - - return false; - } - if (!hasSupervisor()) { - - return false; - } - if (!getProps().isInitialized()) { - - return false; - } - if (!getDeploy().isInitialized()) { - - return false; - } - if (!getSupervisor().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: { - akka.remote.WireFormats.PropsData.Builder subBuilder = akka.remote.WireFormats.PropsData.newBuilder(); - if (hasProps()) { - subBuilder.mergeFrom(getProps()); - } - input.readMessage(subBuilder, extensionRegistry); - setProps(subBuilder.buildPartial()); - break; - } - case 18: { - akka.remote.WireFormats.DeployData.Builder subBuilder = akka.remote.WireFormats.DeployData.newBuilder(); - if (hasDeploy()) { - subBuilder.mergeFrom(getDeploy()); - } - input.readMessage(subBuilder, extensionRegistry); - setDeploy(subBuilder.buildPartial()); - break; - } - case 26: { - bitField0_ |= 0x00000004; - path_ = input.readBytes(); - break; - } - case 34: { - akka.remote.WireFormats.ActorRefData.Builder subBuilder = akka.remote.WireFormats.ActorRefData.newBuilder(); - if (hasSupervisor()) { - subBuilder.mergeFrom(getSupervisor()); - } - input.readMessage(subBuilder, extensionRegistry); - setSupervisor(subBuilder.buildPartial()); - break; - } - } - } - } - - private int bitField0_; - - // required .PropsData props = 1; - private akka.remote.WireFormats.PropsData props_ = akka.remote.WireFormats.PropsData.getDefaultInstance(); - private com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.PropsData, akka.remote.WireFormats.PropsData.Builder, akka.remote.WireFormats.PropsDataOrBuilder> propsBuilder_; - public boolean hasProps() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public akka.remote.WireFormats.PropsData getProps() { - if (propsBuilder_ == null) { - return props_; - } else { - return propsBuilder_.getMessage(); - } - } - public Builder setProps(akka.remote.WireFormats.PropsData value) { - if (propsBuilder_ == null) { - if (value == null) { - throw new NullPointerException(); - } - props_ = value; - onChanged(); - } else { - propsBuilder_.setMessage(value); - } - bitField0_ |= 0x00000001; - return this; - } - public Builder setProps( - akka.remote.WireFormats.PropsData.Builder builderForValue) { - if (propsBuilder_ == null) { - props_ = builderForValue.build(); - onChanged(); - } else { - propsBuilder_.setMessage(builderForValue.build()); - } - bitField0_ |= 0x00000001; - return this; - } - public Builder mergeProps(akka.remote.WireFormats.PropsData value) { - if (propsBuilder_ == null) { - if (((bitField0_ & 0x00000001) == 0x00000001) && - props_ != akka.remote.WireFormats.PropsData.getDefaultInstance()) { - props_ = - akka.remote.WireFormats.PropsData.newBuilder(props_).mergeFrom(value).buildPartial(); - } else { - props_ = value; - } - onChanged(); - } else { - propsBuilder_.mergeFrom(value); - } - bitField0_ |= 0x00000001; - return this; - } - public Builder clearProps() { - if (propsBuilder_ == null) { - props_ = akka.remote.WireFormats.PropsData.getDefaultInstance(); - onChanged(); - } else { - propsBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000001); - return this; - } - public akka.remote.WireFormats.PropsData.Builder getPropsBuilder() { - bitField0_ |= 0x00000001; - onChanged(); - return getPropsFieldBuilder().getBuilder(); - } - public akka.remote.WireFormats.PropsDataOrBuilder getPropsOrBuilder() { - if (propsBuilder_ != null) { - return propsBuilder_.getMessageOrBuilder(); - } else { - return props_; - } - } - private com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.PropsData, akka.remote.WireFormats.PropsData.Builder, akka.remote.WireFormats.PropsDataOrBuilder> - getPropsFieldBuilder() { - if (propsBuilder_ == null) { - propsBuilder_ = new com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.PropsData, akka.remote.WireFormats.PropsData.Builder, akka.remote.WireFormats.PropsDataOrBuilder>( - props_, - getParentForChildren(), - isClean()); - props_ = null; - } - return propsBuilder_; - } - - // required .DeployData deploy = 2; - private akka.remote.WireFormats.DeployData deploy_ = akka.remote.WireFormats.DeployData.getDefaultInstance(); - private com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.DeployData, akka.remote.WireFormats.DeployData.Builder, akka.remote.WireFormats.DeployDataOrBuilder> deployBuilder_; - public boolean hasDeploy() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public akka.remote.WireFormats.DeployData getDeploy() { - if (deployBuilder_ == null) { - return deploy_; - } else { - return deployBuilder_.getMessage(); - } - } - public Builder setDeploy(akka.remote.WireFormats.DeployData value) { - if (deployBuilder_ == null) { - if (value == null) { - throw new NullPointerException(); - } - deploy_ = value; - onChanged(); - } else { - deployBuilder_.setMessage(value); - } - bitField0_ |= 0x00000002; - return this; - } - public Builder setDeploy( - akka.remote.WireFormats.DeployData.Builder builderForValue) { - if (deployBuilder_ == null) { - deploy_ = builderForValue.build(); - onChanged(); - } else { - deployBuilder_.setMessage(builderForValue.build()); - } - bitField0_ |= 0x00000002; - return this; - } - public Builder mergeDeploy(akka.remote.WireFormats.DeployData value) { - if (deployBuilder_ == null) { - if (((bitField0_ & 0x00000002) == 0x00000002) && - deploy_ != akka.remote.WireFormats.DeployData.getDefaultInstance()) { - deploy_ = - akka.remote.WireFormats.DeployData.newBuilder(deploy_).mergeFrom(value).buildPartial(); - } else { - deploy_ = value; - } - onChanged(); - } else { - deployBuilder_.mergeFrom(value); - } - bitField0_ |= 0x00000002; - return this; - } - public Builder clearDeploy() { - if (deployBuilder_ == null) { - deploy_ = akka.remote.WireFormats.DeployData.getDefaultInstance(); - onChanged(); - } else { - deployBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000002); - return this; - } - public akka.remote.WireFormats.DeployData.Builder getDeployBuilder() { - bitField0_ |= 0x00000002; - onChanged(); - return getDeployFieldBuilder().getBuilder(); - } - public akka.remote.WireFormats.DeployDataOrBuilder getDeployOrBuilder() { - if (deployBuilder_ != null) { - return deployBuilder_.getMessageOrBuilder(); - } else { - return deploy_; - } - } - private com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.DeployData, akka.remote.WireFormats.DeployData.Builder, akka.remote.WireFormats.DeployDataOrBuilder> - getDeployFieldBuilder() { - if (deployBuilder_ == null) { - deployBuilder_ = new com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.DeployData, akka.remote.WireFormats.DeployData.Builder, akka.remote.WireFormats.DeployDataOrBuilder>( - deploy_, - getParentForChildren(), - isClean()); - deploy_ = null; - } - return deployBuilder_; - } - - // required string path = 3; - private java.lang.Object path_ = ""; - public boolean hasPath() { - return ((bitField0_ & 0x00000004) == 0x00000004); - } - public String getPath() { - java.lang.Object ref = path_; - if (!(ref instanceof String)) { - String s = ((com.google.protobuf.ByteString) ref).toStringUtf8(); - path_ = s; - return s; - } else { - return (String) ref; - } - } - public Builder setPath(String value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000004; - path_ = value; - onChanged(); - return this; - } - public Builder clearPath() { - bitField0_ = (bitField0_ & ~0x00000004); - path_ = getDefaultInstance().getPath(); - onChanged(); - return this; - } - void setPath(com.google.protobuf.ByteString value) { - bitField0_ |= 0x00000004; - path_ = value; - onChanged(); - } - - // required .ActorRefData supervisor = 4; - private akka.remote.WireFormats.ActorRefData supervisor_ = akka.remote.WireFormats.ActorRefData.getDefaultInstance(); - private com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.ActorRefData, akka.remote.WireFormats.ActorRefData.Builder, akka.remote.WireFormats.ActorRefDataOrBuilder> supervisorBuilder_; - public boolean hasSupervisor() { - return ((bitField0_ & 0x00000008) == 0x00000008); - } - public akka.remote.WireFormats.ActorRefData getSupervisor() { - if (supervisorBuilder_ == null) { - return supervisor_; - } else { - return supervisorBuilder_.getMessage(); - } - } - public Builder setSupervisor(akka.remote.WireFormats.ActorRefData value) { - if (supervisorBuilder_ == null) { - if (value == null) { - throw new NullPointerException(); - } - supervisor_ = value; - onChanged(); - } else { - supervisorBuilder_.setMessage(value); - } - bitField0_ |= 0x00000008; - return this; - } - public Builder setSupervisor( - akka.remote.WireFormats.ActorRefData.Builder builderForValue) { - if (supervisorBuilder_ == null) { - supervisor_ = builderForValue.build(); - onChanged(); - } else { - supervisorBuilder_.setMessage(builderForValue.build()); - } - bitField0_ |= 0x00000008; - return this; - } - public Builder mergeSupervisor(akka.remote.WireFormats.ActorRefData value) { - if (supervisorBuilder_ == null) { - if (((bitField0_ & 0x00000008) == 0x00000008) && - supervisor_ != akka.remote.WireFormats.ActorRefData.getDefaultInstance()) { - supervisor_ = - akka.remote.WireFormats.ActorRefData.newBuilder(supervisor_).mergeFrom(value).buildPartial(); - } else { - supervisor_ = value; - } - onChanged(); - } else { - supervisorBuilder_.mergeFrom(value); - } - bitField0_ |= 0x00000008; - return this; - } - public Builder clearSupervisor() { - if (supervisorBuilder_ == null) { - supervisor_ = akka.remote.WireFormats.ActorRefData.getDefaultInstance(); - onChanged(); - } else { - supervisorBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000008); - return this; - } - public akka.remote.WireFormats.ActorRefData.Builder getSupervisorBuilder() { - bitField0_ |= 0x00000008; - onChanged(); - return getSupervisorFieldBuilder().getBuilder(); - } - public akka.remote.WireFormats.ActorRefDataOrBuilder getSupervisorOrBuilder() { - if (supervisorBuilder_ != null) { - return supervisorBuilder_.getMessageOrBuilder(); - } else { - return supervisor_; - } - } - private com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.ActorRefData, akka.remote.WireFormats.ActorRefData.Builder, akka.remote.WireFormats.ActorRefDataOrBuilder> - getSupervisorFieldBuilder() { - if (supervisorBuilder_ == null) { - supervisorBuilder_ = new com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.ActorRefData, akka.remote.WireFormats.ActorRefData.Builder, akka.remote.WireFormats.ActorRefDataOrBuilder>( - supervisor_, - getParentForChildren(), - isClean()); - supervisor_ = null; - } - return supervisorBuilder_; - } - - // @@protoc_insertion_point(builder_scope:DaemonMsgCreateData) - } - - static { - defaultInstance = new DaemonMsgCreateData(true); - defaultInstance.initFields(); - } - - // @@protoc_insertion_point(class_scope:DaemonMsgCreateData) - } - - public interface PropsDataOrBuilder - extends com.google.protobuf.MessageOrBuilder { - - // required .DeployData deploy = 2; - boolean hasDeploy(); - akka.remote.WireFormats.DeployData getDeploy(); - akka.remote.WireFormats.DeployDataOrBuilder getDeployOrBuilder(); - - // required string clazz = 3; - boolean hasClazz(); - String getClazz(); - - // repeated bytes args = 4; - java.util.List<com.google.protobuf.ByteString> getArgsList(); - int getArgsCount(); - com.google.protobuf.ByteString getArgs(int index); - - // repeated string classes = 5; - java.util.List<String> getClassesList(); - int getClassesCount(); - String getClasses(int index); - } - public static final class PropsData extends - com.google.protobuf.GeneratedMessage - implements PropsDataOrBuilder { - // Use PropsData.newBuilder() to construct. - private PropsData(Builder builder) { - super(builder); - } - private PropsData(boolean noInit) {} - - private static final PropsData defaultInstance; - public static PropsData getDefaultInstance() { - return defaultInstance; - } - - public PropsData getDefaultInstanceForType() { - return defaultInstance; - } - - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return akka.remote.WireFormats.internal_static_PropsData_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return akka.remote.WireFormats.internal_static_PropsData_fieldAccessorTable; - } - - private int bitField0_; - // required .DeployData deploy = 2; - public static final int DEPLOY_FIELD_NUMBER = 2; - private akka.remote.WireFormats.DeployData deploy_; - public boolean hasDeploy() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public akka.remote.WireFormats.DeployData getDeploy() { - return deploy_; - } - public akka.remote.WireFormats.DeployDataOrBuilder getDeployOrBuilder() { - return deploy_; - } - - // required string clazz = 3; - public static final int CLAZZ_FIELD_NUMBER = 3; - private java.lang.Object clazz_; - public boolean hasClazz() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public String getClazz() { - java.lang.Object ref = clazz_; - 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)) { - clazz_ = s; - } - return s; - } - } - private com.google.protobuf.ByteString getClazzBytes() { - java.lang.Object ref = clazz_; - if (ref instanceof String) { - com.google.protobuf.ByteString b = - com.google.protobuf.ByteString.copyFromUtf8((String) ref); - clazz_ = b; - return b; - } else { - return (com.google.protobuf.ByteString) ref; - } - } - - // repeated bytes args = 4; - public static final int ARGS_FIELD_NUMBER = 4; - private java.util.List<com.google.protobuf.ByteString> args_; - public java.util.List<com.google.protobuf.ByteString> - getArgsList() { - return args_; - } - public int getArgsCount() { - return args_.size(); - } - public com.google.protobuf.ByteString getArgs(int index) { - return args_.get(index); - } - - // repeated string classes = 5; - public static final int CLASSES_FIELD_NUMBER = 5; - private com.google.protobuf.LazyStringList classes_; - public java.util.List<String> - getClassesList() { - return classes_; - } - public int getClassesCount() { - return classes_.size(); - } - public String getClasses(int index) { - return classes_.get(index); - } - - private void initFields() { - deploy_ = akka.remote.WireFormats.DeployData.getDefaultInstance(); - clazz_ = ""; - args_ = java.util.Collections.emptyList();; - classes_ = com.google.protobuf.LazyStringArrayList.EMPTY; - } - private byte memoizedIsInitialized = -1; - public final boolean isInitialized() { - byte isInitialized = memoizedIsInitialized; - if (isInitialized != -1) return isInitialized == 1; - - if (!hasDeploy()) { - memoizedIsInitialized = 0; - return false; - } - if (!hasClazz()) { - memoizedIsInitialized = 0; - return false; - } - if (!getDeploy().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.writeMessage(2, deploy_); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - output.writeBytes(3, getClazzBytes()); - } - for (int i = 0; i < args_.size(); i++) { - output.writeBytes(4, args_.get(i)); - } - for (int i = 0; i < classes_.size(); i++) { - output.writeBytes(5, classes_.getByteString(i)); - } - 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(2, deploy_); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - size += com.google.protobuf.CodedOutputStream - .computeBytesSize(3, getClazzBytes()); - } - { - int dataSize = 0; - for (int i = 0; i < args_.size(); i++) { - dataSize += com.google.protobuf.CodedOutputStream - .computeBytesSizeNoTag(args_.get(i)); - } - size += dataSize; - size += 1 * getArgsList().size(); - } - { - int dataSize = 0; - for (int i = 0; i < classes_.size(); i++) { - dataSize += com.google.protobuf.CodedOutputStream - .computeBytesSizeNoTag(classes_.getByteString(i)); - } - size += dataSize; - size += 1 * getClassesList().size(); - } - 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 akka.remote.WireFormats.PropsData parseFrom( - com.google.protobuf.ByteString data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static akka.remote.WireFormats.PropsData parseFrom( - com.google.protobuf.ByteString data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.PropsData parseFrom(byte[] data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static akka.remote.WireFormats.PropsData parseFrom( - byte[] data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.PropsData parseFrom(java.io.InputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static akka.remote.WireFormats.PropsData parseFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return newBuilder().mergeFrom(input, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.PropsData parseDelimitedFrom(java.io.InputStream input) - throws java.io.IOException { - Builder builder = newBuilder(); - if (builder.mergeDelimitedFrom(input)) { - return builder.buildParsed(); - } else { - return null; - } - } - public static akka.remote.WireFormats.PropsData 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 akka.remote.WireFormats.PropsData parseFrom( - com.google.protobuf.CodedInputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static akka.remote.WireFormats.PropsData 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(akka.remote.WireFormats.PropsData 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 akka.remote.WireFormats.PropsDataOrBuilder { - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return akka.remote.WireFormats.internal_static_PropsData_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return akka.remote.WireFormats.internal_static_PropsData_fieldAccessorTable; - } - - // Construct using akka.remote.WireFormats.PropsData.newBuilder() - private Builder() { - maybeForceBuilderInitialization(); - } - - private Builder(BuilderParent parent) { - super(parent); - maybeForceBuilderInitialization(); - } - private void maybeForceBuilderInitialization() { - if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { - getDeployFieldBuilder(); - } - } - private static Builder create() { - return new Builder(); - } - - public Builder clear() { - super.clear(); - if (deployBuilder_ == null) { - deploy_ = akka.remote.WireFormats.DeployData.getDefaultInstance(); - } else { - deployBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000001); - clazz_ = ""; - bitField0_ = (bitField0_ & ~0x00000002); - args_ = java.util.Collections.emptyList();; - bitField0_ = (bitField0_ & ~0x00000004); - classes_ = com.google.protobuf.LazyStringArrayList.EMPTY; - bitField0_ = (bitField0_ & ~0x00000008); - return this; - } - - public Builder clone() { - return create().mergeFrom(buildPartial()); - } - - public com.google.protobuf.Descriptors.Descriptor - getDescriptorForType() { - return akka.remote.WireFormats.PropsData.getDescriptor(); - } - - public akka.remote.WireFormats.PropsData getDefaultInstanceForType() { - return akka.remote.WireFormats.PropsData.getDefaultInstance(); - } - - public akka.remote.WireFormats.PropsData build() { - akka.remote.WireFormats.PropsData result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException(result); - } - return result; - } - - private akka.remote.WireFormats.PropsData buildParsed() - throws com.google.protobuf.InvalidProtocolBufferException { - akka.remote.WireFormats.PropsData result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException( - result).asInvalidProtocolBufferException(); - } - return result; - } - - public akka.remote.WireFormats.PropsData buildPartial() { - akka.remote.WireFormats.PropsData result = new akka.remote.WireFormats.PropsData(this); - int from_bitField0_ = bitField0_; - int to_bitField0_ = 0; - if (((from_bitField0_ & 0x00000001) == 0x00000001)) { - to_bitField0_ |= 0x00000001; - } - if (deployBuilder_ == null) { - result.deploy_ = deploy_; - } else { - result.deploy_ = deployBuilder_.build(); - } - if (((from_bitField0_ & 0x00000002) == 0x00000002)) { - to_bitField0_ |= 0x00000002; - } - result.clazz_ = clazz_; - if (((bitField0_ & 0x00000004) == 0x00000004)) { - args_ = java.util.Collections.unmodifiableList(args_); - bitField0_ = (bitField0_ & ~0x00000004); - } - result.args_ = args_; - if (((bitField0_ & 0x00000008) == 0x00000008)) { - classes_ = new com.google.protobuf.UnmodifiableLazyStringList( - classes_); - bitField0_ = (bitField0_ & ~0x00000008); - } - result.classes_ = classes_; - result.bitField0_ = to_bitField0_; - onBuilt(); - return result; - } - - public Builder mergeFrom(com.google.protobuf.Message other) { - if (other instanceof akka.remote.WireFormats.PropsData) { - return mergeFrom((akka.remote.WireFormats.PropsData)other); - } else { - super.mergeFrom(other); - return this; - } - } - - public Builder mergeFrom(akka.remote.WireFormats.PropsData other) { - if (other == akka.remote.WireFormats.PropsData.getDefaultInstance()) return this; - if (other.hasDeploy()) { - mergeDeploy(other.getDeploy()); - } - if (other.hasClazz()) { - setClazz(other.getClazz()); - } - if (!other.args_.isEmpty()) { - if (args_.isEmpty()) { - args_ = other.args_; - bitField0_ = (bitField0_ & ~0x00000004); - } else { - ensureArgsIsMutable(); - args_.addAll(other.args_); - } - onChanged(); - } - if (!other.classes_.isEmpty()) { - if (classes_.isEmpty()) { - classes_ = other.classes_; - bitField0_ = (bitField0_ & ~0x00000008); - } else { - ensureClassesIsMutable(); - classes_.addAll(other.classes_); - } - onChanged(); - } - this.mergeUnknownFields(other.getUnknownFields()); - return this; - } - - public final boolean isInitialized() { - if (!hasDeploy()) { - - return false; - } - if (!hasClazz()) { - - return false; - } - if (!getDeploy().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 18: { - akka.remote.WireFormats.DeployData.Builder subBuilder = akka.remote.WireFormats.DeployData.newBuilder(); - if (hasDeploy()) { - subBuilder.mergeFrom(getDeploy()); - } - input.readMessage(subBuilder, extensionRegistry); - setDeploy(subBuilder.buildPartial()); - break; - } - case 26: { - bitField0_ |= 0x00000002; - clazz_ = input.readBytes(); - break; - } - case 34: { - ensureArgsIsMutable(); - args_.add(input.readBytes()); - break; - } - case 42: { - ensureClassesIsMutable(); - classes_.add(input.readBytes()); - break; - } - } - } - } - - private int bitField0_; - - // required .DeployData deploy = 2; - private akka.remote.WireFormats.DeployData deploy_ = akka.remote.WireFormats.DeployData.getDefaultInstance(); - private com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.DeployData, akka.remote.WireFormats.DeployData.Builder, akka.remote.WireFormats.DeployDataOrBuilder> deployBuilder_; - public boolean hasDeploy() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public akka.remote.WireFormats.DeployData getDeploy() { - if (deployBuilder_ == null) { - return deploy_; - } else { - return deployBuilder_.getMessage(); - } - } - public Builder setDeploy(akka.remote.WireFormats.DeployData value) { - if (deployBuilder_ == null) { - if (value == null) { - throw new NullPointerException(); - } - deploy_ = value; - onChanged(); - } else { - deployBuilder_.setMessage(value); - } - bitField0_ |= 0x00000001; - return this; - } - public Builder setDeploy( - akka.remote.WireFormats.DeployData.Builder builderForValue) { - if (deployBuilder_ == null) { - deploy_ = builderForValue.build(); - onChanged(); - } else { - deployBuilder_.setMessage(builderForValue.build()); - } - bitField0_ |= 0x00000001; - return this; - } - public Builder mergeDeploy(akka.remote.WireFormats.DeployData value) { - if (deployBuilder_ == null) { - if (((bitField0_ & 0x00000001) == 0x00000001) && - deploy_ != akka.remote.WireFormats.DeployData.getDefaultInstance()) { - deploy_ = - akka.remote.WireFormats.DeployData.newBuilder(deploy_).mergeFrom(value).buildPartial(); - } else { - deploy_ = value; - } - onChanged(); - } else { - deployBuilder_.mergeFrom(value); - } - bitField0_ |= 0x00000001; - return this; - } - public Builder clearDeploy() { - if (deployBuilder_ == null) { - deploy_ = akka.remote.WireFormats.DeployData.getDefaultInstance(); - onChanged(); - } else { - deployBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000001); - return this; - } - public akka.remote.WireFormats.DeployData.Builder getDeployBuilder() { - bitField0_ |= 0x00000001; - onChanged(); - return getDeployFieldBuilder().getBuilder(); - } - public akka.remote.WireFormats.DeployDataOrBuilder getDeployOrBuilder() { - if (deployBuilder_ != null) { - return deployBuilder_.getMessageOrBuilder(); - } else { - return deploy_; - } - } - private com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.DeployData, akka.remote.WireFormats.DeployData.Builder, akka.remote.WireFormats.DeployDataOrBuilder> - getDeployFieldBuilder() { - if (deployBuilder_ == null) { - deployBuilder_ = new com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.DeployData, akka.remote.WireFormats.DeployData.Builder, akka.remote.WireFormats.DeployDataOrBuilder>( - deploy_, - getParentForChildren(), - isClean()); - deploy_ = null; - } - return deployBuilder_; - } - - // required string clazz = 3; - private java.lang.Object clazz_ = ""; - public boolean hasClazz() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public String getClazz() { - java.lang.Object ref = clazz_; - if (!(ref instanceof String)) { - String s = ((com.google.protobuf.ByteString) ref).toStringUtf8(); - clazz_ = s; - return s; - } else { - return (String) ref; - } - } - public Builder setClazz(String value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000002; - clazz_ = value; - onChanged(); - return this; - } - public Builder clearClazz() { - bitField0_ = (bitField0_ & ~0x00000002); - clazz_ = getDefaultInstance().getClazz(); - onChanged(); - return this; - } - void setClazz(com.google.protobuf.ByteString value) { - bitField0_ |= 0x00000002; - clazz_ = value; - onChanged(); - } - - // repeated bytes args = 4; - private java.util.List<com.google.protobuf.ByteString> args_ = java.util.Collections.emptyList();; - private void ensureArgsIsMutable() { - if (!((bitField0_ & 0x00000004) == 0x00000004)) { - args_ = new java.util.ArrayList<com.google.protobuf.ByteString>(args_); - bitField0_ |= 0x00000004; - } - } - public java.util.List<com.google.protobuf.ByteString> - getArgsList() { - return java.util.Collections.unmodifiableList(args_); - } - public int getArgsCount() { - return args_.size(); - } - public com.google.protobuf.ByteString getArgs(int index) { - return args_.get(index); - } - public Builder setArgs( - int index, com.google.protobuf.ByteString value) { - if (value == null) { - throw new NullPointerException(); - } - ensureArgsIsMutable(); - args_.set(index, value); - onChanged(); - return this; - } - public Builder addArgs(com.google.protobuf.ByteString value) { - if (value == null) { - throw new NullPointerException(); - } - ensureArgsIsMutable(); - args_.add(value); - onChanged(); - return this; - } - public Builder addAllArgs( - java.lang.Iterable<? extends com.google.protobuf.ByteString> values) { - ensureArgsIsMutable(); - super.addAll(values, args_); - onChanged(); - return this; - } - public Builder clearArgs() { - args_ = java.util.Collections.emptyList();; - bitField0_ = (bitField0_ & ~0x00000004); - onChanged(); - return this; - } - - // repeated string classes = 5; - private com.google.protobuf.LazyStringList classes_ = com.google.protobuf.LazyStringArrayList.EMPTY; - private void ensureClassesIsMutable() { - if (!((bitField0_ & 0x00000008) == 0x00000008)) { - classes_ = new com.google.protobuf.LazyStringArrayList(classes_); - bitField0_ |= 0x00000008; - } - } - public java.util.List<String> - getClassesList() { - return java.util.Collections.unmodifiableList(classes_); - } - public int getClassesCount() { - return classes_.size(); - } - public String getClasses(int index) { - return classes_.get(index); - } - public Builder setClasses( - int index, String value) { - if (value == null) { - throw new NullPointerException(); - } - ensureClassesIsMutable(); - classes_.set(index, value); - onChanged(); - return this; - } - public Builder addClasses(String value) { - if (value == null) { - throw new NullPointerException(); - } - ensureClassesIsMutable(); - classes_.add(value); - onChanged(); - return this; - } - public Builder addAllClasses( - java.lang.Iterable<String> values) { - ensureClassesIsMutable(); - super.addAll(values, classes_); - onChanged(); - return this; - } - public Builder clearClasses() { - classes_ = com.google.protobuf.LazyStringArrayList.EMPTY; - bitField0_ = (bitField0_ & ~0x00000008); - onChanged(); - return this; - } - void addClasses(com.google.protobuf.ByteString value) { - ensureClassesIsMutable(); - classes_.add(value); - onChanged(); - } - - // @@protoc_insertion_point(builder_scope:PropsData) - } - - static { - defaultInstance = new PropsData(true); - defaultInstance.initFields(); - } - - // @@protoc_insertion_point(class_scope:PropsData) - } - - public interface DeployDataOrBuilder - extends com.google.protobuf.MessageOrBuilder { - - // required string path = 1; - boolean hasPath(); - String getPath(); - - // optional bytes config = 2; - boolean hasConfig(); - com.google.protobuf.ByteString getConfig(); - - // optional bytes routerConfig = 3; - boolean hasRouterConfig(); - com.google.protobuf.ByteString getRouterConfig(); - - // optional bytes scope = 4; - boolean hasScope(); - com.google.protobuf.ByteString getScope(); - - // optional string dispatcher = 5; - boolean hasDispatcher(); - String getDispatcher(); - } - public static final class DeployData extends - com.google.protobuf.GeneratedMessage - implements DeployDataOrBuilder { - // Use DeployData.newBuilder() to construct. - private DeployData(Builder builder) { - super(builder); - } - private DeployData(boolean noInit) {} - - private static final DeployData defaultInstance; - public static DeployData getDefaultInstance() { - return defaultInstance; - } - - public DeployData getDefaultInstanceForType() { - return defaultInstance; - } - - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return akka.remote.WireFormats.internal_static_DeployData_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return akka.remote.WireFormats.internal_static_DeployData_fieldAccessorTable; - } - - private int bitField0_; - // required string path = 1; - public static final int PATH_FIELD_NUMBER = 1; - private java.lang.Object path_; - public boolean hasPath() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public String getPath() { - java.lang.Object ref = path_; - 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)) { - path_ = s; - } - return s; - } - } - private com.google.protobuf.ByteString getPathBytes() { - java.lang.Object ref = path_; - if (ref instanceof String) { - com.google.protobuf.ByteString b = - com.google.protobuf.ByteString.copyFromUtf8((String) ref); - path_ = b; - return b; - } else { - return (com.google.protobuf.ByteString) ref; - } - } - - // optional bytes config = 2; - public static final int CONFIG_FIELD_NUMBER = 2; - private com.google.protobuf.ByteString config_; - public boolean hasConfig() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public com.google.protobuf.ByteString getConfig() { - return config_; - } - - // optional bytes routerConfig = 3; - public static final int ROUTERCONFIG_FIELD_NUMBER = 3; - private com.google.protobuf.ByteString routerConfig_; - public boolean hasRouterConfig() { - return ((bitField0_ & 0x00000004) == 0x00000004); - } - public com.google.protobuf.ByteString getRouterConfig() { - return routerConfig_; - } - - // optional bytes scope = 4; - public static final int SCOPE_FIELD_NUMBER = 4; - private com.google.protobuf.ByteString scope_; - public boolean hasScope() { - return ((bitField0_ & 0x00000008) == 0x00000008); - } - public com.google.protobuf.ByteString getScope() { - return scope_; - } - - // optional string dispatcher = 5; - public static final int DISPATCHER_FIELD_NUMBER = 5; - private java.lang.Object dispatcher_; - public boolean hasDispatcher() { - return ((bitField0_ & 0x00000010) == 0x00000010); - } - public String getDispatcher() { - java.lang.Object ref = dispatcher_; - 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)) { - dispatcher_ = s; - } - return s; - } - } - private com.google.protobuf.ByteString getDispatcherBytes() { - java.lang.Object ref = dispatcher_; - if (ref instanceof String) { - com.google.protobuf.ByteString b = - com.google.protobuf.ByteString.copyFromUtf8((String) ref); - dispatcher_ = b; - return b; - } else { - return (com.google.protobuf.ByteString) ref; - } - } - - private void initFields() { - path_ = ""; - config_ = com.google.protobuf.ByteString.EMPTY; - routerConfig_ = com.google.protobuf.ByteString.EMPTY; - scope_ = com.google.protobuf.ByteString.EMPTY; - dispatcher_ = ""; - } - private byte memoizedIsInitialized = -1; - public final boolean isInitialized() { - byte isInitialized = memoizedIsInitialized; - if (isInitialized != -1) return isInitialized == 1; - - if (!hasPath()) { - 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, getPathBytes()); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - output.writeBytes(2, config_); - } - if (((bitField0_ & 0x00000004) == 0x00000004)) { - output.writeBytes(3, routerConfig_); - } - if (((bitField0_ & 0x00000008) == 0x00000008)) { - output.writeBytes(4, scope_); - } - if (((bitField0_ & 0x00000010) == 0x00000010)) { - output.writeBytes(5, getDispatcherBytes()); - } - 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, getPathBytes()); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - size += com.google.protobuf.CodedOutputStream - .computeBytesSize(2, config_); - } - if (((bitField0_ & 0x00000004) == 0x00000004)) { - size += com.google.protobuf.CodedOutputStream - .computeBytesSize(3, routerConfig_); - } - if (((bitField0_ & 0x00000008) == 0x00000008)) { - size += com.google.protobuf.CodedOutputStream - .computeBytesSize(4, scope_); - } - if (((bitField0_ & 0x00000010) == 0x00000010)) { - size += com.google.protobuf.CodedOutputStream - .computeBytesSize(5, getDispatcherBytes()); - } - 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 akka.remote.WireFormats.DeployData parseFrom( - com.google.protobuf.ByteString data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static akka.remote.WireFormats.DeployData parseFrom( - com.google.protobuf.ByteString data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.DeployData parseFrom(byte[] data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static akka.remote.WireFormats.DeployData parseFrom( - byte[] data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.DeployData parseFrom(java.io.InputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static akka.remote.WireFormats.DeployData parseFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return newBuilder().mergeFrom(input, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.DeployData parseDelimitedFrom(java.io.InputStream input) - throws java.io.IOException { - Builder builder = newBuilder(); - if (builder.mergeDelimitedFrom(input)) { - return builder.buildParsed(); - } else { - return null; - } - } - public static akka.remote.WireFormats.DeployData 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 akka.remote.WireFormats.DeployData parseFrom( - com.google.protobuf.CodedInputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static akka.remote.WireFormats.DeployData 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(akka.remote.WireFormats.DeployData 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 akka.remote.WireFormats.DeployDataOrBuilder { - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return akka.remote.WireFormats.internal_static_DeployData_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return akka.remote.WireFormats.internal_static_DeployData_fieldAccessorTable; - } - - // Construct using akka.remote.WireFormats.DeployData.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(); - path_ = ""; - bitField0_ = (bitField0_ & ~0x00000001); - config_ = com.google.protobuf.ByteString.EMPTY; - bitField0_ = (bitField0_ & ~0x00000002); - routerConfig_ = com.google.protobuf.ByteString.EMPTY; - bitField0_ = (bitField0_ & ~0x00000004); - scope_ = com.google.protobuf.ByteString.EMPTY; - bitField0_ = (bitField0_ & ~0x00000008); - dispatcher_ = ""; - bitField0_ = (bitField0_ & ~0x00000010); - return this; - } - - public Builder clone() { - return create().mergeFrom(buildPartial()); - } - - public com.google.protobuf.Descriptors.Descriptor - getDescriptorForType() { - return akka.remote.WireFormats.DeployData.getDescriptor(); - } - - public akka.remote.WireFormats.DeployData getDefaultInstanceForType() { - return akka.remote.WireFormats.DeployData.getDefaultInstance(); - } - - public akka.remote.WireFormats.DeployData build() { - akka.remote.WireFormats.DeployData result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException(result); - } - return result; - } - - private akka.remote.WireFormats.DeployData buildParsed() - throws com.google.protobuf.InvalidProtocolBufferException { - akka.remote.WireFormats.DeployData result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException( - result).asInvalidProtocolBufferException(); - } - return result; - } - - public akka.remote.WireFormats.DeployData buildPartial() { - akka.remote.WireFormats.DeployData result = new akka.remote.WireFormats.DeployData(this); - int from_bitField0_ = bitField0_; - int to_bitField0_ = 0; - if (((from_bitField0_ & 0x00000001) == 0x00000001)) { - to_bitField0_ |= 0x00000001; - } - result.path_ = path_; - if (((from_bitField0_ & 0x00000002) == 0x00000002)) { - to_bitField0_ |= 0x00000002; - } - result.config_ = config_; - if (((from_bitField0_ & 0x00000004) == 0x00000004)) { - to_bitField0_ |= 0x00000004; - } - result.routerConfig_ = routerConfig_; - if (((from_bitField0_ & 0x00000008) == 0x00000008)) { - to_bitField0_ |= 0x00000008; - } - result.scope_ = scope_; - if (((from_bitField0_ & 0x00000010) == 0x00000010)) { - to_bitField0_ |= 0x00000010; - } - result.dispatcher_ = dispatcher_; - result.bitField0_ = to_bitField0_; - onBuilt(); - return result; - } - - public Builder mergeFrom(com.google.protobuf.Message other) { - if (other instanceof akka.remote.WireFormats.DeployData) { - return mergeFrom((akka.remote.WireFormats.DeployData)other); - } else { - super.mergeFrom(other); - return this; - } - } - - public Builder mergeFrom(akka.remote.WireFormats.DeployData other) { - if (other == akka.remote.WireFormats.DeployData.getDefaultInstance()) return this; - if (other.hasPath()) { - setPath(other.getPath()); - } - if (other.hasConfig()) { - setConfig(other.getConfig()); - } - if (other.hasRouterConfig()) { - setRouterConfig(other.getRouterConfig()); - } - if (other.hasScope()) { - setScope(other.getScope()); - } - if (other.hasDispatcher()) { - setDispatcher(other.getDispatcher()); - } - this.mergeUnknownFields(other.getUnknownFields()); - return this; - } - - public final boolean isInitialized() { - if (!hasPath()) { - - 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; - path_ = input.readBytes(); - break; - } - case 18: { - bitField0_ |= 0x00000002; - config_ = input.readBytes(); - break; - } - case 26: { - bitField0_ |= 0x00000004; - routerConfig_ = input.readBytes(); - break; - } - case 34: { - bitField0_ |= 0x00000008; - scope_ = input.readBytes(); - break; - } - case 42: { - bitField0_ |= 0x00000010; - dispatcher_ = input.readBytes(); - break; - } - } - } - } - - private int bitField0_; - - // required string path = 1; - private java.lang.Object path_ = ""; - public boolean hasPath() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public String getPath() { - java.lang.Object ref = path_; - if (!(ref instanceof String)) { - String s = ((com.google.protobuf.ByteString) ref).toStringUtf8(); - path_ = s; - return s; - } else { - return (String) ref; - } - } - public Builder setPath(String value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000001; - path_ = value; - onChanged(); - return this; - } - public Builder clearPath() { - bitField0_ = (bitField0_ & ~0x00000001); - path_ = getDefaultInstance().getPath(); - onChanged(); - return this; - } - void setPath(com.google.protobuf.ByteString value) { - bitField0_ |= 0x00000001; - path_ = value; - onChanged(); - } - - // optional bytes config = 2; - private com.google.protobuf.ByteString config_ = com.google.protobuf.ByteString.EMPTY; - public boolean hasConfig() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public com.google.protobuf.ByteString getConfig() { - return config_; - } - public Builder setConfig(com.google.protobuf.ByteString value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000002; - config_ = value; - onChanged(); - return this; - } - public Builder clearConfig() { - bitField0_ = (bitField0_ & ~0x00000002); - config_ = getDefaultInstance().getConfig(); - onChanged(); - return this; - } - - // optional bytes routerConfig = 3; - private com.google.protobuf.ByteString routerConfig_ = com.google.protobuf.ByteString.EMPTY; - public boolean hasRouterConfig() { - return ((bitField0_ & 0x00000004) == 0x00000004); - } - public com.google.protobuf.ByteString getRouterConfig() { - return routerConfig_; - } - public Builder setRouterConfig(com.google.protobuf.ByteString value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000004; - routerConfig_ = value; - onChanged(); - return this; - } - public Builder clearRouterConfig() { - bitField0_ = (bitField0_ & ~0x00000004); - routerConfig_ = getDefaultInstance().getRouterConfig(); - onChanged(); - return this; - } - - // optional bytes scope = 4; - private com.google.protobuf.ByteString scope_ = com.google.protobuf.ByteString.EMPTY; - public boolean hasScope() { - return ((bitField0_ & 0x00000008) == 0x00000008); - } - public com.google.protobuf.ByteString getScope() { - return scope_; - } - public Builder setScope(com.google.protobuf.ByteString value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000008; - scope_ = value; - onChanged(); - return this; - } - public Builder clearScope() { - bitField0_ = (bitField0_ & ~0x00000008); - scope_ = getDefaultInstance().getScope(); - onChanged(); - return this; - } - - // optional string dispatcher = 5; - private java.lang.Object dispatcher_ = ""; - public boolean hasDispatcher() { - return ((bitField0_ & 0x00000010) == 0x00000010); - } - public String getDispatcher() { - java.lang.Object ref = dispatcher_; - if (!(ref instanceof String)) { - String s = ((com.google.protobuf.ByteString) ref).toStringUtf8(); - dispatcher_ = s; - return s; - } else { - return (String) ref; - } - } - public Builder setDispatcher(String value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000010; - dispatcher_ = value; - onChanged(); - return this; - } - public Builder clearDispatcher() { - bitField0_ = (bitField0_ & ~0x00000010); - dispatcher_ = getDefaultInstance().getDispatcher(); - onChanged(); - return this; - } - void setDispatcher(com.google.protobuf.ByteString value) { - bitField0_ |= 0x00000010; - dispatcher_ = value; - onChanged(); - } - - // @@protoc_insertion_point(builder_scope:DeployData) - } - - static { - defaultInstance = new DeployData(true); - defaultInstance.initFields(); - } - - // @@protoc_insertion_point(class_scope:DeployData) - } - - public interface AkkaProtocolMessageOrBuilder - extends com.google.protobuf.MessageOrBuilder { - - // optional bytes payload = 1; - boolean hasPayload(); - com.google.protobuf.ByteString getPayload(); - - // optional .AkkaControlMessage instruction = 2; - boolean hasInstruction(); - akka.remote.WireFormats.AkkaControlMessage getInstruction(); - akka.remote.WireFormats.AkkaControlMessageOrBuilder getInstructionOrBuilder(); - } - public static final class AkkaProtocolMessage extends - com.google.protobuf.GeneratedMessage - implements AkkaProtocolMessageOrBuilder { - // Use AkkaProtocolMessage.newBuilder() to construct. - private AkkaProtocolMessage(Builder builder) { - super(builder); - } - private AkkaProtocolMessage(boolean noInit) {} - - private static final AkkaProtocolMessage defaultInstance; - public static AkkaProtocolMessage getDefaultInstance() { - return defaultInstance; - } - - public AkkaProtocolMessage getDefaultInstanceForType() { - return defaultInstance; - } - - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return akka.remote.WireFormats.internal_static_AkkaProtocolMessage_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return akka.remote.WireFormats.internal_static_AkkaProtocolMessage_fieldAccessorTable; - } - - private int bitField0_; - // optional bytes payload = 1; - public static final int PAYLOAD_FIELD_NUMBER = 1; - private com.google.protobuf.ByteString payload_; - public boolean hasPayload() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public com.google.protobuf.ByteString getPayload() { - return payload_; - } - - // optional .AkkaControlMessage instruction = 2; - public static final int INSTRUCTION_FIELD_NUMBER = 2; - private akka.remote.WireFormats.AkkaControlMessage instruction_; - public boolean hasInstruction() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public akka.remote.WireFormats.AkkaControlMessage getInstruction() { - return instruction_; - } - public akka.remote.WireFormats.AkkaControlMessageOrBuilder getInstructionOrBuilder() { - return instruction_; - } - - private void initFields() { - payload_ = com.google.protobuf.ByteString.EMPTY; - instruction_ = akka.remote.WireFormats.AkkaControlMessage.getDefaultInstance(); - } - private byte memoizedIsInitialized = -1; - public final boolean isInitialized() { - byte isInitialized = memoizedIsInitialized; - if (isInitialized != -1) return isInitialized == 1; - - if (hasInstruction()) { - if (!getInstruction().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, payload_); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - output.writeMessage(2, instruction_); - } - 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, payload_); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - size += com.google.protobuf.CodedOutputStream - .computeMessageSize(2, instruction_); - } - 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 akka.remote.WireFormats.AkkaProtocolMessage parseFrom( - com.google.protobuf.ByteString data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static akka.remote.WireFormats.AkkaProtocolMessage parseFrom( - com.google.protobuf.ByteString data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.AkkaProtocolMessage parseFrom(byte[] data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static akka.remote.WireFormats.AkkaProtocolMessage parseFrom( - byte[] data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.AkkaProtocolMessage parseFrom(java.io.InputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static akka.remote.WireFormats.AkkaProtocolMessage parseFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return newBuilder().mergeFrom(input, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.AkkaProtocolMessage parseDelimitedFrom(java.io.InputStream input) - throws java.io.IOException { - Builder builder = newBuilder(); - if (builder.mergeDelimitedFrom(input)) { - return builder.buildParsed(); - } else { - return null; - } - } - public static akka.remote.WireFormats.AkkaProtocolMessage 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 akka.remote.WireFormats.AkkaProtocolMessage parseFrom( - com.google.protobuf.CodedInputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static akka.remote.WireFormats.AkkaProtocolMessage 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(akka.remote.WireFormats.AkkaProtocolMessage 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 akka.remote.WireFormats.AkkaProtocolMessageOrBuilder { - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return akka.remote.WireFormats.internal_static_AkkaProtocolMessage_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return akka.remote.WireFormats.internal_static_AkkaProtocolMessage_fieldAccessorTable; - } - - // Construct using akka.remote.WireFormats.AkkaProtocolMessage.newBuilder() - private Builder() { - maybeForceBuilderInitialization(); - } - - private Builder(BuilderParent parent) { - super(parent); - maybeForceBuilderInitialization(); - } - private void maybeForceBuilderInitialization() { - if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { - getInstructionFieldBuilder(); - } - } - private static Builder create() { - return new Builder(); - } - - public Builder clear() { - super.clear(); - payload_ = com.google.protobuf.ByteString.EMPTY; - bitField0_ = (bitField0_ & ~0x00000001); - if (instructionBuilder_ == null) { - instruction_ = akka.remote.WireFormats.AkkaControlMessage.getDefaultInstance(); - } else { - instructionBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000002); - return this; - } - - public Builder clone() { - return create().mergeFrom(buildPartial()); - } - - public com.google.protobuf.Descriptors.Descriptor - getDescriptorForType() { - return akka.remote.WireFormats.AkkaProtocolMessage.getDescriptor(); - } - - public akka.remote.WireFormats.AkkaProtocolMessage getDefaultInstanceForType() { - return akka.remote.WireFormats.AkkaProtocolMessage.getDefaultInstance(); - } - - public akka.remote.WireFormats.AkkaProtocolMessage build() { - akka.remote.WireFormats.AkkaProtocolMessage result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException(result); - } - return result; - } - - private akka.remote.WireFormats.AkkaProtocolMessage buildParsed() - throws com.google.protobuf.InvalidProtocolBufferException { - akka.remote.WireFormats.AkkaProtocolMessage result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException( - result).asInvalidProtocolBufferException(); - } - return result; - } - - public akka.remote.WireFormats.AkkaProtocolMessage buildPartial() { - akka.remote.WireFormats.AkkaProtocolMessage result = new akka.remote.WireFormats.AkkaProtocolMessage(this); - int from_bitField0_ = bitField0_; - int to_bitField0_ = 0; - if (((from_bitField0_ & 0x00000001) == 0x00000001)) { - to_bitField0_ |= 0x00000001; - } - result.payload_ = payload_; - if (((from_bitField0_ & 0x00000002) == 0x00000002)) { - to_bitField0_ |= 0x00000002; - } - if (instructionBuilder_ == null) { - result.instruction_ = instruction_; - } else { - result.instruction_ = instructionBuilder_.build(); - } - result.bitField0_ = to_bitField0_; - onBuilt(); - return result; - } - - public Builder mergeFrom(com.google.protobuf.Message other) { - if (other instanceof akka.remote.WireFormats.AkkaProtocolMessage) { - return mergeFrom((akka.remote.WireFormats.AkkaProtocolMessage)other); - } else { - super.mergeFrom(other); - return this; - } - } - - public Builder mergeFrom(akka.remote.WireFormats.AkkaProtocolMessage other) { - if (other == akka.remote.WireFormats.AkkaProtocolMessage.getDefaultInstance()) return this; - if (other.hasPayload()) { - setPayload(other.getPayload()); - } - if (other.hasInstruction()) { - mergeInstruction(other.getInstruction()); - } - this.mergeUnknownFields(other.getUnknownFields()); - return this; - } - - public final boolean isInitialized() { - if (hasInstruction()) { - if (!getInstruction().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; - payload_ = input.readBytes(); - break; - } - case 18: { - akka.remote.WireFormats.AkkaControlMessage.Builder subBuilder = akka.remote.WireFormats.AkkaControlMessage.newBuilder(); - if (hasInstruction()) { - subBuilder.mergeFrom(getInstruction()); - } - input.readMessage(subBuilder, extensionRegistry); - setInstruction(subBuilder.buildPartial()); - break; - } - } - } - } - - private int bitField0_; - - // optional bytes payload = 1; - private com.google.protobuf.ByteString payload_ = com.google.protobuf.ByteString.EMPTY; - public boolean hasPayload() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public com.google.protobuf.ByteString getPayload() { - return payload_; - } - public Builder setPayload(com.google.protobuf.ByteString value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000001; - payload_ = value; - onChanged(); - return this; - } - public Builder clearPayload() { - bitField0_ = (bitField0_ & ~0x00000001); - payload_ = getDefaultInstance().getPayload(); - onChanged(); - return this; - } - - // optional .AkkaControlMessage instruction = 2; - private akka.remote.WireFormats.AkkaControlMessage instruction_ = akka.remote.WireFormats.AkkaControlMessage.getDefaultInstance(); - private com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.AkkaControlMessage, akka.remote.WireFormats.AkkaControlMessage.Builder, akka.remote.WireFormats.AkkaControlMessageOrBuilder> instructionBuilder_; - public boolean hasInstruction() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public akka.remote.WireFormats.AkkaControlMessage getInstruction() { - if (instructionBuilder_ == null) { - return instruction_; - } else { - return instructionBuilder_.getMessage(); - } - } - public Builder setInstruction(akka.remote.WireFormats.AkkaControlMessage value) { - if (instructionBuilder_ == null) { - if (value == null) { - throw new NullPointerException(); - } - instruction_ = value; - onChanged(); - } else { - instructionBuilder_.setMessage(value); - } - bitField0_ |= 0x00000002; - return this; - } - public Builder setInstruction( - akka.remote.WireFormats.AkkaControlMessage.Builder builderForValue) { - if (instructionBuilder_ == null) { - instruction_ = builderForValue.build(); - onChanged(); - } else { - instructionBuilder_.setMessage(builderForValue.build()); - } - bitField0_ |= 0x00000002; - return this; - } - public Builder mergeInstruction(akka.remote.WireFormats.AkkaControlMessage value) { - if (instructionBuilder_ == null) { - if (((bitField0_ & 0x00000002) == 0x00000002) && - instruction_ != akka.remote.WireFormats.AkkaControlMessage.getDefaultInstance()) { - instruction_ = - akka.remote.WireFormats.AkkaControlMessage.newBuilder(instruction_).mergeFrom(value).buildPartial(); - } else { - instruction_ = value; - } - onChanged(); - } else { - instructionBuilder_.mergeFrom(value); - } - bitField0_ |= 0x00000002; - return this; - } - public Builder clearInstruction() { - if (instructionBuilder_ == null) { - instruction_ = akka.remote.WireFormats.AkkaControlMessage.getDefaultInstance(); - onChanged(); - } else { - instructionBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000002); - return this; - } - public akka.remote.WireFormats.AkkaControlMessage.Builder getInstructionBuilder() { - bitField0_ |= 0x00000002; - onChanged(); - return getInstructionFieldBuilder().getBuilder(); - } - public akka.remote.WireFormats.AkkaControlMessageOrBuilder getInstructionOrBuilder() { - if (instructionBuilder_ != null) { - return instructionBuilder_.getMessageOrBuilder(); - } else { - return instruction_; - } - } - private com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.AkkaControlMessage, akka.remote.WireFormats.AkkaControlMessage.Builder, akka.remote.WireFormats.AkkaControlMessageOrBuilder> - getInstructionFieldBuilder() { - if (instructionBuilder_ == null) { - instructionBuilder_ = new com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.AkkaControlMessage, akka.remote.WireFormats.AkkaControlMessage.Builder, akka.remote.WireFormats.AkkaControlMessageOrBuilder>( - instruction_, - getParentForChildren(), - isClean()); - instruction_ = null; - } - return instructionBuilder_; - } - - // @@protoc_insertion_point(builder_scope:AkkaProtocolMessage) - } - - static { - defaultInstance = new AkkaProtocolMessage(true); - defaultInstance.initFields(); - } - - // @@protoc_insertion_point(class_scope:AkkaProtocolMessage) - } - - public interface AkkaControlMessageOrBuilder - extends com.google.protobuf.MessageOrBuilder { - - // required .CommandType commandType = 1; - boolean hasCommandType(); - akka.remote.WireFormats.CommandType getCommandType(); - - // optional .AkkaHandshakeInfo handshakeInfo = 2; - boolean hasHandshakeInfo(); - akka.remote.WireFormats.AkkaHandshakeInfo getHandshakeInfo(); - akka.remote.WireFormats.AkkaHandshakeInfoOrBuilder getHandshakeInfoOrBuilder(); - } - public static final class AkkaControlMessage extends - com.google.protobuf.GeneratedMessage - implements AkkaControlMessageOrBuilder { - // Use AkkaControlMessage.newBuilder() to construct. - private AkkaControlMessage(Builder builder) { - super(builder); - } - private AkkaControlMessage(boolean noInit) {} - - private static final AkkaControlMessage defaultInstance; - public static AkkaControlMessage getDefaultInstance() { - return defaultInstance; - } - - public AkkaControlMessage getDefaultInstanceForType() { - return defaultInstance; - } - - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return akka.remote.WireFormats.internal_static_AkkaControlMessage_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return akka.remote.WireFormats.internal_static_AkkaControlMessage_fieldAccessorTable; - } - - private int bitField0_; - // required .CommandType commandType = 1; - public static final int COMMANDTYPE_FIELD_NUMBER = 1; - private akka.remote.WireFormats.CommandType commandType_; - public boolean hasCommandType() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public akka.remote.WireFormats.CommandType getCommandType() { - return commandType_; - } - - // optional .AkkaHandshakeInfo handshakeInfo = 2; - public static final int HANDSHAKEINFO_FIELD_NUMBER = 2; - private akka.remote.WireFormats.AkkaHandshakeInfo handshakeInfo_; - public boolean hasHandshakeInfo() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public akka.remote.WireFormats.AkkaHandshakeInfo getHandshakeInfo() { - return handshakeInfo_; - } - public akka.remote.WireFormats.AkkaHandshakeInfoOrBuilder getHandshakeInfoOrBuilder() { - return handshakeInfo_; - } - - private void initFields() { - commandType_ = akka.remote.WireFormats.CommandType.ASSOCIATE; - handshakeInfo_ = akka.remote.WireFormats.AkkaHandshakeInfo.getDefaultInstance(); - } - private byte memoizedIsInitialized = -1; - public final boolean isInitialized() { - byte isInitialized = memoizedIsInitialized; - if (isInitialized != -1) return isInitialized == 1; - - if (!hasCommandType()) { - memoizedIsInitialized = 0; - return false; - } - if (hasHandshakeInfo()) { - if (!getHandshakeInfo().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.writeEnum(1, commandType_.getNumber()); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - output.writeMessage(2, handshakeInfo_); - } - 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 - .computeEnumSize(1, commandType_.getNumber()); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - size += com.google.protobuf.CodedOutputStream - .computeMessageSize(2, handshakeInfo_); - } - 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 akka.remote.WireFormats.AkkaControlMessage parseFrom( - com.google.protobuf.ByteString data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static akka.remote.WireFormats.AkkaControlMessage parseFrom( - com.google.protobuf.ByteString data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.AkkaControlMessage parseFrom(byte[] data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static akka.remote.WireFormats.AkkaControlMessage parseFrom( - byte[] data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.AkkaControlMessage parseFrom(java.io.InputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static akka.remote.WireFormats.AkkaControlMessage parseFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return newBuilder().mergeFrom(input, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.AkkaControlMessage parseDelimitedFrom(java.io.InputStream input) - throws java.io.IOException { - Builder builder = newBuilder(); - if (builder.mergeDelimitedFrom(input)) { - return builder.buildParsed(); - } else { - return null; - } - } - public static akka.remote.WireFormats.AkkaControlMessage 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 akka.remote.WireFormats.AkkaControlMessage parseFrom( - com.google.protobuf.CodedInputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static akka.remote.WireFormats.AkkaControlMessage 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(akka.remote.WireFormats.AkkaControlMessage 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 akka.remote.WireFormats.AkkaControlMessageOrBuilder { - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return akka.remote.WireFormats.internal_static_AkkaControlMessage_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return akka.remote.WireFormats.internal_static_AkkaControlMessage_fieldAccessorTable; - } - - // Construct using akka.remote.WireFormats.AkkaControlMessage.newBuilder() - private Builder() { - maybeForceBuilderInitialization(); - } - - private Builder(BuilderParent parent) { - super(parent); - maybeForceBuilderInitialization(); - } - private void maybeForceBuilderInitialization() { - if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { - getHandshakeInfoFieldBuilder(); - } - } - private static Builder create() { - return new Builder(); - } - - public Builder clear() { - super.clear(); - commandType_ = akka.remote.WireFormats.CommandType.ASSOCIATE; - bitField0_ = (bitField0_ & ~0x00000001); - if (handshakeInfoBuilder_ == null) { - handshakeInfo_ = akka.remote.WireFormats.AkkaHandshakeInfo.getDefaultInstance(); - } else { - handshakeInfoBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000002); - return this; - } - - public Builder clone() { - return create().mergeFrom(buildPartial()); - } - - public com.google.protobuf.Descriptors.Descriptor - getDescriptorForType() { - return akka.remote.WireFormats.AkkaControlMessage.getDescriptor(); - } - - public akka.remote.WireFormats.AkkaControlMessage getDefaultInstanceForType() { - return akka.remote.WireFormats.AkkaControlMessage.getDefaultInstance(); - } - - public akka.remote.WireFormats.AkkaControlMessage build() { - akka.remote.WireFormats.AkkaControlMessage result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException(result); - } - return result; - } - - private akka.remote.WireFormats.AkkaControlMessage buildParsed() - throws com.google.protobuf.InvalidProtocolBufferException { - akka.remote.WireFormats.AkkaControlMessage result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException( - result).asInvalidProtocolBufferException(); - } - return result; - } - - public akka.remote.WireFormats.AkkaControlMessage buildPartial() { - akka.remote.WireFormats.AkkaControlMessage result = new akka.remote.WireFormats.AkkaControlMessage(this); - int from_bitField0_ = bitField0_; - int to_bitField0_ = 0; - if (((from_bitField0_ & 0x00000001) == 0x00000001)) { - to_bitField0_ |= 0x00000001; - } - result.commandType_ = commandType_; - if (((from_bitField0_ & 0x00000002) == 0x00000002)) { - to_bitField0_ |= 0x00000002; - } - if (handshakeInfoBuilder_ == null) { - result.handshakeInfo_ = handshakeInfo_; - } else { - result.handshakeInfo_ = handshakeInfoBuilder_.build(); - } - result.bitField0_ = to_bitField0_; - onBuilt(); - return result; - } - - public Builder mergeFrom(com.google.protobuf.Message other) { - if (other instanceof akka.remote.WireFormats.AkkaControlMessage) { - return mergeFrom((akka.remote.WireFormats.AkkaControlMessage)other); - } else { - super.mergeFrom(other); - return this; - } - } - - public Builder mergeFrom(akka.remote.WireFormats.AkkaControlMessage other) { - if (other == akka.remote.WireFormats.AkkaControlMessage.getDefaultInstance()) return this; - if (other.hasCommandType()) { - setCommandType(other.getCommandType()); - } - if (other.hasHandshakeInfo()) { - mergeHandshakeInfo(other.getHandshakeInfo()); - } - this.mergeUnknownFields(other.getUnknownFields()); - return this; - } - - public final boolean isInitialized() { - if (!hasCommandType()) { - - return false; - } - if (hasHandshakeInfo()) { - if (!getHandshakeInfo().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 8: { - int rawValue = input.readEnum(); - akka.remote.WireFormats.CommandType value = akka.remote.WireFormats.CommandType.valueOf(rawValue); - if (value == null) { - unknownFields.mergeVarintField(1, rawValue); - } else { - bitField0_ |= 0x00000001; - commandType_ = value; - } - break; - } - case 18: { - akka.remote.WireFormats.AkkaHandshakeInfo.Builder subBuilder = akka.remote.WireFormats.AkkaHandshakeInfo.newBuilder(); - if (hasHandshakeInfo()) { - subBuilder.mergeFrom(getHandshakeInfo()); - } - input.readMessage(subBuilder, extensionRegistry); - setHandshakeInfo(subBuilder.buildPartial()); - break; - } - } - } - } - - private int bitField0_; - - // required .CommandType commandType = 1; - private akka.remote.WireFormats.CommandType commandType_ = akka.remote.WireFormats.CommandType.ASSOCIATE; - public boolean hasCommandType() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public akka.remote.WireFormats.CommandType getCommandType() { - return commandType_; - } - public Builder setCommandType(akka.remote.WireFormats.CommandType value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000001; - commandType_ = value; - onChanged(); - return this; - } - public Builder clearCommandType() { - bitField0_ = (bitField0_ & ~0x00000001); - commandType_ = akka.remote.WireFormats.CommandType.ASSOCIATE; - onChanged(); - return this; - } - - // optional .AkkaHandshakeInfo handshakeInfo = 2; - private akka.remote.WireFormats.AkkaHandshakeInfo handshakeInfo_ = akka.remote.WireFormats.AkkaHandshakeInfo.getDefaultInstance(); - private com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.AkkaHandshakeInfo, akka.remote.WireFormats.AkkaHandshakeInfo.Builder, akka.remote.WireFormats.AkkaHandshakeInfoOrBuilder> handshakeInfoBuilder_; - public boolean hasHandshakeInfo() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public akka.remote.WireFormats.AkkaHandshakeInfo getHandshakeInfo() { - if (handshakeInfoBuilder_ == null) { - return handshakeInfo_; - } else { - return handshakeInfoBuilder_.getMessage(); - } - } - public Builder setHandshakeInfo(akka.remote.WireFormats.AkkaHandshakeInfo value) { - if (handshakeInfoBuilder_ == null) { - if (value == null) { - throw new NullPointerException(); - } - handshakeInfo_ = value; - onChanged(); - } else { - handshakeInfoBuilder_.setMessage(value); - } - bitField0_ |= 0x00000002; - return this; - } - public Builder setHandshakeInfo( - akka.remote.WireFormats.AkkaHandshakeInfo.Builder builderForValue) { - if (handshakeInfoBuilder_ == null) { - handshakeInfo_ = builderForValue.build(); - onChanged(); - } else { - handshakeInfoBuilder_.setMessage(builderForValue.build()); - } - bitField0_ |= 0x00000002; - return this; - } - public Builder mergeHandshakeInfo(akka.remote.WireFormats.AkkaHandshakeInfo value) { - if (handshakeInfoBuilder_ == null) { - if (((bitField0_ & 0x00000002) == 0x00000002) && - handshakeInfo_ != akka.remote.WireFormats.AkkaHandshakeInfo.getDefaultInstance()) { - handshakeInfo_ = - akka.remote.WireFormats.AkkaHandshakeInfo.newBuilder(handshakeInfo_).mergeFrom(value).buildPartial(); - } else { - handshakeInfo_ = value; - } - onChanged(); - } else { - handshakeInfoBuilder_.mergeFrom(value); - } - bitField0_ |= 0x00000002; - return this; - } - public Builder clearHandshakeInfo() { - if (handshakeInfoBuilder_ == null) { - handshakeInfo_ = akka.remote.WireFormats.AkkaHandshakeInfo.getDefaultInstance(); - onChanged(); - } else { - handshakeInfoBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000002); - return this; - } - public akka.remote.WireFormats.AkkaHandshakeInfo.Builder getHandshakeInfoBuilder() { - bitField0_ |= 0x00000002; - onChanged(); - return getHandshakeInfoFieldBuilder().getBuilder(); - } - public akka.remote.WireFormats.AkkaHandshakeInfoOrBuilder getHandshakeInfoOrBuilder() { - if (handshakeInfoBuilder_ != null) { - return handshakeInfoBuilder_.getMessageOrBuilder(); - } else { - return handshakeInfo_; - } - } - private com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.AkkaHandshakeInfo, akka.remote.WireFormats.AkkaHandshakeInfo.Builder, akka.remote.WireFormats.AkkaHandshakeInfoOrBuilder> - getHandshakeInfoFieldBuilder() { - if (handshakeInfoBuilder_ == null) { - handshakeInfoBuilder_ = new com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.AkkaHandshakeInfo, akka.remote.WireFormats.AkkaHandshakeInfo.Builder, akka.remote.WireFormats.AkkaHandshakeInfoOrBuilder>( - handshakeInfo_, - getParentForChildren(), - isClean()); - handshakeInfo_ = null; - } - return handshakeInfoBuilder_; - } - - // @@protoc_insertion_point(builder_scope:AkkaControlMessage) - } - - static { - defaultInstance = new AkkaControlMessage(true); - defaultInstance.initFields(); - } - - // @@protoc_insertion_point(class_scope:AkkaControlMessage) - } - - public interface AkkaHandshakeInfoOrBuilder - extends com.google.protobuf.MessageOrBuilder { - - // required .AddressData origin = 1; - boolean hasOrigin(); - akka.remote.WireFormats.AddressData getOrigin(); - akka.remote.WireFormats.AddressDataOrBuilder getOriginOrBuilder(); - - // required fixed64 uid = 2; - boolean hasUid(); - long getUid(); - - // optional string cookie = 3; - boolean hasCookie(); - String getCookie(); - } - public static final class AkkaHandshakeInfo extends - com.google.protobuf.GeneratedMessage - implements AkkaHandshakeInfoOrBuilder { - // Use AkkaHandshakeInfo.newBuilder() to construct. - private AkkaHandshakeInfo(Builder builder) { - super(builder); - } - private AkkaHandshakeInfo(boolean noInit) {} - - private static final AkkaHandshakeInfo defaultInstance; - public static AkkaHandshakeInfo getDefaultInstance() { - return defaultInstance; - } - - public AkkaHandshakeInfo getDefaultInstanceForType() { - return defaultInstance; - } - - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return akka.remote.WireFormats.internal_static_AkkaHandshakeInfo_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return akka.remote.WireFormats.internal_static_AkkaHandshakeInfo_fieldAccessorTable; - } - - private int bitField0_; - // required .AddressData origin = 1; - public static final int ORIGIN_FIELD_NUMBER = 1; - private akka.remote.WireFormats.AddressData origin_; - public boolean hasOrigin() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public akka.remote.WireFormats.AddressData getOrigin() { - return origin_; - } - public akka.remote.WireFormats.AddressDataOrBuilder getOriginOrBuilder() { - return origin_; - } - - // required fixed64 uid = 2; - public static final int UID_FIELD_NUMBER = 2; - private long uid_; - public boolean hasUid() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public long getUid() { - return uid_; - } - - // optional string cookie = 3; - public static final int COOKIE_FIELD_NUMBER = 3; - private java.lang.Object cookie_; - public boolean hasCookie() { - return ((bitField0_ & 0x00000004) == 0x00000004); - } - public String getCookie() { - java.lang.Object ref = cookie_; - 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)) { - cookie_ = s; - } - return s; - } - } - private com.google.protobuf.ByteString getCookieBytes() { - java.lang.Object ref = cookie_; - if (ref instanceof String) { - com.google.protobuf.ByteString b = - com.google.protobuf.ByteString.copyFromUtf8((String) ref); - cookie_ = b; - return b; - } else { - return (com.google.protobuf.ByteString) ref; - } - } - - private void initFields() { - origin_ = akka.remote.WireFormats.AddressData.getDefaultInstance(); - uid_ = 0L; - cookie_ = ""; - } - private byte memoizedIsInitialized = -1; - public final boolean isInitialized() { - byte isInitialized = memoizedIsInitialized; - if (isInitialized != -1) return isInitialized == 1; - - if (!hasOrigin()) { - memoizedIsInitialized = 0; - return false; - } - if (!hasUid()) { - memoizedIsInitialized = 0; - return false; - } - if (!getOrigin().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.writeMessage(1, origin_); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - output.writeFixed64(2, uid_); - } - if (((bitField0_ & 0x00000004) == 0x00000004)) { - output.writeBytes(3, getCookieBytes()); - } - 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, origin_); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - size += com.google.protobuf.CodedOutputStream - .computeFixed64Size(2, uid_); - } - if (((bitField0_ & 0x00000004) == 0x00000004)) { - size += com.google.protobuf.CodedOutputStream - .computeBytesSize(3, getCookieBytes()); - } - 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 akka.remote.WireFormats.AkkaHandshakeInfo parseFrom( - com.google.protobuf.ByteString data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static akka.remote.WireFormats.AkkaHandshakeInfo parseFrom( - com.google.protobuf.ByteString data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.AkkaHandshakeInfo parseFrom(byte[] data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static akka.remote.WireFormats.AkkaHandshakeInfo parseFrom( - byte[] data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.AkkaHandshakeInfo parseFrom(java.io.InputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static akka.remote.WireFormats.AkkaHandshakeInfo parseFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return newBuilder().mergeFrom(input, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.AkkaHandshakeInfo parseDelimitedFrom(java.io.InputStream input) - throws java.io.IOException { - Builder builder = newBuilder(); - if (builder.mergeDelimitedFrom(input)) { - return builder.buildParsed(); - } else { - return null; - } - } - public static akka.remote.WireFormats.AkkaHandshakeInfo 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 akka.remote.WireFormats.AkkaHandshakeInfo parseFrom( - com.google.protobuf.CodedInputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static akka.remote.WireFormats.AkkaHandshakeInfo 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(akka.remote.WireFormats.AkkaHandshakeInfo 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 akka.remote.WireFormats.AkkaHandshakeInfoOrBuilder { - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return akka.remote.WireFormats.internal_static_AkkaHandshakeInfo_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return akka.remote.WireFormats.internal_static_AkkaHandshakeInfo_fieldAccessorTable; - } - - // Construct using akka.remote.WireFormats.AkkaHandshakeInfo.newBuilder() - private Builder() { - maybeForceBuilderInitialization(); - } - - private Builder(BuilderParent parent) { - super(parent); - maybeForceBuilderInitialization(); - } - private void maybeForceBuilderInitialization() { - if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { - getOriginFieldBuilder(); - } - } - private static Builder create() { - return new Builder(); - } - - public Builder clear() { - super.clear(); - if (originBuilder_ == null) { - origin_ = akka.remote.WireFormats.AddressData.getDefaultInstance(); - } else { - originBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000001); - uid_ = 0L; - bitField0_ = (bitField0_ & ~0x00000002); - cookie_ = ""; - bitField0_ = (bitField0_ & ~0x00000004); - return this; - } - - public Builder clone() { - return create().mergeFrom(buildPartial()); - } - - public com.google.protobuf.Descriptors.Descriptor - getDescriptorForType() { - return akka.remote.WireFormats.AkkaHandshakeInfo.getDescriptor(); - } - - public akka.remote.WireFormats.AkkaHandshakeInfo getDefaultInstanceForType() { - return akka.remote.WireFormats.AkkaHandshakeInfo.getDefaultInstance(); - } - - public akka.remote.WireFormats.AkkaHandshakeInfo build() { - akka.remote.WireFormats.AkkaHandshakeInfo result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException(result); - } - return result; - } - - private akka.remote.WireFormats.AkkaHandshakeInfo buildParsed() - throws com.google.protobuf.InvalidProtocolBufferException { - akka.remote.WireFormats.AkkaHandshakeInfo result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException( - result).asInvalidProtocolBufferException(); - } - return result; - } - - public akka.remote.WireFormats.AkkaHandshakeInfo buildPartial() { - akka.remote.WireFormats.AkkaHandshakeInfo result = new akka.remote.WireFormats.AkkaHandshakeInfo(this); - int from_bitField0_ = bitField0_; - int to_bitField0_ = 0; - if (((from_bitField0_ & 0x00000001) == 0x00000001)) { - to_bitField0_ |= 0x00000001; - } - if (originBuilder_ == null) { - result.origin_ = origin_; - } else { - result.origin_ = originBuilder_.build(); - } - if (((from_bitField0_ & 0x00000002) == 0x00000002)) { - to_bitField0_ |= 0x00000002; - } - result.uid_ = uid_; - if (((from_bitField0_ & 0x00000004) == 0x00000004)) { - to_bitField0_ |= 0x00000004; - } - result.cookie_ = cookie_; - result.bitField0_ = to_bitField0_; - onBuilt(); - return result; - } - - public Builder mergeFrom(com.google.protobuf.Message other) { - if (other instanceof akka.remote.WireFormats.AkkaHandshakeInfo) { - return mergeFrom((akka.remote.WireFormats.AkkaHandshakeInfo)other); - } else { - super.mergeFrom(other); - return this; - } - } - - public Builder mergeFrom(akka.remote.WireFormats.AkkaHandshakeInfo other) { - if (other == akka.remote.WireFormats.AkkaHandshakeInfo.getDefaultInstance()) return this; - if (other.hasOrigin()) { - mergeOrigin(other.getOrigin()); - } - if (other.hasUid()) { - setUid(other.getUid()); - } - if (other.hasCookie()) { - setCookie(other.getCookie()); - } - this.mergeUnknownFields(other.getUnknownFields()); - return this; - } - - public final boolean isInitialized() { - if (!hasOrigin()) { - - return false; - } - if (!hasUid()) { - - return false; - } - if (!getOrigin().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: { - akka.remote.WireFormats.AddressData.Builder subBuilder = akka.remote.WireFormats.AddressData.newBuilder(); - if (hasOrigin()) { - subBuilder.mergeFrom(getOrigin()); - } - input.readMessage(subBuilder, extensionRegistry); - setOrigin(subBuilder.buildPartial()); - break; - } - case 17: { - bitField0_ |= 0x00000002; - uid_ = input.readFixed64(); - break; - } - case 26: { - bitField0_ |= 0x00000004; - cookie_ = input.readBytes(); - break; - } - } - } - } - - private int bitField0_; - - // required .AddressData origin = 1; - private akka.remote.WireFormats.AddressData origin_ = akka.remote.WireFormats.AddressData.getDefaultInstance(); - private com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.AddressData, akka.remote.WireFormats.AddressData.Builder, akka.remote.WireFormats.AddressDataOrBuilder> originBuilder_; - public boolean hasOrigin() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public akka.remote.WireFormats.AddressData getOrigin() { - if (originBuilder_ == null) { - return origin_; - } else { - return originBuilder_.getMessage(); - } - } - public Builder setOrigin(akka.remote.WireFormats.AddressData value) { - if (originBuilder_ == null) { - if (value == null) { - throw new NullPointerException(); - } - origin_ = value; - onChanged(); - } else { - originBuilder_.setMessage(value); - } - bitField0_ |= 0x00000001; - return this; - } - public Builder setOrigin( - akka.remote.WireFormats.AddressData.Builder builderForValue) { - if (originBuilder_ == null) { - origin_ = builderForValue.build(); - onChanged(); - } else { - originBuilder_.setMessage(builderForValue.build()); - } - bitField0_ |= 0x00000001; - return this; - } - public Builder mergeOrigin(akka.remote.WireFormats.AddressData value) { - if (originBuilder_ == null) { - if (((bitField0_ & 0x00000001) == 0x00000001) && - origin_ != akka.remote.WireFormats.AddressData.getDefaultInstance()) { - origin_ = - akka.remote.WireFormats.AddressData.newBuilder(origin_).mergeFrom(value).buildPartial(); - } else { - origin_ = value; - } - onChanged(); - } else { - originBuilder_.mergeFrom(value); - } - bitField0_ |= 0x00000001; - return this; - } - public Builder clearOrigin() { - if (originBuilder_ == null) { - origin_ = akka.remote.WireFormats.AddressData.getDefaultInstance(); - onChanged(); - } else { - originBuilder_.clear(); - } - bitField0_ = (bitField0_ & ~0x00000001); - return this; - } - public akka.remote.WireFormats.AddressData.Builder getOriginBuilder() { - bitField0_ |= 0x00000001; - onChanged(); - return getOriginFieldBuilder().getBuilder(); - } - public akka.remote.WireFormats.AddressDataOrBuilder getOriginOrBuilder() { - if (originBuilder_ != null) { - return originBuilder_.getMessageOrBuilder(); - } else { - return origin_; - } - } - private com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.AddressData, akka.remote.WireFormats.AddressData.Builder, akka.remote.WireFormats.AddressDataOrBuilder> - getOriginFieldBuilder() { - if (originBuilder_ == null) { - originBuilder_ = new com.google.protobuf.SingleFieldBuilder< - akka.remote.WireFormats.AddressData, akka.remote.WireFormats.AddressData.Builder, akka.remote.WireFormats.AddressDataOrBuilder>( - origin_, - getParentForChildren(), - isClean()); - origin_ = null; - } - return originBuilder_; - } - - // required fixed64 uid = 2; - private long uid_ ; - public boolean hasUid() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public long getUid() { - return uid_; - } - public Builder setUid(long value) { - bitField0_ |= 0x00000002; - uid_ = value; - onChanged(); - return this; - } - public Builder clearUid() { - bitField0_ = (bitField0_ & ~0x00000002); - uid_ = 0L; - onChanged(); - return this; - } - - // optional string cookie = 3; - private java.lang.Object cookie_ = ""; - public boolean hasCookie() { - return ((bitField0_ & 0x00000004) == 0x00000004); - } - public String getCookie() { - java.lang.Object ref = cookie_; - if (!(ref instanceof String)) { - String s = ((com.google.protobuf.ByteString) ref).toStringUtf8(); - cookie_ = s; - return s; - } else { - return (String) ref; - } - } - public Builder setCookie(String value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000004; - cookie_ = value; - onChanged(); - return this; - } - public Builder clearCookie() { - bitField0_ = (bitField0_ & ~0x00000004); - cookie_ = getDefaultInstance().getCookie(); - onChanged(); - return this; - } - void setCookie(com.google.protobuf.ByteString value) { - bitField0_ |= 0x00000004; - cookie_ = value; - onChanged(); - } - - // @@protoc_insertion_point(builder_scope:AkkaHandshakeInfo) - } - - static { - defaultInstance = new AkkaHandshakeInfo(true); - defaultInstance.initFields(); - } - - // @@protoc_insertion_point(class_scope:AkkaHandshakeInfo) - } - - public interface AddressDataOrBuilder - extends com.google.protobuf.MessageOrBuilder { - - // required string system = 1; - boolean hasSystem(); - String getSystem(); - - // required string hostname = 2; - boolean hasHostname(); - String getHostname(); - - // required uint32 port = 3; - boolean hasPort(); - int getPort(); - - // optional string protocol = 4; - boolean hasProtocol(); - String getProtocol(); - } - public static final class AddressData extends - com.google.protobuf.GeneratedMessage - implements AddressDataOrBuilder { - // Use AddressData.newBuilder() to construct. - private AddressData(Builder builder) { - super(builder); - } - private AddressData(boolean noInit) {} - - private static final AddressData defaultInstance; - public static AddressData getDefaultInstance() { - return defaultInstance; - } - - public AddressData getDefaultInstanceForType() { - return defaultInstance; - } - - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return akka.remote.WireFormats.internal_static_AddressData_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return akka.remote.WireFormats.internal_static_AddressData_fieldAccessorTable; - } - - private int bitField0_; - // required string system = 1; - public static final int SYSTEM_FIELD_NUMBER = 1; - private java.lang.Object system_; - public boolean hasSystem() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public String getSystem() { - java.lang.Object ref = system_; - 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)) { - system_ = s; - } - return s; - } - } - private com.google.protobuf.ByteString getSystemBytes() { - java.lang.Object ref = system_; - if (ref instanceof String) { - com.google.protobuf.ByteString b = - com.google.protobuf.ByteString.copyFromUtf8((String) ref); - system_ = b; - return b; - } else { - return (com.google.protobuf.ByteString) ref; - } - } - - // required string hostname = 2; - public static final int HOSTNAME_FIELD_NUMBER = 2; - private java.lang.Object hostname_; - public boolean hasHostname() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public String getHostname() { - java.lang.Object ref = hostname_; - 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)) { - hostname_ = s; - } - return s; - } - } - private com.google.protobuf.ByteString getHostnameBytes() { - java.lang.Object ref = hostname_; - if (ref instanceof String) { - com.google.protobuf.ByteString b = - com.google.protobuf.ByteString.copyFromUtf8((String) ref); - hostname_ = b; - return b; - } else { - return (com.google.protobuf.ByteString) ref; - } - } - - // required uint32 port = 3; - public static final int PORT_FIELD_NUMBER = 3; - private int port_; - public boolean hasPort() { - return ((bitField0_ & 0x00000004) == 0x00000004); - } - public int getPort() { - return port_; - } - - // optional string protocol = 4; - public static final int PROTOCOL_FIELD_NUMBER = 4; - private java.lang.Object protocol_; - public boolean hasProtocol() { - return ((bitField0_ & 0x00000008) == 0x00000008); - } - public String getProtocol() { - java.lang.Object ref = protocol_; - 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)) { - protocol_ = s; - } - return s; - } - } - private com.google.protobuf.ByteString getProtocolBytes() { - java.lang.Object ref = protocol_; - if (ref instanceof String) { - com.google.protobuf.ByteString b = - com.google.protobuf.ByteString.copyFromUtf8((String) ref); - protocol_ = b; - return b; - } else { - return (com.google.protobuf.ByteString) ref; - } - } - - private void initFields() { - system_ = ""; - hostname_ = ""; - port_ = 0; - protocol_ = ""; - } - private byte memoizedIsInitialized = -1; - public final boolean isInitialized() { - byte isInitialized = memoizedIsInitialized; - if (isInitialized != -1) return isInitialized == 1; - - if (!hasSystem()) { - memoizedIsInitialized = 0; - return false; - } - if (!hasHostname()) { - memoizedIsInitialized = 0; - return false; - } - if (!hasPort()) { - 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, getSystemBytes()); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - output.writeBytes(2, getHostnameBytes()); - } - if (((bitField0_ & 0x00000004) == 0x00000004)) { - output.writeUInt32(3, port_); - } - if (((bitField0_ & 0x00000008) == 0x00000008)) { - output.writeBytes(4, getProtocolBytes()); - } - 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, getSystemBytes()); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - size += com.google.protobuf.CodedOutputStream - .computeBytesSize(2, getHostnameBytes()); - } - if (((bitField0_ & 0x00000004) == 0x00000004)) { - size += com.google.protobuf.CodedOutputStream - .computeUInt32Size(3, port_); - } - if (((bitField0_ & 0x00000008) == 0x00000008)) { - size += com.google.protobuf.CodedOutputStream - .computeBytesSize(4, getProtocolBytes()); - } - 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 akka.remote.WireFormats.AddressData parseFrom( - com.google.protobuf.ByteString data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static akka.remote.WireFormats.AddressData parseFrom( - com.google.protobuf.ByteString data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.AddressData parseFrom(byte[] data) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data).buildParsed(); - } - public static akka.remote.WireFormats.AddressData parseFrom( - byte[] data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return newBuilder().mergeFrom(data, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.AddressData parseFrom(java.io.InputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static akka.remote.WireFormats.AddressData parseFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return newBuilder().mergeFrom(input, extensionRegistry) - .buildParsed(); - } - public static akka.remote.WireFormats.AddressData parseDelimitedFrom(java.io.InputStream input) - throws java.io.IOException { - Builder builder = newBuilder(); - if (builder.mergeDelimitedFrom(input)) { - return builder.buildParsed(); - } else { - return null; - } - } - public static akka.remote.WireFormats.AddressData 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 akka.remote.WireFormats.AddressData parseFrom( - com.google.protobuf.CodedInputStream input) - throws java.io.IOException { - return newBuilder().mergeFrom(input).buildParsed(); - } - public static akka.remote.WireFormats.AddressData 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(akka.remote.WireFormats.AddressData 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 akka.remote.WireFormats.AddressDataOrBuilder { - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return akka.remote.WireFormats.internal_static_AddressData_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return akka.remote.WireFormats.internal_static_AddressData_fieldAccessorTable; - } - - // Construct using akka.remote.WireFormats.AddressData.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(); - system_ = ""; - bitField0_ = (bitField0_ & ~0x00000001); - hostname_ = ""; - bitField0_ = (bitField0_ & ~0x00000002); - port_ = 0; - bitField0_ = (bitField0_ & ~0x00000004); - protocol_ = ""; - bitField0_ = (bitField0_ & ~0x00000008); - return this; - } - - public Builder clone() { - return create().mergeFrom(buildPartial()); - } - - public com.google.protobuf.Descriptors.Descriptor - getDescriptorForType() { - return akka.remote.WireFormats.AddressData.getDescriptor(); - } - - public akka.remote.WireFormats.AddressData getDefaultInstanceForType() { - return akka.remote.WireFormats.AddressData.getDefaultInstance(); - } - - public akka.remote.WireFormats.AddressData build() { - akka.remote.WireFormats.AddressData result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException(result); - } - return result; - } - - private akka.remote.WireFormats.AddressData buildParsed() - throws com.google.protobuf.InvalidProtocolBufferException { - akka.remote.WireFormats.AddressData result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException( - result).asInvalidProtocolBufferException(); - } - return result; - } - - public akka.remote.WireFormats.AddressData buildPartial() { - akka.remote.WireFormats.AddressData result = new akka.remote.WireFormats.AddressData(this); - int from_bitField0_ = bitField0_; - int to_bitField0_ = 0; - if (((from_bitField0_ & 0x00000001) == 0x00000001)) { - to_bitField0_ |= 0x00000001; - } - result.system_ = system_; - if (((from_bitField0_ & 0x00000002) == 0x00000002)) { - to_bitField0_ |= 0x00000002; - } - result.hostname_ = hostname_; - if (((from_bitField0_ & 0x00000004) == 0x00000004)) { - to_bitField0_ |= 0x00000004; - } - result.port_ = port_; - if (((from_bitField0_ & 0x00000008) == 0x00000008)) { - to_bitField0_ |= 0x00000008; - } - result.protocol_ = protocol_; - result.bitField0_ = to_bitField0_; - onBuilt(); - return result; - } - - public Builder mergeFrom(com.google.protobuf.Message other) { - if (other instanceof akka.remote.WireFormats.AddressData) { - return mergeFrom((akka.remote.WireFormats.AddressData)other); - } else { - super.mergeFrom(other); - return this; - } - } - - public Builder mergeFrom(akka.remote.WireFormats.AddressData other) { - if (other == akka.remote.WireFormats.AddressData.getDefaultInstance()) return this; - if (other.hasSystem()) { - setSystem(other.getSystem()); - } - if (other.hasHostname()) { - setHostname(other.getHostname()); - } - if (other.hasPort()) { - setPort(other.getPort()); - } - if (other.hasProtocol()) { - setProtocol(other.getProtocol()); - } - this.mergeUnknownFields(other.getUnknownFields()); - return this; - } - - public final boolean isInitialized() { - if (!hasSystem()) { - - return false; - } - if (!hasHostname()) { - - return false; - } - if (!hasPort()) { - - 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; - system_ = input.readBytes(); - break; - } - case 18: { - bitField0_ |= 0x00000002; - hostname_ = input.readBytes(); - break; - } - case 24: { - bitField0_ |= 0x00000004; - port_ = input.readUInt32(); - break; - } - case 34: { - bitField0_ |= 0x00000008; - protocol_ = input.readBytes(); - break; - } - } - } - } - - private int bitField0_; - - // required string system = 1; - private java.lang.Object system_ = ""; - public boolean hasSystem() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - public String getSystem() { - java.lang.Object ref = system_; - if (!(ref instanceof String)) { - String s = ((com.google.protobuf.ByteString) ref).toStringUtf8(); - system_ = s; - return s; - } else { - return (String) ref; - } - } - public Builder setSystem(String value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000001; - system_ = value; - onChanged(); - return this; - } - public Builder clearSystem() { - bitField0_ = (bitField0_ & ~0x00000001); - system_ = getDefaultInstance().getSystem(); - onChanged(); - return this; - } - void setSystem(com.google.protobuf.ByteString value) { - bitField0_ |= 0x00000001; - system_ = value; - onChanged(); - } - - // required string hostname = 2; - private java.lang.Object hostname_ = ""; - public boolean hasHostname() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - public String getHostname() { - java.lang.Object ref = hostname_; - if (!(ref instanceof String)) { - String s = ((com.google.protobuf.ByteString) ref).toStringUtf8(); - hostname_ = s; - return s; - } else { - return (String) ref; - } - } - public Builder setHostname(String value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000002; - hostname_ = value; - onChanged(); - return this; - } - public Builder clearHostname() { - bitField0_ = (bitField0_ & ~0x00000002); - hostname_ = getDefaultInstance().getHostname(); - onChanged(); - return this; - } - void setHostname(com.google.protobuf.ByteString value) { - bitField0_ |= 0x00000002; - hostname_ = value; - onChanged(); - } - - // required uint32 port = 3; - private int port_ ; - public boolean hasPort() { - return ((bitField0_ & 0x00000004) == 0x00000004); - } - public int getPort() { - return port_; - } - public Builder setPort(int value) { - bitField0_ |= 0x00000004; - port_ = value; - onChanged(); - return this; - } - public Builder clearPort() { - bitField0_ = (bitField0_ & ~0x00000004); - port_ = 0; - onChanged(); - return this; - } - - // optional string protocol = 4; - private java.lang.Object protocol_ = ""; - public boolean hasProtocol() { - return ((bitField0_ & 0x00000008) == 0x00000008); - } - public String getProtocol() { - java.lang.Object ref = protocol_; - if (!(ref instanceof String)) { - String s = ((com.google.protobuf.ByteString) ref).toStringUtf8(); - protocol_ = s; - return s; - } else { - return (String) ref; - } - } - public Builder setProtocol(String value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000008; - protocol_ = value; - onChanged(); - return this; - } - public Builder clearProtocol() { - bitField0_ = (bitField0_ & ~0x00000008); - protocol_ = getDefaultInstance().getProtocol(); - onChanged(); - return this; - } - void setProtocol(com.google.protobuf.ByteString value) { - bitField0_ |= 0x00000008; - protocol_ = value; - onChanged(); - } - - // @@protoc_insertion_point(builder_scope:AddressData) - } - - static { - defaultInstance = new AddressData(true); - defaultInstance.initFields(); - } - - // @@protoc_insertion_point(class_scope:AddressData) - } - - private static com.google.protobuf.Descriptors.Descriptor - internal_static_AckAndEnvelopeContainer_descriptor; - private static - com.google.protobuf.GeneratedMessage.FieldAccessorTable - internal_static_AckAndEnvelopeContainer_fieldAccessorTable; - private static com.google.protobuf.Descriptors.Descriptor - internal_static_RemoteEnvelope_descriptor; - private static - com.google.protobuf.GeneratedMessage.FieldAccessorTable - internal_static_RemoteEnvelope_fieldAccessorTable; - private static com.google.protobuf.Descriptors.Descriptor - internal_static_AcknowledgementInfo_descriptor; - private static - com.google.protobuf.GeneratedMessage.FieldAccessorTable - internal_static_AcknowledgementInfo_fieldAccessorTable; - private static com.google.protobuf.Descriptors.Descriptor - internal_static_ActorRefData_descriptor; - private static - com.google.protobuf.GeneratedMessage.FieldAccessorTable - internal_static_ActorRefData_fieldAccessorTable; - private static com.google.protobuf.Descriptors.Descriptor - internal_static_SerializedMessage_descriptor; - private static - com.google.protobuf.GeneratedMessage.FieldAccessorTable - internal_static_SerializedMessage_fieldAccessorTable; - private static com.google.protobuf.Descriptors.Descriptor - internal_static_DaemonMsgCreateData_descriptor; - private static - com.google.protobuf.GeneratedMessage.FieldAccessorTable - internal_static_DaemonMsgCreateData_fieldAccessorTable; - private static com.google.protobuf.Descriptors.Descriptor - internal_static_PropsData_descriptor; - private static - com.google.protobuf.GeneratedMessage.FieldAccessorTable - internal_static_PropsData_fieldAccessorTable; - private static com.google.protobuf.Descriptors.Descriptor - internal_static_DeployData_descriptor; - private static - com.google.protobuf.GeneratedMessage.FieldAccessorTable - internal_static_DeployData_fieldAccessorTable; - private static com.google.protobuf.Descriptors.Descriptor - internal_static_AkkaProtocolMessage_descriptor; - private static - com.google.protobuf.GeneratedMessage.FieldAccessorTable - internal_static_AkkaProtocolMessage_fieldAccessorTable; - private static com.google.protobuf.Descriptors.Descriptor - internal_static_AkkaControlMessage_descriptor; - private static - com.google.protobuf.GeneratedMessage.FieldAccessorTable - internal_static_AkkaControlMessage_fieldAccessorTable; - private static com.google.protobuf.Descriptors.Descriptor - internal_static_AkkaHandshakeInfo_descriptor; - private static - com.google.protobuf.GeneratedMessage.FieldAccessorTable - internal_static_AkkaHandshakeInfo_fieldAccessorTable; - private static com.google.protobuf.Descriptors.Descriptor - internal_static_AddressData_descriptor; - private static - com.google.protobuf.GeneratedMessage.FieldAccessorTable - internal_static_AddressData_fieldAccessorTable; - - public static com.google.protobuf.Descriptors.FileDescriptor - getDescriptor() { - return descriptor; - } - private static com.google.protobuf.Descriptors.FileDescriptor - descriptor; - static { - java.lang.String[] descriptorData = { - "\n\021WireFormats.proto\"_\n\027AckAndEnvelopeCon" + - "tainer\022!\n\003ack\030\001 \001(\0132\024.AcknowledgementInf" + - "o\022!\n\010envelope\030\002 \001(\0132\017.RemoteEnvelope\"\203\001\n" + - "\016RemoteEnvelope\022 \n\trecipient\030\001 \002(\0132\r.Act" + - "orRefData\022#\n\007message\030\002 \002(\0132\022.SerializedM" + - "essage\022\035\n\006sender\030\004 \001(\0132\r.ActorRefData\022\013\n" + - "\003seq\030\005 \001(\006\";\n\023AcknowledgementInfo\022\025\n\rcum" + - "ulativeAck\030\001 \002(\006\022\r\n\005nacks\030\002 \003(\006\"\034\n\014Actor" + - "RefData\022\014\n\004path\030\001 \002(\t\"S\n\021SerializedMessa" + - "ge\022\017\n\007message\030\001 \002(\014\022\024\n\014serializerId\030\002 \002(", - "\005\022\027\n\017messageManifest\030\003 \001(\014\"~\n\023DaemonMsgC" + - "reateData\022\031\n\005props\030\001 \002(\0132\n.PropsData\022\033\n\006" + - "deploy\030\002 \002(\0132\013.DeployData\022\014\n\004path\030\003 \002(\t\022" + - "!\n\nsupervisor\030\004 \002(\0132\r.ActorRefData\"V\n\tPr" + - "opsData\022\033\n\006deploy\030\002 \002(\0132\013.DeployData\022\r\n\005" + - "clazz\030\003 \002(\t\022\014\n\004args\030\004 \003(\014\022\017\n\007classes\030\005 \003" + - "(\t\"c\n\nDeployData\022\014\n\004path\030\001 \002(\t\022\016\n\006config" + - "\030\002 \001(\014\022\024\n\014routerConfig\030\003 \001(\014\022\r\n\005scope\030\004 " + - "\001(\014\022\022\n\ndispatcher\030\005 \001(\t\"P\n\023AkkaProtocolM" + - "essage\022\017\n\007payload\030\001 \001(\014\022(\n\013instruction\030\002", - " \001(\0132\023.AkkaControlMessage\"b\n\022AkkaControl" + - "Message\022!\n\013commandType\030\001 \002(\0162\014.CommandTy" + - "pe\022)\n\rhandshakeInfo\030\002 \001(\0132\022.AkkaHandshak" + - "eInfo\"N\n\021AkkaHandshakeInfo\022\034\n\006origin\030\001 \002" + - "(\0132\014.AddressData\022\013\n\003uid\030\002 \002(\006\022\016\n\006cookie\030" + - "\003 \001(\t\"O\n\013AddressData\022\016\n\006system\030\001 \002(\t\022\020\n\010" + - "hostname\030\002 \002(\t\022\014\n\004port\030\003 \002(\r\022\020\n\010protocol" + - "\030\004 \001(\t*{\n\013CommandType\022\r\n\tASSOCIATE\020\001\022\020\n\014" + - "DISASSOCIATE\020\002\022\r\n\tHEARTBEAT\020\003\022\036\n\032DISASSO" + - "CIATE_SHUTTING_DOWN\020\004\022\034\n\030DISASSOCIATE_QU", - "ARANTINED\020\005B\017\n\013akka.remoteH\001" - }; - com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = - new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() { - public com.google.protobuf.ExtensionRegistry assignDescriptors( - com.google.protobuf.Descriptors.FileDescriptor root) { - descriptor = root; - internal_static_AckAndEnvelopeContainer_descriptor = - getDescriptor().getMessageTypes().get(0); - internal_static_AckAndEnvelopeContainer_fieldAccessorTable = new - com.google.protobuf.GeneratedMessage.FieldAccessorTable( - internal_static_AckAndEnvelopeContainer_descriptor, - new java.lang.String[] { "Ack", "Envelope", }, - akka.remote.WireFormats.AckAndEnvelopeContainer.class, - akka.remote.WireFormats.AckAndEnvelopeContainer.Builder.class); - internal_static_RemoteEnvelope_descriptor = - getDescriptor().getMessageTypes().get(1); - internal_static_RemoteEnvelope_fieldAccessorTable = new - com.google.protobuf.GeneratedMessage.FieldAccessorTable( - internal_static_RemoteEnvelope_descriptor, - new java.lang.String[] { "Recipient", "Message", "Sender", "Seq", }, - akka.remote.WireFormats.RemoteEnvelope.class, - akka.remote.WireFormats.RemoteEnvelope.Builder.class); - internal_static_AcknowledgementInfo_descriptor = - getDescriptor().getMessageTypes().get(2); - internal_static_AcknowledgementInfo_fieldAccessorTable = new - com.google.protobuf.GeneratedMessage.FieldAccessorTable( - internal_static_AcknowledgementInfo_descriptor, - new java.lang.String[] { "CumulativeAck", "Nacks", }, - akka.remote.WireFormats.AcknowledgementInfo.class, - akka.remote.WireFormats.AcknowledgementInfo.Builder.class); - internal_static_ActorRefData_descriptor = - getDescriptor().getMessageTypes().get(3); - internal_static_ActorRefData_fieldAccessorTable = new - com.google.protobuf.GeneratedMessage.FieldAccessorTable( - internal_static_ActorRefData_descriptor, - new java.lang.String[] { "Path", }, - akka.remote.WireFormats.ActorRefData.class, - akka.remote.WireFormats.ActorRefData.Builder.class); - internal_static_SerializedMessage_descriptor = - getDescriptor().getMessageTypes().get(4); - internal_static_SerializedMessage_fieldAccessorTable = new - com.google.protobuf.GeneratedMessage.FieldAccessorTable( - internal_static_SerializedMessage_descriptor, - new java.lang.String[] { "Message", "SerializerId", "MessageManifest", }, - akka.remote.WireFormats.SerializedMessage.class, - akka.remote.WireFormats.SerializedMessage.Builder.class); - internal_static_DaemonMsgCreateData_descriptor = - getDescriptor().getMessageTypes().get(5); - internal_static_DaemonMsgCreateData_fieldAccessorTable = new - com.google.protobuf.GeneratedMessage.FieldAccessorTable( - internal_static_DaemonMsgCreateData_descriptor, - new java.lang.String[] { "Props", "Deploy", "Path", "Supervisor", }, - akka.remote.WireFormats.DaemonMsgCreateData.class, - akka.remote.WireFormats.DaemonMsgCreateData.Builder.class); - internal_static_PropsData_descriptor = - getDescriptor().getMessageTypes().get(6); - internal_static_PropsData_fieldAccessorTable = new - com.google.protobuf.GeneratedMessage.FieldAccessorTable( - internal_static_PropsData_descriptor, - new java.lang.String[] { "Deploy", "Clazz", "Args", "Classes", }, - akka.remote.WireFormats.PropsData.class, - akka.remote.WireFormats.PropsData.Builder.class); - internal_static_DeployData_descriptor = - getDescriptor().getMessageTypes().get(7); - internal_static_DeployData_fieldAccessorTable = new - com.google.protobuf.GeneratedMessage.FieldAccessorTable( - internal_static_DeployData_descriptor, - new java.lang.String[] { "Path", "Config", "RouterConfig", "Scope", "Dispatcher", }, - akka.remote.WireFormats.DeployData.class, - akka.remote.WireFormats.DeployData.Builder.class); - internal_static_AkkaProtocolMessage_descriptor = - getDescriptor().getMessageTypes().get(8); - internal_static_AkkaProtocolMessage_fieldAccessorTable = new - com.google.protobuf.GeneratedMessage.FieldAccessorTable( - internal_static_AkkaProtocolMessage_descriptor, - new java.lang.String[] { "Payload", "Instruction", }, - akka.remote.WireFormats.AkkaProtocolMessage.class, - akka.remote.WireFormats.AkkaProtocolMessage.Builder.class); - internal_static_AkkaControlMessage_descriptor = - getDescriptor().getMessageTypes().get(9); - internal_static_AkkaControlMessage_fieldAccessorTable = new - com.google.protobuf.GeneratedMessage.FieldAccessorTable( - internal_static_AkkaControlMessage_descriptor, - new java.lang.String[] { "CommandType", "HandshakeInfo", }, - akka.remote.WireFormats.AkkaControlMessage.class, - akka.remote.WireFormats.AkkaControlMessage.Builder.class); - internal_static_AkkaHandshakeInfo_descriptor = - getDescriptor().getMessageTypes().get(10); - internal_static_AkkaHandshakeInfo_fieldAccessorTable = new - com.google.protobuf.GeneratedMessage.FieldAccessorTable( - internal_static_AkkaHandshakeInfo_descriptor, - new java.lang.String[] { "Origin", "Uid", "Cookie", }, - akka.remote.WireFormats.AkkaHandshakeInfo.class, - akka.remote.WireFormats.AkkaHandshakeInfo.Builder.class); - internal_static_AddressData_descriptor = - getDescriptor().getMessageTypes().get(11); - internal_static_AddressData_fieldAccessorTable = new - com.google.protobuf.GeneratedMessage.FieldAccessorTable( - internal_static_AddressData_descriptor, - new java.lang.String[] { "System", "Hostname", "Port", "Protocol", }, - akka.remote.WireFormats.AddressData.class, - akka.remote.WireFormats.AddressData.Builder.class); - return null; - } - }; - com.google.protobuf.Descriptors.FileDescriptor - .internalBuildGeneratedFileFrom(descriptorData, - new com.google.protobuf.Descriptors.FileDescriptor[] { - }, assigner); - } - - // @@protoc_insertion_point(outer_class_scope) -} |