Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
   // Generated by the protocol buffer compiler.  DO NOT EDIT!
   // source: DistributedPubSubMessages.proto
   
   package akka.contrib.pattern.protobuf.msg;
   
   public final class DistributedPubSubMessages {
     private DistributedPubSubMessages() {}
     public static void registerAllExtensions(
         com.google.protobuf.ExtensionRegistry registry) {
    }
    public interface StatusOrBuilder
        extends com.google.protobuf.MessageOrBuilder {
  
      // repeated .Status.Version versions = 1;
      
repeated .Status.Version versions = 1;
  
          getVersionsList();
    
repeated .Status.Version versions = 1;
  
repeated .Status.Version versions = 1;
  
      int getVersionsCount();
    
repeated .Status.Version versions = 1;
  
          getVersionsOrBuilderList();
    
repeated .Status.Version versions = 1;
  
          int index);
    }
  
Protobuf type Status
  
    public static final class Status extends
        implements StatusOrBuilder {
      // Use Status.newBuilder() to construct.
      private Status(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
        super(builder);
        this. = builder.getUnknownFields();
      }
      private Status(boolean noInit) { this. = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }
  
      private static final Status defaultInstance;
      public static Status getDefaultInstance() {
        return ;
      }
  
      public Status getDefaultInstanceForType() {
        return ;
      }
  
      private final com.google.protobuf.UnknownFieldSet unknownFields;
      @java.lang.Override
      public final com.google.protobuf.UnknownFieldSet
          getUnknownFields() {
        return this.;
      }
      private Status(
          com.google.protobuf.CodedInputStream input,
          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
          throws com.google.protobuf.InvalidProtocolBufferException {
        initFields();
        int mutable_bitField0_ = 0;
        com.google.protobuf.UnknownFieldSet.Builder unknownFields =
            com.google.protobuf.UnknownFieldSet.newBuilder();
        try {
          boolean done = false;
          while (!done) {
            int tag = input.readTag();
            switch (tag) {
              case 0:
                done = true;
                break;
              default: {
                if (!parseUnknownField(inputunknownFields,
                                       extensionRegistrytag)) {
                  done = true;
                }
                break;
              }
              case 10: {
                if (!((mutable_bitField0_ & 0x00000001) == 0x00000001)) {
                  mutable_bitField0_ |= 0x00000001;
                }
                .add(input.readMessage(........extensionRegistry));
                break;
              }
            }
          }
       } catch (com.google.protobuf.InvalidProtocolBufferException e) {
         throw e.setUnfinishedMessage(this);
       } catch (java.io.IOException e) {
         throw new com.google.protobuf.InvalidProtocolBufferException(
             e.getMessage()).setUnfinishedMessage(this);
       } finally {
         if (((mutable_bitField0_ & 0x00000001) == 0x00000001)) {
            = java.util.Collections.unmodifiableList();
         }
         this. = unknownFields.build();
         makeExtensionsImmutable();
       }
     }
     public static final com.google.protobuf.Descriptors.Descriptor
         getDescriptor() {
     }
 
         internalGetFieldAccessorTable() {
           .ensureFieldAccessorsInitialized(
     }
 
     public static com.google.protobuf.Parser<StatusPARSER =
         new com.google.protobuf.AbstractParser<Status>() {
       public Status parsePartialFrom(
           com.google.protobuf.CodedInputStream input,
           com.google.protobuf.ExtensionRegistryLite extensionRegistry)
           throws com.google.protobuf.InvalidProtocolBufferException {
         return new Status(inputextensionRegistry);
       }
     };
 
     @java.lang.Override
       return ;
     }
 
     public interface VersionOrBuilder
         extends com.google.protobuf.MessageOrBuilder {
 
       // required .Address address = 1;
       
required .Address address = 1;
 
       boolean hasAddress();
      
required .Address address = 1;
 
required .Address address = 1;
 
 
       // required int64 timestamp = 2;
       
required int64 timestamp = 2;
 
       boolean hasTimestamp();
      
required int64 timestamp = 2;
 
       long getTimestamp();
     }
    
Protobuf type Status.Version
 
     public static final class Version extends
         implements VersionOrBuilder {
       // Use Version.newBuilder() to construct.
       private Version(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
         super(builder);
         this. = builder.getUnknownFields();
       }
       private Version(boolean noInit) { this. = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }
 
       private static final Version defaultInstance;
       public static Version getDefaultInstance() {
         return ;
       }
 
       public Version getDefaultInstanceForType() {
         return ;
       }
 
       private final com.google.protobuf.UnknownFieldSet unknownFields;
       @java.lang.Override
       public final com.google.protobuf.UnknownFieldSet
           getUnknownFields() {
         return this.;
       }
       private Version(
           com.google.protobuf.CodedInputStream input,
           com.google.protobuf.ExtensionRegistryLite extensionRegistry)
           throws com.google.protobuf.InvalidProtocolBufferException {
         initFields();
         int mutable_bitField0_ = 0;
         com.google.protobuf.UnknownFieldSet.Builder unknownFields =
             com.google.protobuf.UnknownFieldSet.newBuilder();
         try {
           boolean done = false;
           while (!done) {
             int tag = input.readTag();
             switch (tag) {
               case 0:
                 done = true;
                 break;
               default: {
                 if (!parseUnknownField(inputunknownFields,
                                        extensionRegistrytag)) {
                   done = true;
                 }
                 break;
               }
               case 10: {
                 akka.contrib.pattern.protobuf.msg.DistributedPubSubMessages.Address.Builder subBuilder = null;
                 if ((( & 0x00000001) == 0x00000001)) {
                   subBuilder = .toBuilder();
                 }
                  = input.readMessage(.......extensionRegistry);
                 if (subBuilder != null) {
                   subBuilder.mergeFrom();
                    = subBuilder.buildPartial();
                 }
                  |= 0x00000001;
                 break;
               }
               case 16: {
                  |= 0x00000002;
                  = input.readInt64();
                 break;
               }
             }
           }
         } catch (com.google.protobuf.InvalidProtocolBufferException e) {
           throw e.setUnfinishedMessage(this);
         } catch (java.io.IOException e) {
           throw new com.google.protobuf.InvalidProtocolBufferException(
               e.getMessage()).setUnfinishedMessage(this);
         } finally {
           this. = unknownFields.build();
           makeExtensionsImmutable();
         }
       }
       public static final com.google.protobuf.Descriptors.Descriptor
           getDescriptor() {
       }
 
           internalGetFieldAccessorTable() {
             .ensureFieldAccessorsInitialized(
       }
 
       public static com.google.protobuf.Parser<VersionPARSER =
           new com.google.protobuf.AbstractParser<Version>() {
         public Version parsePartialFrom(
             com.google.protobuf.CodedInputStream input,
             com.google.protobuf.ExtensionRegistryLite extensionRegistry)
             throws com.google.protobuf.InvalidProtocolBufferException {
           return new Version(inputextensionRegistry);
         }
       };
 
       @java.lang.Override
       public com.google.protobuf.Parser<VersiongetParserForType() {
         return ;
       }
 
       private int bitField0_;
       // required .Address address = 1;
       public static final int ADDRESS_FIELD_NUMBER = 1;
required .Address address = 1;
 
       public boolean hasAddress() {
         return (( & 0x00000001) == 0x00000001);
       }
      
required .Address address = 1;
 
         return ;
       }
      
required .Address address = 1;
 
         return ;
       }
 
       // required int64 timestamp = 2;
       public static final int TIMESTAMP_FIELD_NUMBER = 2;
       private long timestamp_;
      
required int64 timestamp = 2;
 
       public boolean hasTimestamp() {
         return (( & 0x00000002) == 0x00000002);
       }
      
required int64 timestamp = 2;
 
       public long getTimestamp() {
         return ;
       }
 
       private void initFields() {
          = akka.contrib.pattern.protobuf.msg.DistributedPubSubMessages.Address.getDefaultInstance();
          = 0L;
       }
       private byte memoizedIsInitialized = -1;
       public final boolean isInitialized() {
         byte isInitialized = ;
         if (isInitialized != -1) return isInitialized == 1;
 
         if (!hasAddress()) {
            = 0;
           return false;
         }
         if (!hasTimestamp()) {
            = 0;
           return false;
         }
         if (!getAddress().isInitialized()) {
            = 0;
           return false;
         }
          = 1;
         return true;
       }
 
       public void writeTo(com.google.protobuf.CodedOutputStream output)
                           throws java.io.IOException {
         getSerializedSize();
         if ((( & 0x00000001) == 0x00000001)) {
           output.writeMessage(1, );
         }
         if ((( & 0x00000002) == 0x00000002)) {
           output.writeInt64(2, );
         }
         getUnknownFields().writeTo(output);
       }
 
       private int memoizedSerializedSize = -1;
       public int getSerializedSize() {
         int size = ;
         if (size != -1) return size;
 
         size = 0;
         if ((( & 0x00000001) == 0x00000001)) {
           size += com.google.protobuf.CodedOutputStream
             .computeMessageSize(1, );
         }
         if ((( & 0x00000002) == 0x00000002)) {
           size += com.google.protobuf.CodedOutputStream
             .computeInt64Size(2, );
         }
         size += getUnknownFields().getSerializedSize();
          = size;
         return size;
       }
 
       private static final long serialVersionUID = 0L;
       @java.lang.Override
       protected java.lang.Object writeReplace()
           throws java.io.ObjectStreamException {
         return super.writeReplace();
       }
 
           com.google.protobuf.ByteString data)
           throws com.google.protobuf.InvalidProtocolBufferException {
         return .parseFrom(data);
       }
           com.google.protobuf.ByteString data,
           com.google.protobuf.ExtensionRegistryLite extensionRegistry)
           throws com.google.protobuf.InvalidProtocolBufferException {
         return .parseFrom(dataextensionRegistry);
       }
       public static akka.contrib.pattern.protobuf.msg.DistributedPubSubMessages.Status.Version parseFrom(byte[] data)
           throws com.google.protobuf.InvalidProtocolBufferException {
         return .parseFrom(data);
       }
           byte[] data,
           com.google.protobuf.ExtensionRegistryLite extensionRegistry)
           throws com.google.protobuf.InvalidProtocolBufferException {
         return .parseFrom(dataextensionRegistry);
       }
           throws java.io.IOException {
         return .parseFrom(input);
       }
           java.io.InputStream input,
           com.google.protobuf.ExtensionRegistryLite extensionRegistry)
           throws java.io.IOException {
         return .parseFrom(inputextensionRegistry);
       }
           throws java.io.IOException {
         return .parseDelimitedFrom(input);
       }
           java.io.InputStream input,
           com.google.protobuf.ExtensionRegistryLite extensionRegistry)
           throws java.io.IOException {
         return .parseDelimitedFrom(inputextensionRegistry);
       }
           com.google.protobuf.CodedInputStream input)
           throws java.io.IOException {
         return .parseFrom(input);
       }
           com.google.protobuf.CodedInputStream input,
           com.google.protobuf.ExtensionRegistryLite extensionRegistry)
           throws java.io.IOException {
         return .parseFrom(inputextensionRegistry);
       }
 
       public static Builder newBuilder() { return Builder.create(); }
       public Builder newBuilderForType() { return newBuilder(); }
         return newBuilder().mergeFrom(prototype);
       }
       public Builder toBuilder() { return newBuilder(this); }
 
       @java.lang.Override
       protected Builder newBuilderForType(
           com.google.protobuf.GeneratedMessage.BuilderParent parent) {
         Builder builder = new Builder(parent);
         return builder;
       }
      
Protobuf type Status.Version
 
       public static final class Builder extends
         public static final com.google.protobuf.Descriptors.Descriptor
             getDescriptor() {
         }
 
             internalGetFieldAccessorTable() {
               .ensureFieldAccessorsInitialized(
         }
 
         // Construct using akka.contrib.pattern.protobuf.msg.DistributedPubSubMessages.Status.Version.newBuilder()
         private Builder() {
           maybeForceBuilderInitialization();
         }
 
         private Builder(
             com.google.protobuf.GeneratedMessage.BuilderParent parent) {
           super(parent);
           maybeForceBuilderInitialization();
         }
         private void maybeForceBuilderInitialization() {
             getAddressFieldBuilder();
           }
         }
         private static Builder create() {
           return new Builder();
         }
 
         public Builder clear() {
           super.clear();
           if ( == null) {
              = akka.contrib.pattern.protobuf.msg.DistributedPubSubMessages.Address.getDefaultInstance();
           } else {
             .clear();
           }
            = ( & ~0x00000001);
            = 0L;
            = ( & ~0x00000002);
           return this;
         }
 
         public Builder clone() {
           return create().mergeFrom(buildPartial());
         }
 
         public com.google.protobuf.Descriptors.Descriptor
             getDescriptorForType() {
         }
 
           return akka.contrib.pattern.protobuf.msg.DistributedPubSubMessages.Status.Version.getDefaultInstance();
         }
 
           if (!result.isInitialized()) {
             throw newUninitializedMessageException(result);
           }
           return result;
         }
 
           int from_bitField0_ = ;
           int to_bitField0_ = 0;
           if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
             to_bitField0_ |= 0x00000001;
           }
           if ( == null) {
             result.address_ = ;
           } else {
             result.address_ = .build();
           }
           if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
             to_bitField0_ |= 0x00000002;
           }
           result.timestamp_ = ;
           result.bitField0_ = to_bitField0_;
           onBuilt();
           return result;
         }
 
         public Builder mergeFrom(com.google.protobuf.Message other) {
           if (other instanceof akka.contrib.pattern.protobuf.msg.DistributedPubSubMessages.Status.Version) {
           } else {
             super.mergeFrom(other);
             return this;
           }
         }
 
           if (other == akka.contrib.pattern.protobuf.msg.DistributedPubSubMessages.Status.Version.getDefaultInstance()) return this;
           if (other.hasAddress()) {
             mergeAddress(other.getAddress());
           }
           if (other.hasTimestamp()) {
             setTimestamp(other.getTimestamp());
           }
           this.mergeUnknownFields(other.getUnknownFields());
           return this;
         }
 
         public final boolean isInitialized() {
           if (!hasAddress()) {
             
             return false;
           }
           if (!hasTimestamp()) {
             
             return false;
           }
           if (!getAddress().isInitialized()) {
             
             return false;
           }
           return true;
         }
 
         public Builder mergeFrom(
             com.google.protobuf.CodedInputStream input,
             com.google.protobuf.ExtensionRegistryLite extensionRegistry)
             throws java.io.IOException {
           akka.contrib.pattern.protobuf.msg.DistributedPubSubMessages.Status.Version parsedMessage = null;
           try {
             parsedMessage = .parsePartialFrom(inputextensionRegistry);
           } catch (com.google.protobuf.InvalidProtocolBufferException e) {
             parsedMessage = (akka.contrib.pattern.protobuf.msg.DistributedPubSubMessages.Status.Versione.getUnfinishedMessage();
             throw e;
           } finally {
             if (parsedMessage != null) {
               mergeFrom(parsedMessage);
             }
           }
           return this;
         }
         private int bitField0_;
 
         // required .Address address = 1;
         private akka.contrib.pattern.protobuf.msg.DistributedPubSubMessages.Address address_ = akka.contrib.pattern.protobuf.msg.DistributedPubSubMessages.Address.getDefaultInstance();
         private com.google.protobuf.SingleFieldBuilder<
required .Address address = 1;
 
         public boolean hasAddress() {
           return (( & 0x00000001) == 0x00000001);
         }
        
required .Address address = 1;
 
           if ( == null) {
             return ;
           } else {
             return .getMessage();
           }
         }
        
required .Address address = 1;
 
           if ( == null) {
             if (value == null) {
               throw new NullPointerException();
             }
              = value;
             onChanged();
           } else {
             .setMessage(value);
           }
            |= 0x00000001;
           return this;
         }
        
required .Address address = 1;
 
         public Builder setAddress(
             akka.contrib.pattern.protobuf.msg.DistributedPubSubMessages.Address.Builder builderForValue) {
           if ( == null) {
              = builderForValue.build();
             onChanged();
           } else {
             .setMessage(builderForValue.build());
           }
            |= 0x00000001;
           return this;
         }
        
required .Address address = 1;
 
           if ( == null) {
             if ((( & 0x00000001) == 0x00000001) &&
                  != akka.contrib.pattern.protobuf.msg.DistributedPubSubMessages.Address.getDefaultInstance()) {
                =
                 akka.contrib.pattern.protobuf.msg.DistributedPubSubMessages.Address.newBuilder().mergeFrom(value).buildPartial();
             } else {
                = value;
             }
             onChanged();
           } else {
             .mergeFrom(value);
           }
            |= 0x00000001;
           return this;
         }
        
required .Address address = 1;
 
         public Builder clearAddress() {
           if ( == null) {
              = akka.contrib.pattern.protobuf.msg.DistributedPubSubMessages.Address.getDefaultInstance();
             onChanged();
           } else {
             .clear();
           }
            = ( & ~0x00000001);
           return this;
         }
        
required .Address address = 1;
 
            |= 0x00000001;
           onChanged();
           return getAddressFieldBuilder().getBuilder();
         }
        
required .Address address = 1;
 
           if ( != null) {
             return .getMessageOrBuilder();
           } else {
             return ;
           }
         }
        
required .Address address = 1;
 
         private com.google.protobuf.SingleFieldBuilder<
             getAddressFieldBuilder() {
           if ( == null) {
              = new com.google.protobuf.SingleFieldBuilder<
                     ,
                     getParentForChildren(),
                     isClean());
              = null;
           }
           return ;
         }
 
         // required int64 timestamp = 2;
         private long timestamp_ ;
        
required int64 timestamp = 2;
 
         public boolean hasTimestamp() {
           return (( & 0x00000002) == 0x00000002);
         }
        
required int64 timestamp = 2;
 
         public long getTimestamp() {
           return ;
         }
        
required int64 timestamp = 2;
 
         public Builder setTimestamp(long value) {
            |= 0x00000002;
            = value;
           onChanged();
           return this;
         }
        
required int64 timestamp = 2;
 
         public Builder clearTimestamp() {
            = ( & ~0x00000002);
            = 0L;
           onChanged();
           return this;
         }
 
         // @@protoc_insertion_point(builder_scope:Status.Version)
       }
 
       static {
          = new Version(true);
         .initFields();
       }
 
       // @@protoc_insertion_point(class_scope:Status.Version)
     }
 
     // repeated .Status.Version versions = 1;
     public static final int VERSIONS_FIELD_NUMBER = 1;
repeated .Status.Version versions = 1;
 
       return ;
     }
    
repeated .Status.Version versions = 1;
 
         getVersionsOrBuilderList() {
       return ;
     }
    
repeated .Status.Version versions = 1;
 
     public int getVersionsCount() {
       return .size();
     }
    
repeated .Status.Version versions = 1;
 
       return .get(index);
     }
    
repeated .Status.Version versions = 1;
 
         int index) {
       return .get(index);
     }
 
     private void initFields() {
        = java.util.Collections.emptyList();
     }
     private byte memoizedIsInitialized = -1;
     public final boolean isInitialized() {
       byte isInitialized = ;
       if (isInitialized != -1) return isInitialized == 1;
 
       for (int i = 0; i < getVersionsCount(); i++) {
         if (!getVersions(i).isInitialized()) {
            = 0;
           return false;
         }
       }
        = 1;
       return true;
     }
 
     public void writeTo(com.google.protobuf.CodedOutputStream output)
                         throws java.io.IOException {
       getSerializedSize();
       for (int i = 0; i < .size(); i++) {
         output.writeMessage(1, .get(i));
       }
       getUnknownFields().writeTo(output);
     }
 
     private int memoizedSerializedSize = -1;
     public int getSerializedSize() {
       int size = ;
       if (size != -1) return size;
 
       size = 0;
       for (int i = 0; i < .size(); i++) {
         size += com.google.protobuf.CodedOutputStream
           .computeMessageSize(1, .get(i));
       }
       size += getUnknownFields().getSerializedSize();
        = size;
       return size;
     }
 
     private static final long serialVersionUID = 0L;
     @java.lang.Override
     protected java.lang.Object writeReplace()
         throws java.io.ObjectStreamException {
       return super.writeReplace();
     }
 
         com.google.protobuf.ByteString data)
       return .parseFrom(data);
     }
         com.google.protobuf.ByteString data,
         com.google.protobuf.ExtensionRegistryLite extensionRegistry)
       return .parseFrom(dataextensionRegistry);
     }
     public static akka.contrib.pattern.protobuf.msg.DistributedPubSubMessages.Status parseFrom(byte[] data)
       return .parseFrom(data);
     }
         byte[] data,
         com.google.protobuf.ExtensionRegistryLite extensionRegistry)
       return .parseFrom(dataextensionRegistry);
     }
         throws java.io.IOException {
       return .parseFrom(input);
     }
         java.io.InputStream input,
         com.google.protobuf.ExtensionRegistryLite extensionRegistry)