content: /*
   * Copyright (C) 2023-2025 Lightbend Inc. <https://www.lightbend.com>
   */
  
  // Generated by the protocol buffer compiler.  DO NOT EDIT!
  // source: QueryMessages.proto
  
  package akka.persistence.query.internal.protobuf;
  
  public final class QueryMessages {
    private QueryMessages() {}
  
    public static void registerAllExtensions(
        akka.protobufv3.internal.ExtensionRegistryLite registry) {}
  
    public static void registerAllExtensions(akka.protobufv3.internal.ExtensionRegistry registry) {
      registerAllExtensions((akka.protobufv3.internal.ExtensionRegistryLite) registry);
    }
  
    public interface EventEnvelopeOrBuilder
        extends
        // @@protoc_insertion_point(interface_extends:akka.persistence.query.EventEnvelope)
        akka.protobufv3.internal.MessageOrBuilder {
  
      /**
       * <code>required string persistence_id = 1;</code>
       *
       * @return Whether the persistenceId field is set.
       */
      boolean hasPersistenceId();
      /**
       * <code>required string persistence_id = 1;</code>
       *
       * @return The persistenceId.
       */
      java.lang.String getPersistenceId();
      /**
       * <code>required string persistence_id = 1;</code>
       *
       * @return The bytes for persistenceId.
       */
      akka.protobufv3.internal.ByteString getPersistenceIdBytes();
  
      /**
       * <code>required string entity_type = 2;</code>
       *
       * @return Whether the entityType field is set.
       */
      boolean hasEntityType();
      /**
       * <code>required string entity_type = 2;</code>
       *
       * @return The entityType.
       */
      java.lang.String getEntityType();
      /**
       * <code>required string entity_type = 2;</code>
       *
       * @return The bytes for entityType.
       */
      akka.protobufv3.internal.ByteString getEntityTypeBytes();
  
      /**
       * <code>required int32 slice = 3;</code>
       *
       * @return Whether the slice field is set.
       */
      boolean hasSlice();
      /**
       * <code>required int32 slice = 3;</code>
       *
       * @return The slice.
       */
      int getSlice();
  
      /**
       * <code>required int64 sequence_nr = 4;</code>
       *
       * @return Whether the sequenceNr field is set.
       */
      boolean hasSequenceNr();
      /**
       * <code>required int64 sequence_nr = 4;</code>
       *
       * @return The sequenceNr.
       */
      long getSequenceNr();
  
      /**
       * <code>required int64 timestamp = 5;</code>
       *
       * @return Whether the timestamp field is set.
       */
      boolean hasTimestamp();
      /**
       * <code>required int64 timestamp = 5;</code>
       *
       * @return The timestamp.
       */
      long getTimestamp();
  
      /**
       * <code>required string offset = 6;</code>
       *
       * @return Whether the offset field is set.
       */
      boolean hasOffset();
      /**
       * <code>required string offset = 6;</code>
       *
       * @return The offset.
       */
      java.lang.String getOffset();
      /**
       * <code>required string offset = 6;</code>
       *
       * @return The bytes for offset.
       */
      akka.protobufv3.internal.ByteString getOffsetBytes();
  
      /**
       * <code>required string offset_manifest = 7;</code>
       *
       * @return Whether the offsetManifest field is set.
       */
      boolean hasOffsetManifest();
      /**
       * <code>required string offset_manifest = 7;</code>
       *
       * @return The offsetManifest.
       */
      java.lang.String getOffsetManifest();
      /**
       * <code>required string offset_manifest = 7;</code>
       *
       * @return The bytes for offsetManifest.
       */
      akka.protobufv3.internal.ByteString getOffsetManifestBytes();
  
      /**
       * <code>optional .Payload event = 8;</code>
       *
       * @return Whether the event field is set.
       */
      boolean hasEvent();
      /**
       * <code>optional .Payload event = 8;</code>
       *
       * @return The event.
       */
      akka.remote.ContainerFormats.Payload getEvent();
      /** <code>optional .Payload event = 8;</code> */
      akka.remote.ContainerFormats.PayloadOrBuilder getEventOrBuilder();
  
      /**
       * <code>optional .Payload metadata = 9;</code>
       *
       * @return Whether the metadata field is set.
       */
      boolean hasMetadata();
      /**
       * <code>optional .Payload metadata = 9;</code>
       *
       * @return The metadata.
       */
      akka.remote.ContainerFormats.Payload getMetadata();
      /** <code>optional .Payload metadata = 9;</code> */
      akka.remote.ContainerFormats.PayloadOrBuilder getMetadataOrBuilder();
  
      /**
       * <code>optional bool filtered = 10;</code>
       *
       * @return Whether the filtered field is set.
       */
      boolean hasFiltered();
      /**
       * <code>optional bool filtered = 10;</code>
       *
       * @return The filtered.
       */
      boolean getFiltered();
  
      /**
       * <code>optional string source = 11;</code>
       *
       * @return Whether the source field is set.
       */
      boolean hasSource();
      /**
       * <code>optional string source = 11;</code>
       *
       * @return The source.
       */
      java.lang.String getSource();
      /**
       * <code>optional string source = 11;</code>
       *
       * @return The bytes for source.
       */
      akka.protobufv3.internal.ByteString getSourceBytes();
  
      /**
       * <code>repeated string tags = 12;</code>
       *
       * @return A list containing the tags.
       */
      java.util.List<java.lang.String> getTagsList();
      /**
       * <code>repeated string tags = 12;</code>
       *
       * @return The count of tags.
       */
      int getTagsCount();
      /**
       * <code>repeated string tags = 12;</code>
       *
       * @param index The index of the element to return.
       * @return The tags at the given index.
       */
      java.lang.String getTags(int index);
      /**
       * <code>repeated string tags = 12;</code>
       *
       * @param index The index of the value to return.
       * @return The bytes of the tags at the given index.
       */
      akka.protobufv3.internal.ByteString getTagsBytes(int index);
    }
    /**
     *
     *
     * <pre>
     * for akka.persistence.query.typed.EventEnvelope
     * </pre>
     *
     * Protobuf type {@code akka.persistence.query.EventEnvelope}
     */
    public static final class EventEnvelope extends akka.protobufv3.internal.GeneratedMessageV3
        implements
        // @@protoc_insertion_point(message_implements:akka.persistence.query.EventEnvelope)
        EventEnvelopeOrBuilder {
      private static final long serialVersionUID = 0L;
      // Use EventEnvelope.newBuilder() to construct.
      private EventEnvelope(akka.protobufv3.internal.GeneratedMessageV3.Builder<?> builder) {
        super(builder);
      }
  
      private EventEnvelope() {
        persistenceId_ = "";
        entityType_ = "";
        offset_ = "";
        offsetManifest_ = "";
        source_ = "";
        tags_ = akka.protobufv3.internal.LazyStringArrayList.emptyList();
      }
  
      @java.lang.Override
      @SuppressWarnings({"unused"})
      protected java.lang.Object newInstance(
          akka.protobufv3.internal.GeneratedMessageV3.UnusedPrivateParameter unused) {
        return new EventEnvelope();
      }
  
      public static final akka.protobufv3.internal.Descriptors.Descriptor getDescriptor() {
        return akka.persistence.query.internal.protobuf.QueryMessages
            .internal_static_akka_persistence_query_EventEnvelope_descriptor;
      }
  
      @java.lang.Override
      protected akka.protobufv3.internal.GeneratedMessageV3.FieldAccessorTable
          internalGetFieldAccessorTable() {
        return akka.persistence.query.internal.protobuf.QueryMessages
            .internal_static_akka_persistence_query_EventEnvelope_fieldAccessorTable
            .ensureFieldAccessorsInitialized(
                akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope.class,
                akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope.Builder.class);
      }
  
      private int bitField0_;
      public static final int PERSISTENCE_ID_FIELD_NUMBER = 1;
  
      @SuppressWarnings("serial")
      private volatile java.lang.Object persistenceId_ = "";
      /**
       * <code>required string persistence_id = 1;</code>
       *
       * @return Whether the persistenceId field is set.
       */
      @java.lang.Override
      public boolean hasPersistenceId() {
        return ((bitField0_ & 0x00000001) != 0);
      }
      /**
       * <code>required string persistence_id = 1;</code>
       *
       * @return The persistenceId.
       */
      @java.lang.Override
      public java.lang.String getPersistenceId() {
        java.lang.Object ref = persistenceId_;
        if (ref instanceof java.lang.String) {
          return (java.lang.String) ref;
        } else {
          akka.protobufv3.internal.ByteString bs = (akka.protobufv3.internal.ByteString) ref;
          java.lang.String s = bs.toStringUtf8();
          if (bs.isValidUtf8()) {
            persistenceId_ = s;
          }
          return s;
        }
      }
      /**
       * <code>required string persistence_id = 1;</code>
       *
       * @return The bytes for persistenceId.
       */
      @java.lang.Override
      public akka.protobufv3.internal.ByteString getPersistenceIdBytes() {
        java.lang.Object ref = persistenceId_;
        if (ref instanceof java.lang.String) {
          akka.protobufv3.internal.ByteString b =
              akka.protobufv3.internal.ByteString.copyFromUtf8((java.lang.String) ref);
          persistenceId_ = b;
          return b;
        } else {
          return (akka.protobufv3.internal.ByteString) ref;
        }
      }
  
      public static final int ENTITY_TYPE_FIELD_NUMBER = 2;
  
      @SuppressWarnings("serial")
      private volatile java.lang.Object entityType_ = "";
      /**
       * <code>required string entity_type = 2;</code>
       *
       * @return Whether the entityType field is set.
       */
      @java.lang.Override
      public boolean hasEntityType() {
        return ((bitField0_ & 0x00000002) != 0);
      }
      /**
       * <code>required string entity_type = 2;</code>
       *
       * @return The entityType.
       */
      @java.lang.Override
      public java.lang.String getEntityType() {
        java.lang.Object ref = entityType_;
        if (ref instanceof java.lang.String) {
          return (java.lang.String) ref;
        } else {
          akka.protobufv3.internal.ByteString bs = (akka.protobufv3.internal.ByteString) ref;
          java.lang.String s = bs.toStringUtf8();
          if (bs.isValidUtf8()) {
            entityType_ = s;
          }
          return s;
        }
      }
      /**
       * <code>required string entity_type = 2;</code>
       *
       * @return The bytes for entityType.
       */
      @java.lang.Override
      public akka.protobufv3.internal.ByteString getEntityTypeBytes() {
        java.lang.Object ref = entityType_;
        if (ref instanceof java.lang.String) {
          akka.protobufv3.internal.ByteString b =
              akka.protobufv3.internal.ByteString.copyFromUtf8((java.lang.String) ref);
          entityType_ = b;
          return b;
        } else {
          return (akka.protobufv3.internal.ByteString) ref;
        }
      }
  
      public static final int SLICE_FIELD_NUMBER = 3;
      private int slice_ = 0;
      /**
       * <code>required int32 slice = 3;</code>
       *
       * @return Whether the slice field is set.
       */
      @java.lang.Override
      public boolean hasSlice() {
        return ((bitField0_ & 0x00000004) != 0);
      }
      /**
       * <code>required int32 slice = 3;</code>
       *
       * @return The slice.
       */
      @java.lang.Override
      public int getSlice() {
        return slice_;
      }
  
      public static final int SEQUENCE_NR_FIELD_NUMBER = 4;
      private long sequenceNr_ = 0L;
      /**
       * <code>required int64 sequence_nr = 4;</code>
       *
       * @return Whether the sequenceNr field is set.
       */
      @java.lang.Override
      public boolean hasSequenceNr() {
        return ((bitField0_ & 0x00000008) != 0);
      }
      /**
       * <code>required int64 sequence_nr = 4;</code>
       *
       * @return The sequenceNr.
       */
      @java.lang.Override
      public long getSequenceNr() {
        return sequenceNr_;
      }
  
      public static final int TIMESTAMP_FIELD_NUMBER = 5;
      private long timestamp_ = 0L;
      /**
       * <code>required int64 timestamp = 5;</code>
       *
       * @return Whether the timestamp field is set.
       */
      @java.lang.Override
      public boolean hasTimestamp() {
        return ((bitField0_ & 0x00000010) != 0);
      }
      /**
       * <code>required int64 timestamp = 5;</code>
       *
       * @return The timestamp.
       */
      @java.lang.Override
      public long getTimestamp() {
        return timestamp_;
      }
  
      public static final int OFFSET_FIELD_NUMBER = 6;
  
      @SuppressWarnings("serial")
      private volatile java.lang.Object offset_ = "";
      /**
       * <code>required string offset = 6;</code>
       *
       * @return Whether the offset field is set.
       */
      @java.lang.Override
      public boolean hasOffset() {
        return ((bitField0_ & 0x00000020) != 0);
      }
      /**
       * <code>required string offset = 6;</code>
       *
       * @return The offset.
       */
      @java.lang.Override
      public java.lang.String getOffset() {
        java.lang.Object ref = offset_;
        if (ref instanceof java.lang.String) {
          return (java.lang.String) ref;
        } else {
          akka.protobufv3.internal.ByteString bs = (akka.protobufv3.internal.ByteString) ref;
          java.lang.String s = bs.toStringUtf8();
          if (bs.isValidUtf8()) {
            offset_ = s;
          }
          return s;
        }
      }
      /**
       * <code>required string offset = 6;</code>
       *
       * @return The bytes for offset.
       */
      @java.lang.Override
      public akka.protobufv3.internal.ByteString getOffsetBytes() {
        java.lang.Object ref = offset_;
        if (ref instanceof java.lang.String) {
          akka.protobufv3.internal.ByteString b =
              akka.protobufv3.internal.ByteString.copyFromUtf8((java.lang.String) ref);
          offset_ = b;
          return b;
        } else {
          return (akka.protobufv3.internal.ByteString) ref;
        }
      }
  
      public static final int OFFSET_MANIFEST_FIELD_NUMBER = 7;
  
      @SuppressWarnings("serial")
      private volatile java.lang.Object offsetManifest_ = "";
      /**
       * <code>required string offset_manifest = 7;</code>
       *
       * @return Whether the offsetManifest field is set.
       */
      @java.lang.Override
      public boolean hasOffsetManifest() {
        return ((bitField0_ & 0x00000040) != 0);
      }
      /**
       * <code>required string offset_manifest = 7;</code>
       *
       * @return The offsetManifest.
       */
      @java.lang.Override
      public java.lang.String getOffsetManifest() {
        java.lang.Object ref = offsetManifest_;
        if (ref instanceof java.lang.String) {
          return (java.lang.String) ref;
        } else {
          akka.protobufv3.internal.ByteString bs = (akka.protobufv3.internal.ByteString) ref;
          java.lang.String s = bs.toStringUtf8();
          if (bs.isValidUtf8()) {
            offsetManifest_ = s;
          }
          return s;
        }
      }
      /**
       * <code>required string offset_manifest = 7;</code>
       *
       * @return The bytes for offsetManifest.
       */
      @java.lang.Override
      public akka.protobufv3.internal.ByteString getOffsetManifestBytes() {
        java.lang.Object ref = offsetManifest_;
        if (ref instanceof java.lang.String) {
          akka.protobufv3.internal.ByteString b =
              akka.protobufv3.internal.ByteString.copyFromUtf8((java.lang.String) ref);
          offsetManifest_ = b;
          return b;
        } else {
          return (akka.protobufv3.internal.ByteString) ref;
        }
      }
  
      public static final int EVENT_FIELD_NUMBER = 8;
      private akka.remote.ContainerFormats.Payload event_;
      /**
       * <code>optional .Payload event = 8;</code>
       *
       * @return Whether the event field is set.
       */
      @java.lang.Override
      public boolean hasEvent() {
        return ((bitField0_ & 0x00000080) != 0);
      }
      /**
       * <code>optional .Payload event = 8;</code>
       *
       * @return The event.
       */
      @java.lang.Override
      public akka.remote.ContainerFormats.Payload getEvent() {
        return event_ == null ? akka.remote.ContainerFormats.Payload.getDefaultInstance() : event_;
      }
      /** <code>optional .Payload event = 8;</code> */
      @java.lang.Override
      public akka.remote.ContainerFormats.PayloadOrBuilder getEventOrBuilder() {
        return event_ == null ? akka.remote.ContainerFormats.Payload.getDefaultInstance() : event_;
      }
  
      public static final int METADATA_FIELD_NUMBER = 9;
      private akka.remote.ContainerFormats.Payload metadata_;
      /**
       * <code>optional .Payload metadata = 9;</code>
       *
       * @return Whether the metadata field is set.
       */
      @java.lang.Override
      public boolean hasMetadata() {
        return ((bitField0_ & 0x00000100) != 0);
      }
      /**
       * <code>optional .Payload metadata = 9;</code>
       *
       * @return The metadata.
       */
      @java.lang.Override
      public akka.remote.ContainerFormats.Payload getMetadata() {
        return metadata_ == null
            ? akka.remote.ContainerFormats.Payload.getDefaultInstance()
            : metadata_;
      }
      /** <code>optional .Payload metadata = 9;</code> */
      @java.lang.Override
      public akka.remote.ContainerFormats.PayloadOrBuilder getMetadataOrBuilder() {
        return metadata_ == null
            ? akka.remote.ContainerFormats.Payload.getDefaultInstance()
            : metadata_;
      }
  
      public static final int FILTERED_FIELD_NUMBER = 10;
      private boolean filtered_ = false;
      /**
       * <code>optional bool filtered = 10;</code>
       *
       * @return Whether the filtered field is set.
       */
      @java.lang.Override
      public boolean hasFiltered() {
        return ((bitField0_ & 0x00000200) != 0);
      }
      /**
       * <code>optional bool filtered = 10;</code>
       *
       * @return The filtered.
       */
      @java.lang.Override
      public boolean getFiltered() {
        return filtered_;
      }
  
      public static final int SOURCE_FIELD_NUMBER = 11;
  
      @SuppressWarnings("serial")
      private volatile java.lang.Object source_ = "";
      /**
       * <code>optional string source = 11;</code>
       *
       * @return Whether the source field is set.
       */
      @java.lang.Override
      public boolean hasSource() {
        return ((bitField0_ & 0x00000400) != 0);
      }
      /**
       * <code>optional string source = 11;</code>
       *
       * @return The source.
       */
      @java.lang.Override
      public java.lang.String getSource() {
        java.lang.Object ref = source_;
        if (ref instanceof java.lang.String) {
          return (java.lang.String) ref;
        } else {
          akka.protobufv3.internal.ByteString bs = (akka.protobufv3.internal.ByteString) ref;
          java.lang.String s = bs.toStringUtf8();
          if (bs.isValidUtf8()) {
            source_ = s;
          }
          return s;
        }
      }
      /**
       * <code>optional string source = 11;</code>
       *
       * @return The bytes for source.
       */
      @java.lang.Override
      public akka.protobufv3.internal.ByteString getSourceBytes() {
        java.lang.Object ref = source_;
        if (ref instanceof java.lang.String) {
          akka.protobufv3.internal.ByteString b =
              akka.protobufv3.internal.ByteString.copyFromUtf8((java.lang.String) ref);
          source_ = b;
          return b;
        } else {
          return (akka.protobufv3.internal.ByteString) ref;
        }
      }
  
      public static final int TAGS_FIELD_NUMBER = 12;
  
      @SuppressWarnings("serial")
      private akka.protobufv3.internal.LazyStringArrayList tags_ =
          akka.protobufv3.internal.LazyStringArrayList.emptyList();
      /**
       * <code>repeated string tags = 12;</code>
       *
       * @return A list containing the tags.
       */
      public akka.protobufv3.internal.ProtocolStringList getTagsList() {
        return tags_;
      }
      /**
       * <code>repeated string tags = 12;</code>
       *
       * @return The count of tags.
       */
      public int getTagsCount() {
        return tags_.size();
      }
      /**
       * <code>repeated string tags = 12;</code>
       *
       * @param index The index of the element to return.
       * @return The tags at the given index.
       */
      public java.lang.String getTags(int index) {
        return tags_.get(index);
      }
      /**
       * <code>repeated string tags = 12;</code>
       *
       * @param index The index of the value to return.
       * @return The bytes of the tags at the given index.
       */
      public akka.protobufv3.internal.ByteString getTagsBytes(int index) {
        return tags_.getByteString(index);
      }
  
      private byte memoizedIsInitialized = -1;
  
      @java.lang.Override
      public final boolean isInitialized() {
        byte isInitialized = memoizedIsInitialized;
        if (isInitialized == 1) return true;
        if (isInitialized == 0) return false;
  
        if (!hasPersistenceId()) {
          memoizedIsInitialized = 0;
          return false;
        }
        if (!hasEntityType()) {
          memoizedIsInitialized = 0;
          return false;
        }
        if (!hasSlice()) {
          memoizedIsInitialized = 0;
          return false;
        }
        if (!hasSequenceNr()) {
          memoizedIsInitialized = 0;
          return false;
        }
        if (!hasTimestamp()) {
          memoizedIsInitialized = 0;
          return false;
        }
        if (!hasOffset()) {
          memoizedIsInitialized = 0;
          return false;
        }
        if (!hasOffsetManifest()) {
          memoizedIsInitialized = 0;
          return false;
        }
        if (hasEvent()) {
          if (!getEvent().isInitialized()) {
            memoizedIsInitialized = 0;
            return false;
          }
        }
        if (hasMetadata()) {
          if (!getMetadata().isInitialized()) {
            memoizedIsInitialized = 0;
            return false;
          }
        }
        memoizedIsInitialized = 1;
        return true;
      }
  
      @java.lang.Override
      public void writeTo(akka.protobufv3.internal.CodedOutputStream output)
          throws java.io.IOException {
        if (((bitField0_ & 0x00000001) != 0)) {
          akka.protobufv3.internal.GeneratedMessageV3.writeString(output, 1, persistenceId_);
        }
        if (((bitField0_ & 0x00000002) != 0)) {
          akka.protobufv3.internal.GeneratedMessageV3.writeString(output, 2, entityType_);
        }
        if (((bitField0_ & 0x00000004) != 0)) {
          output.writeInt32(3, slice_);
        }
        if (((bitField0_ & 0x00000008) != 0)) {
          output.writeInt64(4, sequenceNr_);
        }
        if (((bitField0_ & 0x00000010) != 0)) {
          output.writeInt64(5, timestamp_);
        }
        if (((bitField0_ & 0x00000020) != 0)) {
          akka.protobufv3.internal.GeneratedMessageV3.writeString(output, 6, offset_);
        }
        if (((bitField0_ & 0x00000040) != 0)) {
          akka.protobufv3.internal.GeneratedMessageV3.writeString(output, 7, offsetManifest_);
        }
        if (((bitField0_ & 0x00000080) != 0)) {
          output.writeMessage(8, getEvent());
        }
        if (((bitField0_ & 0x00000100) != 0)) {
          output.writeMessage(9, getMetadata());
        }
        if (((bitField0_ & 0x00000200) != 0)) {
          output.writeBool(10, filtered_);
        }
        if (((bitField0_ & 0x00000400) != 0)) {
          akka.protobufv3.internal.GeneratedMessageV3.writeString(output, 11, source_);
        }
        for (int i = 0; i < tags_.size(); i++) {
          akka.protobufv3.internal.GeneratedMessageV3.writeString(output, 12, tags_.getRaw(i));
        }
        getUnknownFields().writeTo(output);
      }
  
      @java.lang.Override
      public int getSerializedSize() {
        int size = memoizedSize;
        if (size != -1) return size;
  
        size = 0;
        if (((bitField0_ & 0x00000001) != 0)) {
          size += akka.protobufv3.internal.GeneratedMessageV3.computeStringSize(1, persistenceId_);
        }
        if (((bitField0_ & 0x00000002) != 0)) {
          size += akka.protobufv3.internal.GeneratedMessageV3.computeStringSize(2, entityType_);
        }
        if (((bitField0_ & 0x00000004) != 0)) {
          size += akka.protobufv3.internal.CodedOutputStream.computeInt32Size(3, slice_);
        }
        if (((bitField0_ & 0x00000008) != 0)) {
          size += akka.protobufv3.internal.CodedOutputStream.computeInt64Size(4, sequenceNr_);
        }
        if (((bitField0_ & 0x00000010) != 0)) {
          size += akka.protobufv3.internal.CodedOutputStream.computeInt64Size(5, timestamp_);
        }
        if (((bitField0_ & 0x00000020) != 0)) {
          size += akka.protobufv3.internal.GeneratedMessageV3.computeStringSize(6, offset_);
        }
        if (((bitField0_ & 0x00000040) != 0)) {
          size += akka.protobufv3.internal.GeneratedMessageV3.computeStringSize(7, offsetManifest_);
        }
        if (((bitField0_ & 0x00000080) != 0)) {
          size += akka.protobufv3.internal.CodedOutputStream.computeMessageSize(8, getEvent());
        }
        if (((bitField0_ & 0x00000100) != 0)) {
          size += akka.protobufv3.internal.CodedOutputStream.computeMessageSize(9, getMetadata());
        }
        if (((bitField0_ & 0x00000200) != 0)) {
          size += akka.protobufv3.internal.CodedOutputStream.computeBoolSize(10, filtered_);
        }
        if (((bitField0_ & 0x00000400) != 0)) {
          size += akka.protobufv3.internal.GeneratedMessageV3.computeStringSize(11, source_);
        }
        {
          int dataSize = 0;
          for (int i = 0; i < tags_.size(); i++) {
            dataSize += computeStringSizeNoTag(tags_.getRaw(i));
          }
          size += dataSize;
          size += 1 * getTagsList().size();
        }
        size += getUnknownFields().getSerializedSize();
        memoizedSize = size;
        return size;
      }
  
      @java.lang.Override
      public boolean equals(final java.lang.Object obj) {
        if (obj == this) {
          return true;
        }
        if (!(obj instanceof akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope)) {
          return super.equals(obj);
        }
        akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope other =
            (akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope) obj;
  
        if (hasPersistenceId() != other.hasPersistenceId()) return false;
        if (hasPersistenceId()) {
          if (!getPersistenceId().equals(other.getPersistenceId())) return false;
        }
        if (hasEntityType() != other.hasEntityType()) return false;
        if (hasEntityType()) {
          if (!getEntityType().equals(other.getEntityType())) return false;
        }
        if (hasSlice() != other.hasSlice()) return false;
        if (hasSlice()) {
          if (getSlice() != other.getSlice()) return false;
        }
        if (hasSequenceNr() != other.hasSequenceNr()) return false;
        if (hasSequenceNr()) {
          if (getSequenceNr() != other.getSequenceNr()) return false;
        }
        if (hasTimestamp() != other.hasTimestamp()) return false;
        if (hasTimestamp()) {
          if (getTimestamp() != other.getTimestamp()) return false;
        }
        if (hasOffset() != other.hasOffset()) return false;
        if (hasOffset()) {
          if (!getOffset().equals(other.getOffset())) return false;
        }
        if (hasOffsetManifest() != other.hasOffsetManifest()) return false;
        if (hasOffsetManifest()) {
          if (!getOffsetManifest().equals(other.getOffsetManifest())) return false;
        }
        if (hasEvent() != other.hasEvent()) return false;
        if (hasEvent()) {
          if (!getEvent().equals(other.getEvent())) return false;
        }
        if (hasMetadata() != other.hasMetadata()) return false;
        if (hasMetadata()) {
          if (!getMetadata().equals(other.getMetadata())) return false;
        }
        if (hasFiltered() != other.hasFiltered()) return false;
        if (hasFiltered()) {
          if (getFiltered() != other.getFiltered()) return false;
        }
        if (hasSource() != other.hasSource()) return false;
        if (hasSource()) {
          if (!getSource().equals(other.getSource())) return false;
        }
        if (!getTagsList().equals(other.getTagsList())) return false;
        if (!getUnknownFields().equals(other.getUnknownFields())) return false;
        return true;
      }
  
      @java.lang.Override
      public int hashCode() {
        if (memoizedHashCode != 0) {
          return memoizedHashCode;
        }
        int hash = 41;
        hash = (19 * hash) + getDescriptor().hashCode();
        if (hasPersistenceId()) {
          hash = (37 * hash) + PERSISTENCE_ID_FIELD_NUMBER;
          hash = (53 * hash) + getPersistenceId().hashCode();
        }
        if (hasEntityType()) {
          hash = (37 * hash) + ENTITY_TYPE_FIELD_NUMBER;
          hash = (53 * hash) + getEntityType().hashCode();
        }
        if (hasSlice()) {
          hash = (37 * hash) + SLICE_FIELD_NUMBER;
          hash = (53 * hash) + getSlice();
        }
        if (hasSequenceNr()) {
          hash = (37 * hash) + SEQUENCE_NR_FIELD_NUMBER;
          hash = (53 * hash) + akka.protobufv3.internal.Internal.hashLong(getSequenceNr());
        }
        if (hasTimestamp()) {
          hash = (37 * hash) + TIMESTAMP_FIELD_NUMBER;
          hash = (53 * hash) + akka.protobufv3.internal.Internal.hashLong(getTimestamp());
        }
        if (hasOffset()) {
          hash = (37 * hash) + OFFSET_FIELD_NUMBER;
          hash = (53 * hash) + getOffset().hashCode();
        }
        if (hasOffsetManifest()) {
          hash = (37 * hash) + OFFSET_MANIFEST_FIELD_NUMBER;
          hash = (53 * hash) + getOffsetManifest().hashCode();
        }
        if (hasEvent()) {
          hash = (37 * hash) + EVENT_FIELD_NUMBER;
          hash = (53 * hash) + getEvent().hashCode();
        }
        if (hasMetadata()) {
          hash = (37 * hash) + METADATA_FIELD_NUMBER;
          hash = (53 * hash) + getMetadata().hashCode();
        }
        if (hasFiltered()) {
          hash = (37 * hash) + FILTERED_FIELD_NUMBER;
          hash = (53 * hash) + akka.protobufv3.internal.Internal.hashBoolean(getFiltered());
        }
        if (hasSource()) {
          hash = (37 * hash) + SOURCE_FIELD_NUMBER;
          hash = (53 * hash) + getSource().hashCode();
        }
        if (getTagsCount() > 0) {
          hash = (37 * hash) + TAGS_FIELD_NUMBER;
          hash = (53 * hash) + getTagsList().hashCode();
        }
        hash = (29 * hash) + getUnknownFields().hashCode();
        memoizedHashCode = hash;
        return hash;
      }
  
      public static akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope parseFrom(
          java.nio.ByteBuffer data) throws akka.protobufv3.internal.InvalidProtocolBufferException {
        return PARSER.parseFrom(data);
      }
  
      public static akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope parseFrom(
          java.nio.ByteBuffer data, akka.protobufv3.internal.ExtensionRegistryLite extensionRegistry)
          throws akka.protobufv3.internal.InvalidProtocolBufferException {
        return PARSER.parseFrom(data, extensionRegistry);
      }
  
      public static akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope parseFrom(
          akka.protobufv3.internal.ByteString data)
          throws akka.protobufv3.internal.InvalidProtocolBufferException {
        return PARSER.parseFrom(data);
      }
  
      public static akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope parseFrom(
          akka.protobufv3.internal.ByteString data,
          akka.protobufv3.internal.ExtensionRegistryLite extensionRegistry)
          throws akka.protobufv3.internal.InvalidProtocolBufferException {
        return PARSER.parseFrom(data, extensionRegistry);
      }
  
      public static akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope parseFrom(
          byte[] data) throws akka.protobufv3.internal.InvalidProtocolBufferException {
        return PARSER.parseFrom(data);
      }
  
      public static akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope parseFrom(
          byte[] data, akka.protobufv3.internal.ExtensionRegistryLite extensionRegistry)
          throws akka.protobufv3.internal.InvalidProtocolBufferException {
        return PARSER.parseFrom(data, extensionRegistry);
      }
  
      public static akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope parseFrom(
          java.io.InputStream input) throws java.io.IOException {
        return akka.protobufv3.internal.GeneratedMessageV3.parseWithIOException(PARSER, input);
      }
  
      public static akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope parseFrom(
          java.io.InputStream input, akka.protobufv3.internal.ExtensionRegistryLite extensionRegistry)
          throws java.io.IOException {
        return akka.protobufv3.internal.GeneratedMessageV3.parseWithIOException(
            PARSER, input, extensionRegistry);
      }
  
      public static akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope
          parseDelimitedFrom(java.io.InputStream input) throws java.io.IOException {
        return akka.protobufv3.internal.GeneratedMessageV3.parseDelimitedWithIOException(
            PARSER, input);
      }
  
      public static akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope
          parseDelimitedFrom(
              java.io.InputStream input,
              akka.protobufv3.internal.ExtensionRegistryLite extensionRegistry)
              throws java.io.IOException {
        return akka.protobufv3.internal.GeneratedMessageV3.parseDelimitedWithIOException(
            PARSER, input, extensionRegistry);
      }
  
      public static akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope parseFrom(
          akka.protobufv3.internal.CodedInputStream input) throws java.io.IOException {
        return akka.protobufv3.internal.GeneratedMessageV3.parseWithIOException(PARSER, input);
      }
  
      public static akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope parseFrom(
          akka.protobufv3.internal.CodedInputStream input,
          akka.protobufv3.internal.ExtensionRegistryLite extensionRegistry)
          throws java.io.IOException {
        return akka.protobufv3.internal.GeneratedMessageV3.parseWithIOException(
            PARSER, input, extensionRegistry);
      }
  
      @java.lang.Override
      public Builder newBuilderForType() {
        return newBuilder();
      }
  
      public static Builder newBuilder() {
        return DEFAULT_INSTANCE.toBuilder();
      }
  
      public static Builder newBuilder(
          akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope prototype) {
        return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
      }
  
      @java.lang.Override
      public Builder toBuilder() {
        return this == DEFAULT_INSTANCE ? new Builder() : new Builder().mergeFrom(this);
      }
  
      @java.lang.Override
      protected Builder newBuilderForType(
          akka.protobufv3.internal.GeneratedMessageV3.BuilderParent parent) {
        Builder builder = new Builder(parent);
        return builder;
      }
      /**
       *
       *
       * <pre>
       * for akka.persistence.query.typed.EventEnvelope
       * </pre>
       *
       * Protobuf type {@code akka.persistence.query.EventEnvelope}
       */
      public static final class Builder
          extends akka.protobufv3.internal.GeneratedMessageV3.Builder<Builder>
          implements
          // @@protoc_insertion_point(builder_implements:akka.persistence.query.EventEnvelope)
          akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelopeOrBuilder {
        public static final akka.protobufv3.internal.Descriptors.Descriptor getDescriptor() {
          return akka.persistence.query.internal.protobuf.QueryMessages
              .internal_static_akka_persistence_query_EventEnvelope_descriptor;
        }
  
        @java.lang.Override
        protected akka.protobufv3.internal.GeneratedMessageV3.FieldAccessorTable
            internalGetFieldAccessorTable() {
          return akka.persistence.query.internal.protobuf.QueryMessages
              .internal_static_akka_persistence_query_EventEnvelope_fieldAccessorTable
              .ensureFieldAccessorsInitialized(
                  akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope.class,
                  akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope.Builder.class);
        }
  
        // Construct using
        // akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope.newBuilder()
        private Builder() {
          maybeForceBuilderInitialization();
        }
  
        private Builder(akka.protobufv3.internal.GeneratedMessageV3.BuilderParent parent) {
          super(parent);
          maybeForceBuilderInitialization();
        }
  
        private void maybeForceBuilderInitialization() {
          if (akka.protobufv3.internal.GeneratedMessageV3.alwaysUseFieldBuilders) {
            getEventFieldBuilder();
            getMetadataFieldBuilder();
          }
        }
  
        @java.lang.Override
        public Builder clear() {
          super.clear();
          bitField0_ = 0;
          persistenceId_ = "";
          entityType_ = "";
          slice_ = 0;
          sequenceNr_ = 0L;
          timestamp_ = 0L;
          offset_ = "";
          offsetManifest_ = "";
          event_ = null;
          if (eventBuilder_ != null) {
            eventBuilder_.dispose();
            eventBuilder_ = null;
          }
          metadata_ = null;
          if (metadataBuilder_ != null) {
            metadataBuilder_.dispose();
            metadataBuilder_ = null;
          }
          filtered_ = false;
          source_ = "";
          tags_ = akka.protobufv3.internal.LazyStringArrayList.emptyList();
          return this;
        }
  
        @java.lang.Override
        public akka.protobufv3.internal.Descriptors.Descriptor getDescriptorForType() {
          return akka.persistence.query.internal.protobuf.QueryMessages
              .internal_static_akka_persistence_query_EventEnvelope_descriptor;
        }
  
        @java.lang.Override
        public akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope
            getDefaultInstanceForType() {
          return akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope
              .getDefaultInstance();
        }
  
        @java.lang.Override
        public akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope build() {
          akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope result =
              buildPartial();
          if (!result.isInitialized()) {
            throw newUninitializedMessageException(result);
          }
          return result;
        }
  
        @java.lang.Override
        public akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope buildPartial() {
          akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope result =
              new akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope(this);
          if (bitField0_ != 0) {
            buildPartial0(result);
          }
          onBuilt();
          return result;
        }
  
        private void buildPartial0(
            akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope result) {
          int from_bitField0_ = bitField0_;
          int to_bitField0_ = 0;
          if (((from_bitField0_ & 0x00000001) != 0)) {
            result.persistenceId_ = persistenceId_;
            to_bitField0_ |= 0x00000001;
          }
          if (((from_bitField0_ & 0x00000002) != 0)) {
            result.entityType_ = entityType_;
            to_bitField0_ |= 0x00000002;
          }
          if (((from_bitField0_ & 0x00000004) != 0)) {
            result.slice_ = slice_;
            to_bitField0_ |= 0x00000004;
          }
          if (((from_bitField0_ & 0x00000008) != 0)) {
            result.sequenceNr_ = sequenceNr_;
            to_bitField0_ |= 0x00000008;
          }
          if (((from_bitField0_ & 0x00000010) != 0)) {
            result.timestamp_ = timestamp_;
            to_bitField0_ |= 0x00000010;
          }
          if (((from_bitField0_ & 0x00000020) != 0)) {
            result.offset_ = offset_;
            to_bitField0_ |= 0x00000020;
          }
          if (((from_bitField0_ & 0x00000040) != 0)) {
            result.offsetManifest_ = offsetManifest_;
            to_bitField0_ |= 0x00000040;
          }
          if (((from_bitField0_ & 0x00000080) != 0)) {
            result.event_ = eventBuilder_ == null ? event_ : eventBuilder_.build();
            to_bitField0_ |= 0x00000080;
          }
          if (((from_bitField0_ & 0x00000100) != 0)) {
            result.metadata_ = metadataBuilder_ == null ? metadata_ : metadataBuilder_.build();
            to_bitField0_ |= 0x00000100;
          }
          if (((from_bitField0_ & 0x00000200) != 0)) {
            result.filtered_ = filtered_;
            to_bitField0_ |= 0x00000200;
          }
          if (((from_bitField0_ & 0x00000400) != 0)) {
            result.source_ = source_;
            to_bitField0_ |= 0x00000400;
          }
          if (((from_bitField0_ & 0x00000800) != 0)) {
            tags_.makeImmutable();
            result.tags_ = tags_;
          }
          result.bitField0_ |= to_bitField0_;
        }
  
        @java.lang.Override
        public Builder clone() {
          return super.clone();
        }
  
        @java.lang.Override
        public Builder setField(
            akka.protobufv3.internal.Descriptors.FieldDescriptor field, java.lang.Object value) {
          return super.setField(field, value);
        }
  
        @java.lang.Override
        public Builder clearField(akka.protobufv3.internal.Descriptors.FieldDescriptor field) {
          return super.clearField(field);
        }
  
        @java.lang.Override
        public Builder clearOneof(akka.protobufv3.internal.Descriptors.OneofDescriptor oneof) {
          return super.clearOneof(oneof);
        }
  
        @java.lang.Override
        public Builder setRepeatedField(
            akka.protobufv3.internal.Descriptors.FieldDescriptor field,
            int index,
            java.lang.Object value) {
          return super.setRepeatedField(field, index, value);
        }
  
        @java.lang.Override
        public Builder addRepeatedField(
            akka.protobufv3.internal.Descriptors.FieldDescriptor field, java.lang.Object value) {
          return super.addRepeatedField(field, value);
        }
  
        @java.lang.Override
        public Builder mergeFrom(akka.protobufv3.internal.Message other) {
          if (other instanceof akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope) {
            return mergeFrom(
                (akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope) other);
          } else {
            super.mergeFrom(other);
            return this;
          }
        }
  
        public Builder mergeFrom(
            akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope other) {
          if (other
              == akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope
                  .getDefaultInstance()) return this;
          if (other.hasPersistenceId()) {
            persistenceId_ = other.persistenceId_;
            bitField0_ |= 0x00000001;
            onChanged();
          }
          if (other.hasEntityType()) {
            entityType_ = other.entityType_;
            bitField0_ |= 0x00000002;
            onChanged();
          }
          if (other.hasSlice()) {
            setSlice(other.getSlice());
          }
          if (other.hasSequenceNr()) {
            setSequenceNr(other.getSequenceNr());
          }
          if (other.hasTimestamp()) {
            setTimestamp(other.getTimestamp());
          }
          if (other.hasOffset()) {
            offset_ = other.offset_;
            bitField0_ |= 0x00000020;
            onChanged();
          }
          if (other.hasOffsetManifest()) {
            offsetManifest_ = other.offsetManifest_;
            bitField0_ |= 0x00000040;
            onChanged();
          }
          if (other.hasEvent()) {
            mergeEvent(other.getEvent());
          }
          if (other.hasMetadata()) {
            mergeMetadata(other.getMetadata());
          }
          if (other.hasFiltered()) {
            setFiltered(other.getFiltered());
          }
          if (other.hasSource()) {
            source_ = other.source_;
            bitField0_ |= 0x00000400;
            onChanged();
          }
          if (!other.tags_.isEmpty()) {
            if (tags_.isEmpty()) {
              tags_ = other.tags_;
              bitField0_ |= 0x00000800;
            } else {
              ensureTagsIsMutable();
              tags_.addAll(other.tags_);
            }
            onChanged();
          }
          this.mergeUnknownFields(other.getUnknownFields());
          onChanged();
          return this;
        }
  
        @java.lang.Override
        public final boolean isInitialized() {
          if (!hasPersistenceId()) {
            return false;
          }
          if (!hasEntityType()) {
            return false;
          }
          if (!hasSlice()) {
            return false;
          }
          if (!hasSequenceNr()) {
            return false;
          }
          if (!hasTimestamp()) {
            return false;
          }
          if (!hasOffset()) {
            return false;
          }
          if (!hasOffsetManifest()) {
            return false;
          }
          if (hasEvent()) {
            if (!getEvent().isInitialized()) {
              return false;
            }
          }
          if (hasMetadata()) {
            if (!getMetadata().isInitialized()) {
              return false;
            }
          }
          return true;
        }
  
        @java.lang.Override
        public Builder mergeFrom(
            akka.protobufv3.internal.CodedInputStream input,
            akka.protobufv3.internal.ExtensionRegistryLite extensionRegistry)
            throws java.io.IOException {
          if (extensionRegistry == null) {
            throw new java.lang.NullPointerException();
          }
          try {
            boolean done = false;
            while (!done) {
              int tag = input.readTag();
              switch (tag) {
                case 0:
                  done = true;
                  break;
                case 10:
                  {
                    persistenceId_ = input.readBytes();
                    bitField0_ |= 0x00000001;
                    break;
                  } // case 10
                case 18:
                  {
                    entityType_ = input.readBytes();
                    bitField0_ |= 0x00000002;
                    break;
                  } // case 18
                case 24:
                  {
                    slice_ = input.readInt32();
                    bitField0_ |= 0x00000004;
                    break;
                  } // case 24
                case 32:
                  {
                    sequenceNr_ = input.readInt64();
                    bitField0_ |= 0x00000008;
                    break;
                  } // case 32
                case 40:
                  {
                    timestamp_ = input.readInt64();
                    bitField0_ |= 0x00000010;
                    break;
                  } // case 40
                case 50:
                  {
                    offset_ = input.readBytes();
                    bitField0_ |= 0x00000020;
                    break;
                  } // case 50
                case 58:
                  {
                    offsetManifest_ = input.readBytes();
                    bitField0_ |= 0x00000040;
                    break;
                  } // case 58
                case 66:
                  {
                    input.readMessage(getEventFieldBuilder().getBuilder(), extensionRegistry);
                    bitField0_ |= 0x00000080;
                    break;
                  } // case 66
                case 74:
                  {
                    input.readMessage(getMetadataFieldBuilder().getBuilder(), extensionRegistry);
                    bitField0_ |= 0x00000100;
                    break;
                  } // case 74
                case 80:
                  {
                    filtered_ = input.readBool();
                    bitField0_ |= 0x00000200;
                    break;
                  } // case 80
                case 90:
                  {
                    source_ = input.readBytes();
                    bitField0_ |= 0x00000400;
                    break;
                  } // case 90
                case 98:
                  {
                    akka.protobufv3.internal.ByteString bs = input.readBytes();
                    ensureTagsIsMutable();
                    tags_.add(bs);
                    break;
                  } // case 98
                default:
                  {
                    if (!super.parseUnknownField(input, extensionRegistry, tag)) {
                      done = true; // was an endgroup tag
                    }
                    break;
                  } // default:
              } // switch (tag)
            } // while (!done)
          } catch (akka.protobufv3.internal.InvalidProtocolBufferException e) {
            throw e.unwrapIOException();
          } finally {
            onChanged();
          } // finally
          return this;
        }
  
        private int bitField0_;
  
        private java.lang.Object persistenceId_ = "";
        /**
         * <code>required string persistence_id = 1;</code>
         *
         * @return Whether the persistenceId field is set.
         */
        public boolean hasPersistenceId() {
          return ((bitField0_ & 0x00000001) != 0);
        }
        /**
         * <code>required string persistence_id = 1;</code>
         *
         * @return The persistenceId.
         */
        public java.lang.String getPersistenceId() {
          java.lang.Object ref = persistenceId_;
          if (!(ref instanceof java.lang.String)) {
            akka.protobufv3.internal.ByteString bs = (akka.protobufv3.internal.ByteString) ref;
            java.lang.String s = bs.toStringUtf8();
            if (bs.isValidUtf8()) {
              persistenceId_ = s;
            }
            return s;
          } else {
            return (java.lang.String) ref;
          }
        }
        /**
         * <code>required string persistence_id = 1;</code>
         *
         * @return The bytes for persistenceId.
         */
        public akka.protobufv3.internal.ByteString getPersistenceIdBytes() {
          java.lang.Object ref = persistenceId_;
          if (ref instanceof String) {
            akka.protobufv3.internal.ByteString b =
                akka.protobufv3.internal.ByteString.copyFromUtf8((java.lang.String) ref);
            persistenceId_ = b;
            return b;
          } else {
            return (akka.protobufv3.internal.ByteString) ref;
          }
        }
        /**
         * <code>required string persistence_id = 1;</code>
         *
         * @param value The persistenceId to set.
         * @return This builder for chaining.
         */
        public Builder setPersistenceId(java.lang.String value) {
          if (value == null) {
            throw new NullPointerException();
          }
          persistenceId_ = value;
          bitField0_ |= 0x00000001;
          onChanged();
          return this;
        }
        /**
         * <code>required string persistence_id = 1;</code>
         *
         * @return This builder for chaining.
         */
        public Builder clearPersistenceId() {
          persistenceId_ = getDefaultInstance().getPersistenceId();
          bitField0_ = (bitField0_ & ~0x00000001);
          onChanged();
          return this;
        }
        /**
         * <code>required string persistence_id = 1;</code>
         *
         * @param value The bytes for persistenceId to set.
         * @return This builder for chaining.
         */
        public Builder setPersistenceIdBytes(akka.protobufv3.internal.ByteString value) {
          if (value == null) {
            throw new NullPointerException();
          }
          persistenceId_ = value;
          bitField0_ |= 0x00000001;
          onChanged();
          return this;
        }
  
        private java.lang.Object entityType_ = "";
        /**
         * <code>required string entity_type = 2;</code>
         *
         * @return Whether the entityType field is set.
         */
        public boolean hasEntityType() {
          return ((bitField0_ & 0x00000002) != 0);
        }
        /**
         * <code>required string entity_type = 2;</code>
         *
         * @return The entityType.
         */
        public java.lang.String getEntityType() {
          java.lang.Object ref = entityType_;
          if (!(ref instanceof java.lang.String)) {
            akka.protobufv3.internal.ByteString bs = (akka.protobufv3.internal.ByteString) ref;
            java.lang.String s = bs.toStringUtf8();
            if (bs.isValidUtf8()) {
              entityType_ = s;
            }
            return s;
          } else {
            return (java.lang.String) ref;
          }
        }
        /**
         * <code>required string entity_type = 2;</code>
         *
         * @return The bytes for entityType.
         */
        public akka.protobufv3.internal.ByteString getEntityTypeBytes() {
          java.lang.Object ref = entityType_;
          if (ref instanceof String) {
            akka.protobufv3.internal.ByteString b =
                akka.protobufv3.internal.ByteString.copyFromUtf8((java.lang.String) ref);
            entityType_ = b;
            return b;
          } else {
            return (akka.protobufv3.internal.ByteString) ref;
          }
        }
        /**
         * <code>required string entity_type = 2;</code>
         *
         * @param value The entityType to set.
         * @return This builder for chaining.
         */
        public Builder setEntityType(java.lang.String value) {
          if (value == null) {
            throw new NullPointerException();
          }
          entityType_ = value;
          bitField0_ |= 0x00000002;
          onChanged();
          return this;
        }
        /**
         * <code>required string entity_type = 2;</code>
         *
         * @return This builder for chaining.
         */
        public Builder clearEntityType() {
          entityType_ = getDefaultInstance().getEntityType();
          bitField0_ = (bitField0_ & ~0x00000002);
          onChanged();
          return this;
        }
        /**
         * <code>required string entity_type = 2;</code>
         *
         * @param value The bytes for entityType to set.
         * @return This builder for chaining.
         */
        public Builder setEntityTypeBytes(akka.protobufv3.internal.ByteString value) {
          if (value == null) {
            throw new NullPointerException();
          }
          entityType_ = value;
          bitField0_ |= 0x00000002;
          onChanged();
          return this;
        }
  
        private int slice_;
        /**
         * <code>required int32 slice = 3;</code>
         *
         * @return Whether the slice field is set.
         */
        @java.lang.Override
        public boolean hasSlice() {
          return ((bitField0_ & 0x00000004) != 0);
        }
        /**
         * <code>required int32 slice = 3;</code>
         *
         * @return The slice.
         */
        @java.lang.Override
        public int getSlice() {
          return slice_;
        }
        /**
         * <code>required int32 slice = 3;</code>
         *
         * @param value The slice to set.
         * @return This builder for chaining.
         */
        public Builder setSlice(int value) {
  
          slice_ = value;
          bitField0_ |= 0x00000004;
          onChanged();
          return this;
        }
        /**
         * <code>required int32 slice = 3;</code>
         *
         * @return This builder for chaining.
         */
        public Builder clearSlice() {
          bitField0_ = (bitField0_ & ~0x00000004);
          slice_ = 0;
          onChanged();
          return this;
        }
  
        private long sequenceNr_;
        /**
         * <code>required int64 sequence_nr = 4;</code>
         *
         * @return Whether the sequenceNr field is set.
         */
        @java.lang.Override
        public boolean hasSequenceNr() {
          return ((bitField0_ & 0x00000008) != 0);
        }
        /**
         * <code>required int64 sequence_nr = 4;</code>
         *
         * @return The sequenceNr.
         */
        @java.lang.Override
        public long getSequenceNr() {
          return sequenceNr_;
        }
        /**
         * <code>required int64 sequence_nr = 4;</code>
         *
         * @param value The sequenceNr to set.
         * @return This builder for chaining.
         */
        public Builder setSequenceNr(long value) {
  
          sequenceNr_ = value;
          bitField0_ |= 0x00000008;
          onChanged();
          return this;
        }
        /**
         * <code>required int64 sequence_nr = 4;</code>
         *
         * @return This builder for chaining.
         */
        public Builder clearSequenceNr() {
          bitField0_ = (bitField0_ & ~0x00000008);
          sequenceNr_ = 0L;
          onChanged();
          return this;
        }
  
        private long timestamp_;
        /**
         * <code>required int64 timestamp = 5;</code>
         *
         * @return Whether the timestamp field is set.
         */
        @java.lang.Override
        public boolean hasTimestamp() {
          return ((bitField0_ & 0x00000010) != 0);
        }
        /**
         * <code>required int64 timestamp = 5;</code>
         *
         * @return The timestamp.
         */
        @java.lang.Override
        public long getTimestamp() {
          return timestamp_;
        }
        /**
         * <code>required int64 timestamp = 5;</code>
         *
         * @param value The timestamp to set.
         * @return This builder for chaining.
         */
        public Builder setTimestamp(long value) {
  
          timestamp_ = value;
          bitField0_ |= 0x00000010;
          onChanged();
          return this;
        }
        /**
         * <code>required int64 timestamp = 5;</code>
         *
         * @return This builder for chaining.
         */
        public Builder clearTimestamp() {
          bitField0_ = (bitField0_ & ~0x00000010);
          timestamp_ = 0L;
          onChanged();
          return this;
        }
  
        private java.lang.Object offset_ = "";
        /**
         * <code>required string offset = 6;</code>
         *
         * @return Whether the offset field is set.
         */
        public boolean hasOffset() {
          return ((bitField0_ & 0x00000020) != 0);
        }
        /**
         * <code>required string offset = 6;</code>
         *
         * @return The offset.
         */
        public java.lang.String getOffset() {
          java.lang.Object ref = offset_;
          if (!(ref instanceof java.lang.String)) {
            akka.protobufv3.internal.ByteString bs = (akka.protobufv3.internal.ByteString) ref;
            java.lang.String s = bs.toStringUtf8();
            if (bs.isValidUtf8()) {
              offset_ = s;
            }
            return s;
          } else {
            return (java.lang.String) ref;
          }
        }
        /**
         * <code>required string offset = 6;</code>
         *
         * @return The bytes for offset.
         */
        public akka.protobufv3.internal.ByteString getOffsetBytes() {
          java.lang.Object ref = offset_;
          if (ref instanceof String) {
            akka.protobufv3.internal.ByteString b =
                akka.protobufv3.internal.ByteString.copyFromUtf8((java.lang.String) ref);
            offset_ = b;
            return b;
          } else {
            return (akka.protobufv3.internal.ByteString) ref;
          }
        }
        /**
         * <code>required string offset = 6;</code>
         *
         * @param value The offset to set.
         * @return This builder for chaining.
         */
        public Builder setOffset(java.lang.String value) {
          if (value == null) {
            throw new NullPointerException();
          }
          offset_ = value;
          bitField0_ |= 0x00000020;
          onChanged();
          return this;
        }
        /**
         * <code>required string offset = 6;</code>
         *
         * @return This builder for chaining.
         */
        public Builder clearOffset() {
          offset_ = getDefaultInstance().getOffset();
          bitField0_ = (bitField0_ & ~0x00000020);
          onChanged();
          return this;
        }
        /**
         * <code>required string offset = 6;</code>
         *
         * @param value The bytes for offset to set.
         * @return This builder for chaining.
         */
        public Builder setOffsetBytes(akka.protobufv3.internal.ByteString value) {
          if (value == null) {
            throw new NullPointerException();
          }
          offset_ = value;
          bitField0_ |= 0x00000020;
          onChanged();
          return this;
        }
  
        private java.lang.Object offsetManifest_ = "";
        /**
         * <code>required string offset_manifest = 7;</code>
         *
         * @return Whether the offsetManifest field is set.
         */
        public boolean hasOffsetManifest() {
          return ((bitField0_ & 0x00000040) != 0);
        }
        /**
         * <code>required string offset_manifest = 7;</code>
         *
         * @return The offsetManifest.
         */
        public java.lang.String getOffsetManifest() {
          java.lang.Object ref = offsetManifest_;
          if (!(ref instanceof java.lang.String)) {
            akka.protobufv3.internal.ByteString bs = (akka.protobufv3.internal.ByteString) ref;
            java.lang.String s = bs.toStringUtf8();
            if (bs.isValidUtf8()) {
              offsetManifest_ = s;
            }
            return s;
          } else {
            return (java.lang.String) ref;
          }
        }
        /**
         * <code>required string offset_manifest = 7;</code>
         *
         * @return The bytes for offsetManifest.
         */
        public akka.protobufv3.internal.ByteString getOffsetManifestBytes() {
          java.lang.Object ref = offsetManifest_;
          if (ref instanceof String) {
            akka.protobufv3.internal.ByteString b =
                akka.protobufv3.internal.ByteString.copyFromUtf8((java.lang.String) ref);
            offsetManifest_ = b;
            return b;
          } else {
            return (akka.protobufv3.internal.ByteString) ref;
          }
        }
        /**
         * <code>required string offset_manifest = 7;</code>
         *
         * @param value The offsetManifest to set.
         * @return This builder for chaining.
         */
        public Builder setOffsetManifest(java.lang.String value) {
          if (value == null) {
            throw new NullPointerException();
          }
          offsetManifest_ = value;
          bitField0_ |= 0x00000040;
          onChanged();
          return this;
        }
        /**
         * <code>required string offset_manifest = 7;</code>
         *
         * @return This builder for chaining.
         */
        public Builder clearOffsetManifest() {
          offsetManifest_ = getDefaultInstance().getOffsetManifest();
          bitField0_ = (bitField0_ & ~0x00000040);
          onChanged();
          return this;
        }
        /**
         * <code>required string offset_manifest = 7;</code>
         *
         * @param value The bytes for offsetManifest to set.
         * @return This builder for chaining.
         */
        public Builder setOffsetManifestBytes(akka.protobufv3.internal.ByteString value) {
          if (value == null) {
            throw new NullPointerException();
          }
          offsetManifest_ = value;
          bitField0_ |= 0x00000040;
          onChanged();
          return this;
        }
  
        private akka.remote.ContainerFormats.Payload event_;
        private akka.protobufv3.internal.SingleFieldBuilderV3<
                akka.remote.ContainerFormats.Payload,
                akka.remote.ContainerFormats.Payload.Builder,
                akka.remote.ContainerFormats.PayloadOrBuilder>
            eventBuilder_;
        /**
         * <code>optional .Payload event = 8;</code>
         *
         * @return Whether the event field is set.
         */
        public boolean hasEvent() {
          return ((bitField0_ & 0x00000080) != 0);
        }
        /**
         * <code>optional .Payload event = 8;</code>
         *
         * @return The event.
         */
        public akka.remote.ContainerFormats.Payload getEvent() {
          if (eventBuilder_ == null) {
            return event_ == null
                ? akka.remote.ContainerFormats.Payload.getDefaultInstance()
                : event_;
          } else {
            return eventBuilder_.getMessage();
          }
        }
        /** <code>optional .Payload event = 8;</code> */
        public Builder setEvent(akka.remote.ContainerFormats.Payload value) {
          if (eventBuilder_ == null) {
            if (value == null) {
              throw new NullPointerException();
            }
            event_ = value;
          } else {
            eventBuilder_.setMessage(value);
          }
          bitField0_ |= 0x00000080;
          onChanged();
          return this;
        }
        /** <code>optional .Payload event = 8;</code> */
        public Builder setEvent(akka.remote.ContainerFormats.Payload.Builder builderForValue) {
          if (eventBuilder_ == null) {
            event_ = builderForValue.build();
          } else {
            eventBuilder_.setMessage(builderForValue.build());
          }
          bitField0_ |= 0x00000080;
          onChanged();
          return this;
        }
        /** <code>optional .Payload event = 8;</code> */
        public Builder mergeEvent(akka.remote.ContainerFormats.Payload value) {
          if (eventBuilder_ == null) {
            if (((bitField0_ & 0x00000080) != 0)
                && event_ != null
                && event_ != akka.remote.ContainerFormats.Payload.getDefaultInstance()) {
              getEventBuilder().mergeFrom(value);
            } else {
              event_ = value;
            }
          } else {
            eventBuilder_.mergeFrom(value);
          }
          if (event_ != null) {
            bitField0_ |= 0x00000080;
            onChanged();
          }
          return this;
        }
        /** <code>optional .Payload event = 8;</code> */
        public Builder clearEvent() {
          bitField0_ = (bitField0_ & ~0x00000080);
          event_ = null;
          if (eventBuilder_ != null) {
            eventBuilder_.dispose();
            eventBuilder_ = null;
          }
          onChanged();
          return this;
        }
        /** <code>optional .Payload event = 8;</code> */
        public akka.remote.ContainerFormats.Payload.Builder getEventBuilder() {
          bitField0_ |= 0x00000080;
          onChanged();
          return getEventFieldBuilder().getBuilder();
        }
        /** <code>optional .Payload event = 8;</code> */
        public akka.remote.ContainerFormats.PayloadOrBuilder getEventOrBuilder() {
          if (eventBuilder_ != null) {
            return eventBuilder_.getMessageOrBuilder();
          } else {
            return event_ == null
                ? akka.remote.ContainerFormats.Payload.getDefaultInstance()
                : event_;
          }
        }
        /** <code>optional .Payload event = 8;</code> */
        private akka.protobufv3.internal.SingleFieldBuilderV3<
                akka.remote.ContainerFormats.Payload,
                akka.remote.ContainerFormats.Payload.Builder,
                akka.remote.ContainerFormats.PayloadOrBuilder>
            getEventFieldBuilder() {
          if (eventBuilder_ == null) {
            eventBuilder_ =
                new akka.protobufv3.internal.SingleFieldBuilderV3<
                    akka.remote.ContainerFormats.Payload,
                    akka.remote.ContainerFormats.Payload.Builder,
                    akka.remote.ContainerFormats.PayloadOrBuilder>(
                    getEvent(), getParentForChildren(), isClean());
            event_ = null;
          }
          return eventBuilder_;
        }
  
        private akka.remote.ContainerFormats.Payload metadata_;
        private akka.protobufv3.internal.SingleFieldBuilderV3<
                akka.remote.ContainerFormats.Payload,
                akka.remote.ContainerFormats.Payload.Builder,
                akka.remote.ContainerFormats.PayloadOrBuilder>
            metadataBuilder_;
        /**
         * <code>optional .Payload metadata = 9;</code>
         *
         * @return Whether the metadata field is set.
         */
        public boolean hasMetadata() {
          return ((bitField0_ & 0x00000100) != 0);
        }
        /**
         * <code>optional .Payload metadata = 9;</code>
         *
         * @return The metadata.
         */
        public akka.remote.ContainerFormats.Payload getMetadata() {
          if (metadataBuilder_ == null) {
            return metadata_ == null
                ? akka.remote.ContainerFormats.Payload.getDefaultInstance()
                : metadata_;
          } else {
            return metadataBuilder_.getMessage();
          }
        }
        /** <code>optional .Payload metadata = 9;</code> */
        public Builder setMetadata(akka.remote.ContainerFormats.Payload value) {
          if (metadataBuilder_ == null) {
            if (value == null) {
              throw new NullPointerException();
            }
            metadata_ = value;
          } else {
            metadataBuilder_.setMessage(value);
          }
          bitField0_ |= 0x00000100;
          onChanged();
          return this;
        }
        /** <code>optional .Payload metadata = 9;</code> */
        public Builder setMetadata(akka.remote.ContainerFormats.Payload.Builder builderForValue) {
          if (metadataBuilder_ == null) {
            metadata_ = builderForValue.build();
          } else {
            metadataBuilder_.setMessage(builderForValue.build());
          }
          bitField0_ |= 0x00000100;
          onChanged();
          return this;
        }
        /** <code>optional .Payload metadata = 9;</code> */
        public Builder mergeMetadata(akka.remote.ContainerFormats.Payload value) {
          if (metadataBuilder_ == null) {
            if (((bitField0_ & 0x00000100) != 0)
                && metadata_ != null
                && metadata_ != akka.remote.ContainerFormats.Payload.getDefaultInstance()) {
              getMetadataBuilder().mergeFrom(value);
            } else {
              metadata_ = value;
            }
          } else {
            metadataBuilder_.mergeFrom(value);
          }
          if (metadata_ != null) {
            bitField0_ |= 0x00000100;
            onChanged();
          }
          return this;
        }
        /** <code>optional .Payload metadata = 9;</code> */
        public Builder clearMetadata() {
          bitField0_ = (bitField0_ & ~0x00000100);
          metadata_ = null;
          if (metadataBuilder_ != null) {
            metadataBuilder_.dispose();
            metadataBuilder_ = null;
          }
          onChanged();
          return this;
        }
        /** <code>optional .Payload metadata = 9;</code> */
        public akka.remote.ContainerFormats.Payload.Builder getMetadataBuilder() {
          bitField0_ |= 0x00000100;
          onChanged();
          return getMetadataFieldBuilder().getBuilder();
        }
        /** <code>optional .Payload metadata = 9;</code> */
        public akka.remote.ContainerFormats.PayloadOrBuilder getMetadataOrBuilder() {
          if (metadataBuilder_ != null) {
            return metadataBuilder_.getMessageOrBuilder();
          } else {
            return metadata_ == null
                ? akka.remote.ContainerFormats.Payload.getDefaultInstance()
                : metadata_;
          }
        }
        /** <code>optional .Payload metadata = 9;</code> */
        private akka.protobufv3.internal.SingleFieldBuilderV3<
                akka.remote.ContainerFormats.Payload,
                akka.remote.ContainerFormats.Payload.Builder,
                akka.remote.ContainerFormats.PayloadOrBuilder>
            getMetadataFieldBuilder() {
          if (metadataBuilder_ == null) {
            metadataBuilder_ =
                new akka.protobufv3.internal.SingleFieldBuilderV3<
                    akka.remote.ContainerFormats.Payload,
                    akka.remote.ContainerFormats.Payload.Builder,
                    akka.remote.ContainerFormats.PayloadOrBuilder>(
                    getMetadata(), getParentForChildren(), isClean());
            metadata_ = null;
          }
          return metadataBuilder_;
        }
  
        private boolean filtered_;
        /**
         * <code>optional bool filtered = 10;</code>
         *
         * @return Whether the filtered field is set.
         */
        @java.lang.Override
        public boolean hasFiltered() {
          return ((bitField0_ & 0x00000200) != 0);
        }
        /**
         * <code>optional bool filtered = 10;</code>
         *
         * @return The filtered.
         */
        @java.lang.Override
        public boolean getFiltered() {
          return filtered_;
        }
        /**
         * <code>optional bool filtered = 10;</code>
         *
         * @param value The filtered to set.
         * @return This builder for chaining.
         */
        public Builder setFiltered(boolean value) {
  
          filtered_ = value;
          bitField0_ |= 0x00000200;
          onChanged();
          return this;
        }
        /**
         * <code>optional bool filtered = 10;</code>
         *
         * @return This builder for chaining.
         */
        public Builder clearFiltered() {
          bitField0_ = (bitField0_ & ~0x00000200);
          filtered_ = false;
          onChanged();
          return this;
        }
  
        private java.lang.Object source_ = "";
        /**
         * <code>optional string source = 11;</code>
         *
         * @return Whether the source field is set.
         */
        public boolean hasSource() {
          return ((bitField0_ & 0x00000400) != 0);
        }
        /**
         * <code>optional string source = 11;</code>
         *
         * @return The source.
         */
        public java.lang.String getSource() {
          java.lang.Object ref = source_;
          if (!(ref instanceof java.lang.String)) {
            akka.protobufv3.internal.ByteString bs = (akka.protobufv3.internal.ByteString) ref;
            java.lang.String s = bs.toStringUtf8();
            if (bs.isValidUtf8()) {
              source_ = s;
            }
            return s;
          } else {
            return (java.lang.String) ref;
          }
        }
        /**
         * <code>optional string source = 11;</code>
         *
         * @return The bytes for source.
         */
        public akka.protobufv3.internal.ByteString getSourceBytes() {
          java.lang.Object ref = source_;
          if (ref instanceof String) {
            akka.protobufv3.internal.ByteString b =
                akka.protobufv3.internal.ByteString.copyFromUtf8((java.lang.String) ref);
            source_ = b;
            return b;
          } else {
            return (akka.protobufv3.internal.ByteString) ref;
          }
        }
        /**
         * <code>optional string source = 11;</code>
         *
         * @param value The source to set.
         * @return This builder for chaining.
         */
        public Builder setSource(java.lang.String value) {
          if (value == null) {
            throw new NullPointerException();
          }
          source_ = value;
          bitField0_ |= 0x00000400;
          onChanged();
          return this;
        }
        /**
         * <code>optional string source = 11;</code>
         *
         * @return This builder for chaining.
         */
        public Builder clearSource() {
          source_ = getDefaultInstance().getSource();
          bitField0_ = (bitField0_ & ~0x00000400);
          onChanged();
          return this;
        }
        /**
         * <code>optional string source = 11;</code>
         *
         * @param value The bytes for source to set.
         * @return This builder for chaining.
         */
        public Builder setSourceBytes(akka.protobufv3.internal.ByteString value) {
          if (value == null) {
            throw new NullPointerException();
          }
          source_ = value;
          bitField0_ |= 0x00000400;
          onChanged();
          return this;
        }
  
        private akka.protobufv3.internal.LazyStringArrayList tags_ =
            akka.protobufv3.internal.LazyStringArrayList.emptyList();
  
        private void ensureTagsIsMutable() {
          if (!tags_.isModifiable()) {
            tags_ = new akka.protobufv3.internal.LazyStringArrayList(tags_);
          }
          bitField0_ |= 0x00000800;
        }
        /**
         * <code>repeated string tags = 12;</code>
         *
         * @return A list containing the tags.
         */
        public akka.protobufv3.internal.ProtocolStringList getTagsList() {
          tags_.makeImmutable();
          return tags_;
        }
        /**
         * <code>repeated string tags = 12;</code>
         *
         * @return The count of tags.
         */
        public int getTagsCount() {
          return tags_.size();
        }
        /**
         * <code>repeated string tags = 12;</code>
         *
         * @param index The index of the element to return.
         * @return The tags at the given index.
         */
        public java.lang.String getTags(int index) {
          return tags_.get(index);
        }
        /**
         * <code>repeated string tags = 12;</code>
         *
         * @param index The index of the value to return.
         * @return The bytes of the tags at the given index.
         */
        public akka.protobufv3.internal.ByteString getTagsBytes(int index) {
          return tags_.getByteString(index);
        }
        /**
         * <code>repeated string tags = 12;</code>
         *
         * @param index The index to set the value at.
         * @param value The tags to set.
         * @return This builder for chaining.
         */
        public Builder setTags(int index, java.lang.String value) {
          if (value == null) {
            throw new NullPointerException();
          }
          ensureTagsIsMutable();
          tags_.set(index, value);
          bitField0_ |= 0x00000800;
          onChanged();
          return this;
        }
        /**
         * <code>repeated string tags = 12;</code>
         *
         * @param value The tags to add.
         * @return This builder for chaining.
         */
        public Builder addTags(java.lang.String value) {
          if (value == null) {
            throw new NullPointerException();
          }
          ensureTagsIsMutable();
          tags_.add(value);
          bitField0_ |= 0x00000800;
          onChanged();
          return this;
        }
        /**
         * <code>repeated string tags = 12;</code>
         *
         * @param values The tags to add.
         * @return This builder for chaining.
         */
        public Builder addAllTags(java.lang.Iterable<java.lang.String> values) {
          ensureTagsIsMutable();
          akka.protobufv3.internal.AbstractMessageLite.Builder.addAll(values, tags_);
          bitField0_ |= 0x00000800;
          onChanged();
          return this;
        }
        /**
         * <code>repeated string tags = 12;</code>
         *
         * @return This builder for chaining.
         */
        public Builder clearTags() {
          tags_ = akka.protobufv3.internal.LazyStringArrayList.emptyList();
          bitField0_ = (bitField0_ & ~0x00000800);
          ;
          onChanged();
          return this;
        }
        /**
         * <code>repeated string tags = 12;</code>
         *
         * @param value The bytes of the tags to add.
         * @return This builder for chaining.
         */
        public Builder addTagsBytes(akka.protobufv3.internal.ByteString value) {
          if (value == null) {
            throw new NullPointerException();
          }
          ensureTagsIsMutable();
          tags_.add(value);
          bitField0_ |= 0x00000800;
          onChanged();
          return this;
        }
  
        @java.lang.Override
        public final Builder setUnknownFields(
            final akka.protobufv3.internal.UnknownFieldSet unknownFields) {
          return super.setUnknownFields(unknownFields);
        }
  
        @java.lang.Override
        public final Builder mergeUnknownFields(
            final akka.protobufv3.internal.UnknownFieldSet unknownFields) {
          return super.mergeUnknownFields(unknownFields);
        }
  
        // @@protoc_insertion_point(builder_scope:akka.persistence.query.EventEnvelope)
      }
  
      // @@protoc_insertion_point(class_scope:akka.persistence.query.EventEnvelope)
      private static final akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope
          DEFAULT_INSTANCE;
  
      static {
        DEFAULT_INSTANCE = new akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope();
      }
  
      public static akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope
          getDefaultInstance() {
        return DEFAULT_INSTANCE;
      }
  
      @java.lang.Deprecated
      public static final akka.protobufv3.internal.Parser<EventEnvelope> PARSER =
          new akka.protobufv3.internal.AbstractParser<EventEnvelope>() {
            @java.lang.Override
            public EventEnvelope parsePartialFrom(
                akka.protobufv3.internal.CodedInputStream input,
                akka.protobufv3.internal.ExtensionRegistryLite extensionRegistry)
                throws akka.protobufv3.internal.InvalidProtocolBufferException {
              Builder builder = newBuilder();
              try {
                builder.mergeFrom(input, extensionRegistry);
              } catch (akka.protobufv3.internal.InvalidProtocolBufferException e) {
                throw e.setUnfinishedMessage(builder.buildPartial());
              } catch (akka.protobufv3.internal.UninitializedMessageException e) {
                throw e.asInvalidProtocolBufferException()
                    .setUnfinishedMessage(builder.buildPartial());
              } catch (java.io.IOException e) {
                throw new akka.protobufv3.internal.InvalidProtocolBufferException(e)
                    .setUnfinishedMessage(builder.buildPartial());
              }
              return builder.buildPartial();
            }
          };
  
      public static akka.protobufv3.internal.Parser<EventEnvelope> parser() {
        return PARSER;
      }
  
      @java.lang.Override
      public akka.protobufv3.internal.Parser<EventEnvelope> getParserForType() {
        return PARSER;
      }
  
      @java.lang.Override
      public akka.persistence.query.internal.protobuf.QueryMessages.EventEnvelope
          getDefaultInstanceForType() {
        return DEFAULT_INSTANCE;
      }
    }
  
    private static final akka.protobufv3.internal.Descriptors.Descriptor
        internal_static_akka_persistence_query_EventEnvelope_descriptor;
    private static final akka.protobufv3.internal.GeneratedMessageV3.FieldAccessorTable
        internal_static_akka_persistence_query_EventEnvelope_fieldAccessorTable;
  
    public static akka.protobufv3.internal.Descriptors.FileDescriptor getDescriptor() {
      return descriptor;
    }
  
    private static akka.protobufv3.internal.Descriptors.FileDescriptor descriptor;
  
    static {
      java.lang.String[] descriptorData = {
        "\n\023QueryMessages.proto\022\026akka.persistence."
            + "query\032\026ContainerFormats.proto\"\201\002\n\rEventE"
            + "nvelope\022\026\n\016persistence_id\030\001 \002(\t\022\023\n\013entit"
            + "y_type\030\002 \002(\t\022\r\n\005slice\030\003 \002(\005\022\023\n\013sequence_"
            + "nr\030\004 \002(\003\022\021\n\ttimestamp\030\005 \002(\003\022\016\n\006offset\030\006 "
            + "\002(\t\022\027\n\017offset_manifest\030\007 \002(\t\022\027\n\005event\030\010 "
            + "\001(\0132\010.Payload\022\032\n\010metadata\030\t \001(\0132\010.Payloa"
            + "d\022\020\n\010filtered\030\n \001(\010\022\016\n\006source\030\013 \001(\t\022\014\n\004t"
            + "ags\030\014 \003(\tB,\n(akka.persistence.query.inte"
            + "rnal.protobufH\001"
      };
      descriptor =
          akka.protobufv3.internal.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom(
              descriptorData,
              new akka.protobufv3.internal.Descriptors.FileDescriptor[] {
                akka.remote.ContainerFormats.getDescriptor(),
              });
      internal_static_akka_persistence_query_EventEnvelope_descriptor =
          getDescriptor().getMessageTypes().get(0);
      internal_static_akka_persistence_query_EventEnvelope_fieldAccessorTable =
          new akka.protobufv3.internal.GeneratedMessageV3.FieldAccessorTable(
              internal_static_akka_persistence_query_EventEnvelope_descriptor,
              new java.lang.String[] {
                "PersistenceId",
                "EntityType",
                "Slice",
                "SequenceNr",
                "Timestamp",
                "Offset",
                "OffsetManifest",
                "Event",
                "Metadata",
                "Filtered",
                "Source",
                "Tags",
              });
      akka.remote.ContainerFormats.getDescriptor();
    }
  
    // @@protoc_insertion_point(outer_class_scope)
  }
  