silentbalanceyh/vertx-zero

View on GitHub
vertx-semper/aeon-eternal/aeon-inlet/src/main/java/io/vertx/mod/ipc/eon/StreamServerRequest.java

Summary

Maintainability
F
1 wk
Test Coverage
// Generated by the protocol buffer compiler.  DO NOT EDIT!
// source: zero.stream.proto

package io.vertx.mod.ipc.eon;

/**
 * Protobuf type {@code io.vertx.mod.ipc.eon.StreamServerRequest}
 */
public final class StreamServerRequest extends
    com.google.protobuf.GeneratedMessageV3 implements
    // @@protoc_insertion_point(message_implements:io.vertx.mod.ipc.eon.StreamServerRequest)
    StreamServerRequestOrBuilder {
    // Use StreamServerRequest.newBuilder() to construct.
    private StreamServerRequest(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
        super(builder);
    }

    private StreamServerRequest() {
        responseType_ = 0;
        responseParams_ = java.util.Collections.emptyList();
        algorithm_ = 0;
    }

    @java.lang.Override
    public final com.google.protobuf.UnknownFieldSet
    getUnknownFields() {
        return com.google.protobuf.UnknownFieldSet.getDefaultInstance();
    }

    private StreamServerRequest(
        com.google.protobuf.CodedInputStream input,
        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
        throws com.google.protobuf.InvalidProtocolBufferException {
        this();
        int mutable_bitField0_ = 0;
        try {
            boolean done = false;
            while (!done) {
                int tag = input.readTag();
                switch (tag) {
                    case 0:
                        done = true;
                        break;
                    default: {
                        if (!input.skipField(tag)) {
                            done = true;
                        }
                        break;
                    }
                    case 8: {
                        int rawValue = input.readEnum();

                        responseType_ = rawValue;
                        break;
                    }
                    case 18: {
                        if (!((mutable_bitField0_ & 0x00000002) == 0x00000002)) {
                            responseParams_ = new java.util.ArrayList<io.vertx.mod.ipc.eon.ResponseParams>();
                            mutable_bitField0_ |= 0x00000002;
                        }
                        responseParams_.add(
                            input.readMessage(io.vertx.mod.ipc.eon.ResponseParams.parser(), extensionRegistry));
                        break;
                    }
                    case 26: {
                        io.vertx.mod.ipc.eon.IpcEnvelop.Builder subBuilder = null;
                        if (envelop_ != null) {
                            subBuilder = envelop_.toBuilder();
                        }
                        envelop_ = input.readMessage(io.vertx.mod.ipc.eon.IpcEnvelop.parser(), extensionRegistry);
                        if (subBuilder != null) {
                            subBuilder.mergeFrom(envelop_);
                            envelop_ = subBuilder.buildPartial();
                        }

                        break;
                    }
                    case 32: {
                        int rawValue = input.readEnum();

                        algorithm_ = rawValue;
                        break;
                    }
                    case 42: {
                        io.vertx.mod.ipc.eon.IpcStatus.Builder subBuilder = null;
                        if (responseStatus_ != null) {
                            subBuilder = responseStatus_.toBuilder();
                        }
                        responseStatus_ = input.readMessage(io.vertx.mod.ipc.eon.IpcStatus.parser(), extensionRegistry);
                        if (subBuilder != null) {
                            subBuilder.mergeFrom(responseStatus_);
                            responseStatus_ = subBuilder.buildPartial();
                        }

                        break;
                    }
                }
            }
        } catch (com.google.protobuf.InvalidProtocolBufferException e) {
            throw e.setUnfinishedMessage(this);
        } catch (java.io.IOException e) {
            throw new com.google.protobuf.InvalidProtocolBufferException(
                e).setUnfinishedMessage(this);
        } finally {
            if (((mutable_bitField0_ & 0x00000002) == 0x00000002)) {
                responseParams_ = java.util.Collections.unmodifiableList(responseParams_);
            }
            makeExtensionsImmutable();
        }
    }

    public static final com.google.protobuf.Descriptors.Descriptor
    getDescriptor() {
        return io.vertx.mod.ipc.eon.UpStream.internal_static_io_vertx_tp_ipc_eon_StreamServerRequest_descriptor;
    }

    protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
    internalGetFieldAccessorTable() {
        return io.vertx.mod.ipc.eon.UpStream.internal_static_io_vertx_tp_ipc_eon_StreamServerRequest_fieldAccessorTable
            .ensureFieldAccessorsInitialized(
                io.vertx.mod.ipc.eon.StreamServerRequest.class, io.vertx.mod.ipc.eon.StreamServerRequest.Builder.class);
    }

    private int bitField0_;
    public static final int RESPONSE_TYPE_FIELD_NUMBER = 1;
    private int responseType_;

    /**
     * <code>.io.vertx.mod.ipc.eon.em.Format response_type = 1;</code>
     */
    public int getResponseTypeValue() {
        return responseType_;
    }

    /**
     * <code>.io.vertx.mod.ipc.eon.em.Format response_type = 1;</code>
     */
    public io.vertx.mod.ipc.eon.em.Format getResponseType() {
        io.vertx.mod.ipc.eon.em.Format result = io.vertx.mod.ipc.eon.em.Format.valueOf(responseType_);
        return result == null ? io.vertx.mod.ipc.eon.em.Format.UNRECOGNIZED : result;
    }

    public static final int RESPONSE_PARAMS_FIELD_NUMBER = 2;
    private java.util.List<io.vertx.mod.ipc.eon.ResponseParams> responseParams_;

    /**
     * <code>repeated .io.vertx.mod.ipc.eon.ResponseParams response_params = 2;</code>
     */
    public java.util.List<io.vertx.mod.ipc.eon.ResponseParams> getResponseParamsList() {
        return responseParams_;
    }

    /**
     * <code>repeated .io.vertx.mod.ipc.eon.ResponseParams response_params = 2;</code>
     */
    public java.util.List<? extends io.vertx.mod.ipc.eon.ResponseParamsOrBuilder>
    getResponseParamsOrBuilderList() {
        return responseParams_;
    }

    /**
     * <code>repeated .io.vertx.mod.ipc.eon.ResponseParams response_params = 2;</code>
     */
    public int getResponseParamsCount() {
        return responseParams_.size();
    }

    /**
     * <code>repeated .io.vertx.mod.ipc.eon.ResponseParams response_params = 2;</code>
     */
    public io.vertx.mod.ipc.eon.ResponseParams getResponseParams(int index) {
        return responseParams_.get(index);
    }

    /**
     * <code>repeated .io.vertx.mod.ipc.eon.ResponseParams response_params = 2;</code>
     */
    public io.vertx.mod.ipc.eon.ResponseParamsOrBuilder getResponseParamsOrBuilder(
        int index) {
        return responseParams_.get(index);
    }

    public static final int ENVELOP_FIELD_NUMBER = 3;
    private io.vertx.mod.ipc.eon.IpcEnvelop envelop_;

    /**
     * <code>.io.vertx.mod.ipc.eon.IpcEnvelop envelop = 3;</code>
     */
    public boolean hasEnvelop() {
        return envelop_ != null;
    }

    /**
     * <code>.io.vertx.mod.ipc.eon.IpcEnvelop envelop = 3;</code>
     */
    public io.vertx.mod.ipc.eon.IpcEnvelop getEnvelop() {
        return envelop_ == null ? io.vertx.mod.ipc.eon.IpcEnvelop.getDefaultInstance() : envelop_;
    }

    /**
     * <code>.io.vertx.mod.ipc.eon.IpcEnvelop envelop = 3;</code>
     */
    public io.vertx.mod.ipc.eon.IpcEnvelopOrBuilder getEnvelopOrBuilder() {
        return getEnvelop();
    }

    public static final int ALGORITHM_FIELD_NUMBER = 4;
    private int algorithm_;

    /**
     * <code>.io.vertx.mod.ipc.eon.em.Compression algorithm = 4;</code>
     */
    public int getAlgorithmValue() {
        return algorithm_;
    }

    /**
     * <code>.io.vertx.mod.ipc.eon.em.Compression algorithm = 4;</code>
     */
    public io.vertx.mod.ipc.eon.em.Compression getAlgorithm() {
        io.vertx.mod.ipc.eon.em.Compression result = io.vertx.mod.ipc.eon.em.Compression.valueOf(algorithm_);
        return result == null ? io.vertx.mod.ipc.eon.em.Compression.UNRECOGNIZED : result;
    }

    public static final int RESPONSE_STATUS_FIELD_NUMBER = 5;
    private io.vertx.mod.ipc.eon.IpcStatus responseStatus_;

    /**
     * <code>.io.vertx.mod.ipc.eon.IpcStatus response_status = 5;</code>
     */
    public boolean hasResponseStatus() {
        return responseStatus_ != null;
    }

    /**
     * <code>.io.vertx.mod.ipc.eon.IpcStatus response_status = 5;</code>
     */
    public io.vertx.mod.ipc.eon.IpcStatus getResponseStatus() {
        return responseStatus_ == null ? io.vertx.mod.ipc.eon.IpcStatus.getDefaultInstance() : responseStatus_;
    }

    /**
     * <code>.io.vertx.mod.ipc.eon.IpcStatus response_status = 5;</code>
     */
    public io.vertx.mod.ipc.eon.IpcStatusOrBuilder getResponseStatusOrBuilder() {
        return getResponseStatus();
    }

    private byte memoizedIsInitialized = -1;

    public final boolean isInitialized() {
        byte isInitialized = memoizedIsInitialized;
        if (isInitialized == 1) return true;
        if (isInitialized == 0) return false;

        memoizedIsInitialized = 1;
        return true;
    }

    public void writeTo(com.google.protobuf.CodedOutputStream output)
        throws java.io.IOException {
        if (responseType_ != io.vertx.mod.ipc.eon.em.Format.BINARY.getNumber()) {
            output.writeEnum(1, responseType_);
        }
        for (int i = 0; i < responseParams_.size(); i++) {
            output.writeMessage(2, responseParams_.get(i));
        }
        if (envelop_ != null) {
            output.writeMessage(3, getEnvelop());
        }
        if (algorithm_ != io.vertx.mod.ipc.eon.em.Compression.NONE.getNumber()) {
            output.writeEnum(4, algorithm_);
        }
        if (responseStatus_ != null) {
            output.writeMessage(5, getResponseStatus());
        }
    }

    public int getSerializedSize() {
        int size = memoizedSize;
        if (size != -1) return size;

        size = 0;
        if (responseType_ != io.vertx.mod.ipc.eon.em.Format.BINARY.getNumber()) {
            size += com.google.protobuf.CodedOutputStream
                .computeEnumSize(1, responseType_);
        }
        for (int i = 0; i < responseParams_.size(); i++) {
            size += com.google.protobuf.CodedOutputStream
                .computeMessageSize(2, responseParams_.get(i));
        }
        if (envelop_ != null) {
            size += com.google.protobuf.CodedOutputStream
                .computeMessageSize(3, getEnvelop());
        }
        if (algorithm_ != io.vertx.mod.ipc.eon.em.Compression.NONE.getNumber()) {
            size += com.google.protobuf.CodedOutputStream
                .computeEnumSize(4, algorithm_);
        }
        if (responseStatus_ != null) {
            size += com.google.protobuf.CodedOutputStream
                .computeMessageSize(5, getResponseStatus());
        }
        memoizedSize = size;
        return size;
    }

    private static final long serialVersionUID = 0L;

    @java.lang.Override
    public boolean equals(final java.lang.Object obj) {
        if (obj == this) {
            return true;
        }
        if (!(obj instanceof io.vertx.mod.ipc.eon.StreamServerRequest)) {
            return super.equals(obj);
        }
        io.vertx.mod.ipc.eon.StreamServerRequest other = (io.vertx.mod.ipc.eon.StreamServerRequest) obj;

        boolean result = true;
        result = result && responseType_ == other.responseType_;
        result = result && getResponseParamsList()
            .equals(other.getResponseParamsList());
        result = result && (hasEnvelop() == other.hasEnvelop());
        if (hasEnvelop()) {
            result = result && getEnvelop()
                .equals(other.getEnvelop());
        }
        result = result && algorithm_ == other.algorithm_;
        result = result && (hasResponseStatus() == other.hasResponseStatus());
        if (hasResponseStatus()) {
            result = result && getResponseStatus()
                .equals(other.getResponseStatus());
        }
        return result;
    }

    @java.lang.Override
    public int hashCode() {
        if (memoizedHashCode != 0) {
            return memoizedHashCode;
        }
        int hash = 41;
        hash = (19 * hash) + getDescriptor().hashCode();
        hash = (37 * hash) + RESPONSE_TYPE_FIELD_NUMBER;
        hash = (53 * hash) + responseType_;
        if (getResponseParamsCount() > 0) {
            hash = (37 * hash) + RESPONSE_PARAMS_FIELD_NUMBER;
            hash = (53 * hash) + getResponseParamsList().hashCode();
        }
        if (hasEnvelop()) {
            hash = (37 * hash) + ENVELOP_FIELD_NUMBER;
            hash = (53 * hash) + getEnvelop().hashCode();
        }
        hash = (37 * hash) + ALGORITHM_FIELD_NUMBER;
        hash = (53 * hash) + algorithm_;
        if (hasResponseStatus()) {
            hash = (37 * hash) + RESPONSE_STATUS_FIELD_NUMBER;
            hash = (53 * hash) + getResponseStatus().hashCode();
        }
        hash = (29 * hash) + unknownFields.hashCode();
        memoizedHashCode = hash;
        return hash;
    }

    public static io.vertx.mod.ipc.eon.StreamServerRequest parseFrom(
        com.google.protobuf.ByteString data)
        throws com.google.protobuf.InvalidProtocolBufferException {
        return PARSER.parseFrom(data);
    }

    public static io.vertx.mod.ipc.eon.StreamServerRequest parseFrom(
        com.google.protobuf.ByteString data,
        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
        throws com.google.protobuf.InvalidProtocolBufferException {
        return PARSER.parseFrom(data, extensionRegistry);
    }

    public static io.vertx.mod.ipc.eon.StreamServerRequest parseFrom(byte[] data)
        throws com.google.protobuf.InvalidProtocolBufferException {
        return PARSER.parseFrom(data);
    }

    public static io.vertx.mod.ipc.eon.StreamServerRequest parseFrom(
        byte[] data,
        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
        throws com.google.protobuf.InvalidProtocolBufferException {
        return PARSER.parseFrom(data, extensionRegistry);
    }

    public static io.vertx.mod.ipc.eon.StreamServerRequest parseFrom(java.io.InputStream input)
        throws java.io.IOException {
        return com.google.protobuf.GeneratedMessageV3
            .parseWithIOException(PARSER, input);
    }

    public static io.vertx.mod.ipc.eon.StreamServerRequest parseFrom(
        java.io.InputStream input,
        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
        return com.google.protobuf.GeneratedMessageV3
            .parseWithIOException(PARSER, input, extensionRegistry);
    }

    public static io.vertx.mod.ipc.eon.StreamServerRequest parseDelimitedFrom(java.io.InputStream input)
        throws java.io.IOException {
        return com.google.protobuf.GeneratedMessageV3
            .parseDelimitedWithIOException(PARSER, input);
    }

    public static io.vertx.mod.ipc.eon.StreamServerRequest parseDelimitedFrom(
        java.io.InputStream input,
        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
        return com.google.protobuf.GeneratedMessageV3
            .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
    }

    public static io.vertx.mod.ipc.eon.StreamServerRequest parseFrom(
        com.google.protobuf.CodedInputStream input)
        throws java.io.IOException {
        return com.google.protobuf.GeneratedMessageV3
            .parseWithIOException(PARSER, input);
    }

    public static io.vertx.mod.ipc.eon.StreamServerRequest parseFrom(
        com.google.protobuf.CodedInputStream input,
        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
        throws java.io.IOException {
        return com.google.protobuf.GeneratedMessageV3
            .parseWithIOException(PARSER, input, extensionRegistry);
    }

    public Builder newBuilderForType() {
        return newBuilder();
    }

    public static Builder newBuilder() {
        return DEFAULT_INSTANCE.toBuilder();
    }

    public static Builder newBuilder(io.vertx.mod.ipc.eon.StreamServerRequest prototype) {
        return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
    }

    public Builder toBuilder() {
        return this == DEFAULT_INSTANCE
            ? new Builder() : new Builder().mergeFrom(this);
    }

    @java.lang.Override
    protected Builder newBuilderForType(
        com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
        Builder builder = new Builder(parent);
        return builder;
    }

    /**
     * Protobuf type {@code io.vertx.mod.ipc.eon.StreamServerRequest}
     */
    public static final class Builder extends
        com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
        // @@protoc_insertion_point(builder_implements:io.vertx.mod.ipc.eon.StreamServerRequest)
        io.vertx.mod.ipc.eon.StreamServerRequestOrBuilder {
        public static final com.google.protobuf.Descriptors.Descriptor
        getDescriptor() {
            return io.vertx.mod.ipc.eon.UpStream.internal_static_io_vertx_tp_ipc_eon_StreamServerRequest_descriptor;
        }

        protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
        internalGetFieldAccessorTable() {
            return io.vertx.mod.ipc.eon.UpStream.internal_static_io_vertx_tp_ipc_eon_StreamServerRequest_fieldAccessorTable
                .ensureFieldAccessorsInitialized(
                    io.vertx.mod.ipc.eon.StreamServerRequest.class, io.vertx.mod.ipc.eon.StreamServerRequest.Builder.class);
        }

        // Construct using io.vertx.mod.ipc.eon.StreamServerRequest.newBuilder()
        private Builder() {
            maybeForceBuilderInitialization();
        }

        private Builder(
            com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
            super(parent);
            maybeForceBuilderInitialization();
        }

        private void maybeForceBuilderInitialization() {
            if (com.google.protobuf.GeneratedMessageV3
                .alwaysUseFieldBuilders) {
                getResponseParamsFieldBuilder();
            }
        }

        public Builder clear() {
            super.clear();
            responseType_ = 0;

            if (responseParamsBuilder_ == null) {
                responseParams_ = java.util.Collections.emptyList();
                bitField0_ = (bitField0_ & ~0x00000002);
            } else {
                responseParamsBuilder_.clear();
            }
            if (envelopBuilder_ == null) {
                envelop_ = null;
            } else {
                envelop_ = null;
                envelopBuilder_ = null;
            }
            algorithm_ = 0;

            if (responseStatusBuilder_ == null) {
                responseStatus_ = null;
            } else {
                responseStatus_ = null;
                responseStatusBuilder_ = null;
            }
            return this;
        }

        public com.google.protobuf.Descriptors.Descriptor
        getDescriptorForType() {
            return io.vertx.mod.ipc.eon.UpStream.internal_static_io_vertx_tp_ipc_eon_StreamServerRequest_descriptor;
        }

        public io.vertx.mod.ipc.eon.StreamServerRequest getDefaultInstanceForType() {
            return io.vertx.mod.ipc.eon.StreamServerRequest.getDefaultInstance();
        }

        public io.vertx.mod.ipc.eon.StreamServerRequest build() {
            io.vertx.mod.ipc.eon.StreamServerRequest result = buildPartial();
            if (!result.isInitialized()) {
                throw newUninitializedMessageException(result);
            }
            return result;
        }

        public io.vertx.mod.ipc.eon.StreamServerRequest buildPartial() {
            io.vertx.mod.ipc.eon.StreamServerRequest result = new io.vertx.mod.ipc.eon.StreamServerRequest(this);
            int from_bitField0_ = bitField0_;
            int to_bitField0_ = 0;
            result.responseType_ = responseType_;
            if (responseParamsBuilder_ == null) {
                if (((bitField0_ & 0x00000002) == 0x00000002)) {
                    responseParams_ = java.util.Collections.unmodifiableList(responseParams_);
                    bitField0_ = (bitField0_ & ~0x00000002);
                }
                result.responseParams_ = responseParams_;
            } else {
                result.responseParams_ = responseParamsBuilder_.build();
            }
            if (envelopBuilder_ == null) {
                result.envelop_ = envelop_;
            } else {
                result.envelop_ = envelopBuilder_.build();
            }
            result.algorithm_ = algorithm_;
            if (responseStatusBuilder_ == null) {
                result.responseStatus_ = responseStatus_;
            } else {
                result.responseStatus_ = responseStatusBuilder_.build();
            }
            result.bitField0_ = to_bitField0_;
            onBuilt();
            return result;
        }

        public Builder clone() {
            return (Builder) super.clone();
        }

        public Builder setField(
            com.google.protobuf.Descriptors.FieldDescriptor field,
            Object value) {
            return (Builder) super.setField(field, value);
        }

        public Builder clearField(
            com.google.protobuf.Descriptors.FieldDescriptor field) {
            return (Builder) super.clearField(field);
        }

        public Builder clearOneof(
            com.google.protobuf.Descriptors.OneofDescriptor oneof) {
            return (Builder) super.clearOneof(oneof);
        }

        public Builder setRepeatedField(
            com.google.protobuf.Descriptors.FieldDescriptor field,
            int index, Object value) {
            return (Builder) super.setRepeatedField(field, index, value);
        }

        public Builder addRepeatedField(
            com.google.protobuf.Descriptors.FieldDescriptor field,
            Object value) {
            return (Builder) super.addRepeatedField(field, value);
        }

        public Builder mergeFrom(com.google.protobuf.Message other) {
            if (other instanceof io.vertx.mod.ipc.eon.StreamServerRequest) {
                return mergeFrom((io.vertx.mod.ipc.eon.StreamServerRequest) other);
            } else {
                super.mergeFrom(other);
                return this;
            }
        }

        public Builder mergeFrom(io.vertx.mod.ipc.eon.StreamServerRequest other) {
            if (other == io.vertx.mod.ipc.eon.StreamServerRequest.getDefaultInstance()) return this;
            if (other.responseType_ != 0) {
                setResponseTypeValue(other.getResponseTypeValue());
            }
            if (responseParamsBuilder_ == null) {
                if (!other.responseParams_.isEmpty()) {
                    if (responseParams_.isEmpty()) {
                        responseParams_ = other.responseParams_;
                        bitField0_ = (bitField0_ & ~0x00000002);
                    } else {
                        ensureResponseParamsIsMutable();
                        responseParams_.addAll(other.responseParams_);
                    }
                    onChanged();
                }
            } else {
                if (!other.responseParams_.isEmpty()) {
                    if (responseParamsBuilder_.isEmpty()) {
                        responseParamsBuilder_.dispose();
                        responseParamsBuilder_ = null;
                        responseParams_ = other.responseParams_;
                        bitField0_ = (bitField0_ & ~0x00000002);
                        responseParamsBuilder_ =
                            com.google.protobuf.GeneratedMessageV3.alwaysUseFieldBuilders ?
                                getResponseParamsFieldBuilder() : null;
                    } else {
                        responseParamsBuilder_.addAllMessages(other.responseParams_);
                    }
                }
            }
            if (other.hasEnvelop()) {
                mergeEnvelop(other.getEnvelop());
            }
            if (other.algorithm_ != 0) {
                setAlgorithmValue(other.getAlgorithmValue());
            }
            if (other.hasResponseStatus()) {
                mergeResponseStatus(other.getResponseStatus());
            }
            onChanged();
            return this;
        }

        public final boolean isInitialized() {
            return true;
        }

        public Builder mergeFrom(
            com.google.protobuf.CodedInputStream input,
            com.google.protobuf.ExtensionRegistryLite extensionRegistry)
            throws java.io.IOException {
            io.vertx.mod.ipc.eon.StreamServerRequest parsedMessage = null;
            try {
                parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
            } catch (com.google.protobuf.InvalidProtocolBufferException e) {
                parsedMessage = (io.vertx.mod.ipc.eon.StreamServerRequest) e.getUnfinishedMessage();
                throw e.unwrapIOException();
            } finally {
                if (parsedMessage != null) {
                    mergeFrom(parsedMessage);
                }
            }
            return this;
        }

        private int bitField0_;

        private int responseType_ = 0;

        /**
         * <code>.io.vertx.mod.ipc.eon.em.Format response_type = 1;</code>
         */
        public int getResponseTypeValue() {
            return responseType_;
        }

        /**
         * <code>.io.vertx.mod.ipc.eon.em.Format response_type = 1;</code>
         */
        public Builder setResponseTypeValue(int value) {
            responseType_ = value;
            onChanged();
            return this;
        }

        /**
         * <code>.io.vertx.mod.ipc.eon.em.Format response_type = 1;</code>
         */
        public io.vertx.mod.ipc.eon.em.Format getResponseType() {
            io.vertx.mod.ipc.eon.em.Format result = io.vertx.mod.ipc.eon.em.Format.valueOf(responseType_);
            return result == null ? io.vertx.mod.ipc.eon.em.Format.UNRECOGNIZED : result;
        }

        /**
         * <code>.io.vertx.mod.ipc.eon.em.Format response_type = 1;</code>
         */
        public Builder setResponseType(io.vertx.mod.ipc.eon.em.Format value) {
            if (value == null) {
                throw new NullPointerException();
            }

            responseType_ = value.getNumber();
            onChanged();
            return this;
        }

        /**
         * <code>.io.vertx.mod.ipc.eon.em.Format response_type = 1;</code>
         */
        public Builder clearResponseType() {

            responseType_ = 0;
            onChanged();
            return this;
        }

        private java.util.List<io.vertx.mod.ipc.eon.ResponseParams> responseParams_ =
            java.util.Collections.emptyList();

        private void ensureResponseParamsIsMutable() {
            if (!((bitField0_ & 0x00000002) == 0x00000002)) {
                responseParams_ = new java.util.ArrayList<io.vertx.mod.ipc.eon.ResponseParams>(responseParams_);
                bitField0_ |= 0x00000002;
            }
        }

        private com.google.protobuf.RepeatedFieldBuilderV3<
            io.vertx.mod.ipc.eon.ResponseParams, io.vertx.mod.ipc.eon.ResponseParams.Builder, io.vertx.mod.ipc.eon.ResponseParamsOrBuilder> responseParamsBuilder_;

        /**
         * <code>repeated .io.vertx.mod.ipc.eon.ResponseParams response_params = 2;</code>
         */
        public java.util.List<io.vertx.mod.ipc.eon.ResponseParams> getResponseParamsList() {
            if (responseParamsBuilder_ == null) {
                return java.util.Collections.unmodifiableList(responseParams_);
            } else {
                return responseParamsBuilder_.getMessageList();
            }
        }

        /**
         * <code>repeated .io.vertx.mod.ipc.eon.ResponseParams response_params = 2;</code>
         */
        public int getResponseParamsCount() {
            if (responseParamsBuilder_ == null) {
                return responseParams_.size();
            } else {
                return responseParamsBuilder_.getCount();
            }
        }

        /**
         * <code>repeated .io.vertx.mod.ipc.eon.ResponseParams response_params = 2;</code>
         */
        public io.vertx.mod.ipc.eon.ResponseParams getResponseParams(int index) {
            if (responseParamsBuilder_ == null) {
                return responseParams_.get(index);
            } else {
                return responseParamsBuilder_.getMessage(index);
            }
        }

        /**
         * <code>repeated .io.vertx.mod.ipc.eon.ResponseParams response_params = 2;</code>
         */
        public Builder setResponseParams(
            int index, io.vertx.mod.ipc.eon.ResponseParams value) {
            if (responseParamsBuilder_ == null) {
                if (value == null) {
                    throw new NullPointerException();
                }
                ensureResponseParamsIsMutable();
                responseParams_.set(index, value);
                onChanged();
            } else {
                responseParamsBuilder_.setMessage(index, value);
            }
            return this;
        }

        /**
         * <code>repeated .io.vertx.mod.ipc.eon.ResponseParams response_params = 2;</code>
         */
        public Builder setResponseParams(
            int index, io.vertx.mod.ipc.eon.ResponseParams.Builder builderForValue) {
            if (responseParamsBuilder_ == null) {
                ensureResponseParamsIsMutable();
                responseParams_.set(index, builderForValue.build());
                onChanged();
            } else {
                responseParamsBuilder_.setMessage(index, builderForValue.build());
            }
            return this;
        }

        /**
         * <code>repeated .io.vertx.mod.ipc.eon.ResponseParams response_params = 2;</code>
         */
        public Builder addResponseParams(io.vertx.mod.ipc.eon.ResponseParams value) {
            if (responseParamsBuilder_ == null) {
                if (value == null) {
                    throw new NullPointerException();
                }
                ensureResponseParamsIsMutable();
                responseParams_.add(value);
                onChanged();
            } else {
                responseParamsBuilder_.addMessage(value);
            }
            return this;
        }

        /**
         * <code>repeated .io.vertx.mod.ipc.eon.ResponseParams response_params = 2;</code>
         */
        public Builder addResponseParams(
            int index, io.vertx.mod.ipc.eon.ResponseParams value) {
            if (responseParamsBuilder_ == null) {
                if (value == null) {
                    throw new NullPointerException();
                }
                ensureResponseParamsIsMutable();
                responseParams_.add(index, value);
                onChanged();
            } else {
                responseParamsBuilder_.addMessage(index, value);
            }
            return this;
        }

        /**
         * <code>repeated .io.vertx.mod.ipc.eon.ResponseParams response_params = 2;</code>
         */
        public Builder addResponseParams(
            io.vertx.mod.ipc.eon.ResponseParams.Builder builderForValue) {
            if (responseParamsBuilder_ == null) {
                ensureResponseParamsIsMutable();
                responseParams_.add(builderForValue.build());
                onChanged();
            } else {
                responseParamsBuilder_.addMessage(builderForValue.build());
            }
            return this;
        }

        /**
         * <code>repeated .io.vertx.mod.ipc.eon.ResponseParams response_params = 2;</code>
         */
        public Builder addResponseParams(
            int index, io.vertx.mod.ipc.eon.ResponseParams.Builder builderForValue) {
            if (responseParamsBuilder_ == null) {
                ensureResponseParamsIsMutable();
                responseParams_.add(index, builderForValue.build());
                onChanged();
            } else {
                responseParamsBuilder_.addMessage(index, builderForValue.build());
            }
            return this;
        }

        /**
         * <code>repeated .io.vertx.mod.ipc.eon.ResponseParams response_params = 2;</code>
         */
        public Builder addAllResponseParams(
            java.lang.Iterable<? extends io.vertx.mod.ipc.eon.ResponseParams> values) {
            if (responseParamsBuilder_ == null) {
                ensureResponseParamsIsMutable();
                com.google.protobuf.AbstractMessageLite.Builder.addAll(
                    values, responseParams_);
                onChanged();
            } else {
                responseParamsBuilder_.addAllMessages(values);
            }
            return this;
        }

        /**
         * <code>repeated .io.vertx.mod.ipc.eon.ResponseParams response_params = 2;</code>
         */
        public Builder clearResponseParams() {
            if (responseParamsBuilder_ == null) {
                responseParams_ = java.util.Collections.emptyList();
                bitField0_ = (bitField0_ & ~0x00000002);
                onChanged();
            } else {
                responseParamsBuilder_.clear();
            }
            return this;
        }

        /**
         * <code>repeated .io.vertx.mod.ipc.eon.ResponseParams response_params = 2;</code>
         */
        public Builder removeResponseParams(int index) {
            if (responseParamsBuilder_ == null) {
                ensureResponseParamsIsMutable();
                responseParams_.remove(index);
                onChanged();
            } else {
                responseParamsBuilder_.remove(index);
            }
            return this;
        }

        /**
         * <code>repeated .io.vertx.mod.ipc.eon.ResponseParams response_params = 2;</code>
         */
        public io.vertx.mod.ipc.eon.ResponseParams.Builder getResponseParamsBuilder(
            int index) {
            return getResponseParamsFieldBuilder().getBuilder(index);
        }

        /**
         * <code>repeated .io.vertx.mod.ipc.eon.ResponseParams response_params = 2;</code>
         */
        public io.vertx.mod.ipc.eon.ResponseParamsOrBuilder getResponseParamsOrBuilder(
            int index) {
            if (responseParamsBuilder_ == null) {
                return responseParams_.get(index);
            } else {
                return responseParamsBuilder_.getMessageOrBuilder(index);
            }
        }

        /**
         * <code>repeated .io.vertx.mod.ipc.eon.ResponseParams response_params = 2;</code>
         */
        public java.util.List<? extends io.vertx.mod.ipc.eon.ResponseParamsOrBuilder>
        getResponseParamsOrBuilderList() {
            if (responseParamsBuilder_ != null) {
                return responseParamsBuilder_.getMessageOrBuilderList();
            } else {
                return java.util.Collections.unmodifiableList(responseParams_);
            }
        }

        /**
         * <code>repeated .io.vertx.mod.ipc.eon.ResponseParams response_params = 2;</code>
         */
        public io.vertx.mod.ipc.eon.ResponseParams.Builder addResponseParamsBuilder() {
            return getResponseParamsFieldBuilder().addBuilder(
                io.vertx.mod.ipc.eon.ResponseParams.getDefaultInstance());
        }

        /**
         * <code>repeated .io.vertx.mod.ipc.eon.ResponseParams response_params = 2;</code>
         */
        public io.vertx.mod.ipc.eon.ResponseParams.Builder addResponseParamsBuilder(
            int index) {
            return getResponseParamsFieldBuilder().addBuilder(
                index, io.vertx.mod.ipc.eon.ResponseParams.getDefaultInstance());
        }

        /**
         * <code>repeated .io.vertx.mod.ipc.eon.ResponseParams response_params = 2;</code>
         */
        public java.util.List<io.vertx.mod.ipc.eon.ResponseParams.Builder>
        getResponseParamsBuilderList() {
            return getResponseParamsFieldBuilder().getBuilderList();
        }

        private com.google.protobuf.RepeatedFieldBuilderV3<
            io.vertx.mod.ipc.eon.ResponseParams, io.vertx.mod.ipc.eon.ResponseParams.Builder, io.vertx.mod.ipc.eon.ResponseParamsOrBuilder>
        getResponseParamsFieldBuilder() {
            if (responseParamsBuilder_ == null) {
                responseParamsBuilder_ = new com.google.protobuf.RepeatedFieldBuilderV3<
                    io.vertx.mod.ipc.eon.ResponseParams, io.vertx.mod.ipc.eon.ResponseParams.Builder, io.vertx.mod.ipc.eon.ResponseParamsOrBuilder>(
                    responseParams_,
                    ((bitField0_ & 0x00000002) == 0x00000002),
                    getParentForChildren(),
                    isClean());
                responseParams_ = null;
            }
            return responseParamsBuilder_;
        }

        private io.vertx.mod.ipc.eon.IpcEnvelop envelop_ = null;
        private com.google.protobuf.SingleFieldBuilderV3<
            io.vertx.mod.ipc.eon.IpcEnvelop, io.vertx.mod.ipc.eon.IpcEnvelop.Builder, io.vertx.mod.ipc.eon.IpcEnvelopOrBuilder> envelopBuilder_;

        /**
         * <code>.io.vertx.mod.ipc.eon.IpcEnvelop envelop = 3;</code>
         */
        public boolean hasEnvelop() {
            return envelopBuilder_ != null || envelop_ != null;
        }

        /**
         * <code>.io.vertx.mod.ipc.eon.IpcEnvelop envelop = 3;</code>
         */
        public io.vertx.mod.ipc.eon.IpcEnvelop getEnvelop() {
            if (envelopBuilder_ == null) {
                return envelop_ == null ? io.vertx.mod.ipc.eon.IpcEnvelop.getDefaultInstance() : envelop_;
            } else {
                return envelopBuilder_.getMessage();
            }
        }

        /**
         * <code>.io.vertx.mod.ipc.eon.IpcEnvelop envelop = 3;</code>
         */
        public Builder setEnvelop(io.vertx.mod.ipc.eon.IpcEnvelop value) {
            if (envelopBuilder_ == null) {
                if (value == null) {
                    throw new NullPointerException();
                }
                envelop_ = value;
                onChanged();
            } else {
                envelopBuilder_.setMessage(value);
            }

            return this;
        }

        /**
         * <code>.io.vertx.mod.ipc.eon.IpcEnvelop envelop = 3;</code>
         */
        public Builder setEnvelop(
            io.vertx.mod.ipc.eon.IpcEnvelop.Builder builderForValue) {
            if (envelopBuilder_ == null) {
                envelop_ = builderForValue.build();
                onChanged();
            } else {
                envelopBuilder_.setMessage(builderForValue.build());
            }

            return this;
        }

        /**
         * <code>.io.vertx.mod.ipc.eon.IpcEnvelop envelop = 3;</code>
         */
        public Builder mergeEnvelop(io.vertx.mod.ipc.eon.IpcEnvelop value) {
            if (envelopBuilder_ == null) {
                if (envelop_ != null) {
                    envelop_ =
                        io.vertx.mod.ipc.eon.IpcEnvelop.newBuilder(envelop_).mergeFrom(value).buildPartial();
                } else {
                    envelop_ = value;
                }
                onChanged();
            } else {
                envelopBuilder_.mergeFrom(value);
            }

            return this;
        }

        /**
         * <code>.io.vertx.mod.ipc.eon.IpcEnvelop envelop = 3;</code>
         */
        public Builder clearEnvelop() {
            if (envelopBuilder_ == null) {
                envelop_ = null;
                onChanged();
            } else {
                envelop_ = null;
                envelopBuilder_ = null;
            }

            return this;
        }

        /**
         * <code>.io.vertx.mod.ipc.eon.IpcEnvelop envelop = 3;</code>
         */
        public io.vertx.mod.ipc.eon.IpcEnvelop.Builder getEnvelopBuilder() {

            onChanged();
            return getEnvelopFieldBuilder().getBuilder();
        }

        /**
         * <code>.io.vertx.mod.ipc.eon.IpcEnvelop envelop = 3;</code>
         */
        public io.vertx.mod.ipc.eon.IpcEnvelopOrBuilder getEnvelopOrBuilder() {
            if (envelopBuilder_ != null) {
                return envelopBuilder_.getMessageOrBuilder();
            } else {
                return envelop_ == null ?
                    io.vertx.mod.ipc.eon.IpcEnvelop.getDefaultInstance() : envelop_;
            }
        }

        /**
         * <code>.io.vertx.mod.ipc.eon.IpcEnvelop envelop = 3;</code>
         */
        private com.google.protobuf.SingleFieldBuilderV3<
            io.vertx.mod.ipc.eon.IpcEnvelop, io.vertx.mod.ipc.eon.IpcEnvelop.Builder, io.vertx.mod.ipc.eon.IpcEnvelopOrBuilder>
        getEnvelopFieldBuilder() {
            if (envelopBuilder_ == null) {
                envelopBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
                    io.vertx.mod.ipc.eon.IpcEnvelop, io.vertx.mod.ipc.eon.IpcEnvelop.Builder, io.vertx.mod.ipc.eon.IpcEnvelopOrBuilder>(
                    getEnvelop(),
                    getParentForChildren(),
                    isClean());
                envelop_ = null;
            }
            return envelopBuilder_;
        }

        private int algorithm_ = 0;

        /**
         * <code>.io.vertx.mod.ipc.eon.em.Compression algorithm = 4;</code>
         */
        public int getAlgorithmValue() {
            return algorithm_;
        }

        /**
         * <code>.io.vertx.mod.ipc.eon.em.Compression algorithm = 4;</code>
         */
        public Builder setAlgorithmValue(int value) {
            algorithm_ = value;
            onChanged();
            return this;
        }

        /**
         * <code>.io.vertx.mod.ipc.eon.em.Compression algorithm = 4;</code>
         */
        public io.vertx.mod.ipc.eon.em.Compression getAlgorithm() {
            io.vertx.mod.ipc.eon.em.Compression result = io.vertx.mod.ipc.eon.em.Compression.valueOf(algorithm_);
            return result == null ? io.vertx.mod.ipc.eon.em.Compression.UNRECOGNIZED : result;
        }

        /**
         * <code>.io.vertx.mod.ipc.eon.em.Compression algorithm = 4;</code>
         */
        public Builder setAlgorithm(io.vertx.mod.ipc.eon.em.Compression value) {
            if (value == null) {
                throw new NullPointerException();
            }

            algorithm_ = value.getNumber();
            onChanged();
            return this;
        }

        /**
         * <code>.io.vertx.mod.ipc.eon.em.Compression algorithm = 4;</code>
         */
        public Builder clearAlgorithm() {

            algorithm_ = 0;
            onChanged();
            return this;
        }

        private io.vertx.mod.ipc.eon.IpcStatus responseStatus_ = null;
        private com.google.protobuf.SingleFieldBuilderV3<
            io.vertx.mod.ipc.eon.IpcStatus, io.vertx.mod.ipc.eon.IpcStatus.Builder, io.vertx.mod.ipc.eon.IpcStatusOrBuilder> responseStatusBuilder_;

        /**
         * <code>.io.vertx.mod.ipc.eon.IpcStatus response_status = 5;</code>
         */
        public boolean hasResponseStatus() {
            return responseStatusBuilder_ != null || responseStatus_ != null;
        }

        /**
         * <code>.io.vertx.mod.ipc.eon.IpcStatus response_status = 5;</code>
         */
        public io.vertx.mod.ipc.eon.IpcStatus getResponseStatus() {
            if (responseStatusBuilder_ == null) {
                return responseStatus_ == null ? io.vertx.mod.ipc.eon.IpcStatus.getDefaultInstance() : responseStatus_;
            } else {
                return responseStatusBuilder_.getMessage();
            }
        }

        /**
         * <code>.io.vertx.mod.ipc.eon.IpcStatus response_status = 5;</code>
         */
        public Builder setResponseStatus(io.vertx.mod.ipc.eon.IpcStatus value) {
            if (responseStatusBuilder_ == null) {
                if (value == null) {
                    throw new NullPointerException();
                }
                responseStatus_ = value;
                onChanged();
            } else {
                responseStatusBuilder_.setMessage(value);
            }

            return this;
        }

        /**
         * <code>.io.vertx.mod.ipc.eon.IpcStatus response_status = 5;</code>
         */
        public Builder setResponseStatus(
            io.vertx.mod.ipc.eon.IpcStatus.Builder builderForValue) {
            if (responseStatusBuilder_ == null) {
                responseStatus_ = builderForValue.build();
                onChanged();
            } else {
                responseStatusBuilder_.setMessage(builderForValue.build());
            }

            return this;
        }

        /**
         * <code>.io.vertx.mod.ipc.eon.IpcStatus response_status = 5;</code>
         */
        public Builder mergeResponseStatus(io.vertx.mod.ipc.eon.IpcStatus value) {
            if (responseStatusBuilder_ == null) {
                if (responseStatus_ != null) {
                    responseStatus_ =
                        io.vertx.mod.ipc.eon.IpcStatus.newBuilder(responseStatus_).mergeFrom(value).buildPartial();
                } else {
                    responseStatus_ = value;
                }
                onChanged();
            } else {
                responseStatusBuilder_.mergeFrom(value);
            }

            return this;
        }

        /**
         * <code>.io.vertx.mod.ipc.eon.IpcStatus response_status = 5;</code>
         */
        public Builder clearResponseStatus() {
            if (responseStatusBuilder_ == null) {
                responseStatus_ = null;
                onChanged();
            } else {
                responseStatus_ = null;
                responseStatusBuilder_ = null;
            }

            return this;
        }

        /**
         * <code>.io.vertx.mod.ipc.eon.IpcStatus response_status = 5;</code>
         */
        public io.vertx.mod.ipc.eon.IpcStatus.Builder getResponseStatusBuilder() {

            onChanged();
            return getResponseStatusFieldBuilder().getBuilder();
        }

        /**
         * <code>.io.vertx.mod.ipc.eon.IpcStatus response_status = 5;</code>
         */
        public io.vertx.mod.ipc.eon.IpcStatusOrBuilder getResponseStatusOrBuilder() {
            if (responseStatusBuilder_ != null) {
                return responseStatusBuilder_.getMessageOrBuilder();
            } else {
                return responseStatus_ == null ?
                    io.vertx.mod.ipc.eon.IpcStatus.getDefaultInstance() : responseStatus_;
            }
        }

        /**
         * <code>.io.vertx.mod.ipc.eon.IpcStatus response_status = 5;</code>
         */
        private com.google.protobuf.SingleFieldBuilderV3<
            io.vertx.mod.ipc.eon.IpcStatus, io.vertx.mod.ipc.eon.IpcStatus.Builder, io.vertx.mod.ipc.eon.IpcStatusOrBuilder>
        getResponseStatusFieldBuilder() {
            if (responseStatusBuilder_ == null) {
                responseStatusBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
                    io.vertx.mod.ipc.eon.IpcStatus, io.vertx.mod.ipc.eon.IpcStatus.Builder, io.vertx.mod.ipc.eon.IpcStatusOrBuilder>(
                    getResponseStatus(),
                    getParentForChildren(),
                    isClean());
                responseStatus_ = null;
            }
            return responseStatusBuilder_;
        }

        public final Builder setUnknownFields(
            final com.google.protobuf.UnknownFieldSet unknownFields) {
            return this;
        }

        public final Builder mergeUnknownFields(
            final com.google.protobuf.UnknownFieldSet unknownFields) {
            return this;
        }


        // @@protoc_insertion_point(builder_scope:io.vertx.mod.ipc.eon.StreamServerRequest)
    }

    // @@protoc_insertion_point(class_scope:io.vertx.mod.ipc.eon.StreamServerRequest)
    private static final io.vertx.mod.ipc.eon.StreamServerRequest DEFAULT_INSTANCE;

    static {
        DEFAULT_INSTANCE = new io.vertx.mod.ipc.eon.StreamServerRequest();
    }

    public static io.vertx.mod.ipc.eon.StreamServerRequest getDefaultInstance() {
        return DEFAULT_INSTANCE;
    }

    private static final com.google.protobuf.Parser<StreamServerRequest>
        PARSER = new com.google.protobuf.AbstractParser<StreamServerRequest>() {
        public StreamServerRequest parsePartialFrom(
            com.google.protobuf.CodedInputStream input,
            com.google.protobuf.ExtensionRegistryLite extensionRegistry)
            throws com.google.protobuf.InvalidProtocolBufferException {
            return new StreamServerRequest(input, extensionRegistry);
        }
    };

    public static com.google.protobuf.Parser<StreamServerRequest> parser() {
        return PARSER;
    }

    @java.lang.Override
    public com.google.protobuf.Parser<StreamServerRequest> getParserForType() {
        return PARSER;
    }

    public io.vertx.mod.ipc.eon.StreamServerRequest getDefaultInstanceForType() {
        return DEFAULT_INSTANCE;
    }

}