• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1 /*
2  * Copyright 2020 Google LLC
3  *
4  * Licensed under the Apache License, Version 2.0 (the "License");
5  * you may not use this file except in compliance with the License.
6  * You may obtain a copy of the License at
7  *
8  *     https://www.apache.org/licenses/LICENSE-2.0
9  *
10  * Unless required by applicable law or agreed to in writing, software
11  * distributed under the License is distributed on an "AS IS" BASIS,
12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  * See the License for the specific language governing permissions and
14  * limitations under the License.
15  */
16 // Generated by the protocol buffer compiler.  DO NOT EDIT!
17 // source: google/cloud/tasks/v2beta2/target.proto
18 
19 package com.google.cloud.tasks.v2beta2;
20 
21 /**
22  *
23  *
24  * <pre>
25  * The pull message contains data that can be used by the caller of
26  * [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] to process the
27  * task.
28  * This proto can only be used for tasks in a queue which has
29  * [pull_target][google.cloud.tasks.v2beta2.Queue.pull_target] set.
30  * </pre>
31  *
32  * Protobuf type {@code google.cloud.tasks.v2beta2.PullMessage}
33  */
34 public final class PullMessage extends com.google.protobuf.GeneratedMessageV3
35     implements
36     // @@protoc_insertion_point(message_implements:google.cloud.tasks.v2beta2.PullMessage)
37     PullMessageOrBuilder {
38   private static final long serialVersionUID = 0L;
39   // Use PullMessage.newBuilder() to construct.
PullMessage(com.google.protobuf.GeneratedMessageV3.Builder<?> builder)40   private PullMessage(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
41     super(builder);
42   }
43 
PullMessage()44   private PullMessage() {
45     payload_ = com.google.protobuf.ByteString.EMPTY;
46     tag_ = "";
47   }
48 
49   @java.lang.Override
50   @SuppressWarnings({"unused"})
newInstance(UnusedPrivateParameter unused)51   protected java.lang.Object newInstance(UnusedPrivateParameter unused) {
52     return new PullMessage();
53   }
54 
55   @java.lang.Override
getUnknownFields()56   public final com.google.protobuf.UnknownFieldSet getUnknownFields() {
57     return this.unknownFields;
58   }
59 
getDescriptor()60   public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() {
61     return com.google.cloud.tasks.v2beta2.TargetProto
62         .internal_static_google_cloud_tasks_v2beta2_PullMessage_descriptor;
63   }
64 
65   @java.lang.Override
66   protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable()67       internalGetFieldAccessorTable() {
68     return com.google.cloud.tasks.v2beta2.TargetProto
69         .internal_static_google_cloud_tasks_v2beta2_PullMessage_fieldAccessorTable
70         .ensureFieldAccessorsInitialized(
71             com.google.cloud.tasks.v2beta2.PullMessage.class,
72             com.google.cloud.tasks.v2beta2.PullMessage.Builder.class);
73   }
74 
75   public static final int PAYLOAD_FIELD_NUMBER = 1;
76   private com.google.protobuf.ByteString payload_ = com.google.protobuf.ByteString.EMPTY;
77   /**
78    *
79    *
80    * <pre>
81    * A data payload consumed by the worker to execute the task.
82    * </pre>
83    *
84    * <code>bytes payload = 1;</code>
85    *
86    * @return The payload.
87    */
88   @java.lang.Override
getPayload()89   public com.google.protobuf.ByteString getPayload() {
90     return payload_;
91   }
92 
93   public static final int TAG_FIELD_NUMBER = 2;
94 
95   @SuppressWarnings("serial")
96   private volatile java.lang.Object tag_ = "";
97   /**
98    *
99    *
100    * <pre>
101    * The task's tag.
102    * Tags allow similar tasks to be processed in a batch. If you label
103    * tasks with a tag, your worker can
104    * [lease tasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] with the
105    * same tag using
106    * [filter][google.cloud.tasks.v2beta2.LeaseTasksRequest.filter]. For example,
107    * if you want to aggregate the events associated with a specific user once a
108    * day, you could tag tasks with the user ID.
109    * The task's tag can only be set when the
110    * [task is created][google.cloud.tasks.v2beta2.CloudTasks.CreateTask].
111    * The tag must be less than 500 characters.
112    * SDK compatibility: Although the SDK allows tags to be either
113    * string or
114    * [bytes](https://cloud.google.com/appengine/docs/standard/java/javadoc/com/google/appengine/api/taskqueue/TaskOptions.html#tag-byte:A-),
115    * only UTF-8 encoded tags can be used in Cloud Tasks. If a tag isn't UTF-8
116    * encoded, the tag will be empty when the task is returned by Cloud Tasks.
117    * </pre>
118    *
119    * <code>string tag = 2;</code>
120    *
121    * @return The tag.
122    */
123   @java.lang.Override
getTag()124   public java.lang.String getTag() {
125     java.lang.Object ref = tag_;
126     if (ref instanceof java.lang.String) {
127       return (java.lang.String) ref;
128     } else {
129       com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
130       java.lang.String s = bs.toStringUtf8();
131       tag_ = s;
132       return s;
133     }
134   }
135   /**
136    *
137    *
138    * <pre>
139    * The task's tag.
140    * Tags allow similar tasks to be processed in a batch. If you label
141    * tasks with a tag, your worker can
142    * [lease tasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] with the
143    * same tag using
144    * [filter][google.cloud.tasks.v2beta2.LeaseTasksRequest.filter]. For example,
145    * if you want to aggregate the events associated with a specific user once a
146    * day, you could tag tasks with the user ID.
147    * The task's tag can only be set when the
148    * [task is created][google.cloud.tasks.v2beta2.CloudTasks.CreateTask].
149    * The tag must be less than 500 characters.
150    * SDK compatibility: Although the SDK allows tags to be either
151    * string or
152    * [bytes](https://cloud.google.com/appengine/docs/standard/java/javadoc/com/google/appengine/api/taskqueue/TaskOptions.html#tag-byte:A-),
153    * only UTF-8 encoded tags can be used in Cloud Tasks. If a tag isn't UTF-8
154    * encoded, the tag will be empty when the task is returned by Cloud Tasks.
155    * </pre>
156    *
157    * <code>string tag = 2;</code>
158    *
159    * @return The bytes for tag.
160    */
161   @java.lang.Override
getTagBytes()162   public com.google.protobuf.ByteString getTagBytes() {
163     java.lang.Object ref = tag_;
164     if (ref instanceof java.lang.String) {
165       com.google.protobuf.ByteString b =
166           com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
167       tag_ = b;
168       return b;
169     } else {
170       return (com.google.protobuf.ByteString) ref;
171     }
172   }
173 
174   private byte memoizedIsInitialized = -1;
175 
176   @java.lang.Override
isInitialized()177   public final boolean isInitialized() {
178     byte isInitialized = memoizedIsInitialized;
179     if (isInitialized == 1) return true;
180     if (isInitialized == 0) return false;
181 
182     memoizedIsInitialized = 1;
183     return true;
184   }
185 
186   @java.lang.Override
writeTo(com.google.protobuf.CodedOutputStream output)187   public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io.IOException {
188     if (!payload_.isEmpty()) {
189       output.writeBytes(1, payload_);
190     }
191     if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(tag_)) {
192       com.google.protobuf.GeneratedMessageV3.writeString(output, 2, tag_);
193     }
194     getUnknownFields().writeTo(output);
195   }
196 
197   @java.lang.Override
getSerializedSize()198   public int getSerializedSize() {
199     int size = memoizedSize;
200     if (size != -1) return size;
201 
202     size = 0;
203     if (!payload_.isEmpty()) {
204       size += com.google.protobuf.CodedOutputStream.computeBytesSize(1, payload_);
205     }
206     if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(tag_)) {
207       size += com.google.protobuf.GeneratedMessageV3.computeStringSize(2, tag_);
208     }
209     size += getUnknownFields().getSerializedSize();
210     memoizedSize = size;
211     return size;
212   }
213 
214   @java.lang.Override
equals(final java.lang.Object obj)215   public boolean equals(final java.lang.Object obj) {
216     if (obj == this) {
217       return true;
218     }
219     if (!(obj instanceof com.google.cloud.tasks.v2beta2.PullMessage)) {
220       return super.equals(obj);
221     }
222     com.google.cloud.tasks.v2beta2.PullMessage other =
223         (com.google.cloud.tasks.v2beta2.PullMessage) obj;
224 
225     if (!getPayload().equals(other.getPayload())) return false;
226     if (!getTag().equals(other.getTag())) return false;
227     if (!getUnknownFields().equals(other.getUnknownFields())) return false;
228     return true;
229   }
230 
231   @java.lang.Override
hashCode()232   public int hashCode() {
233     if (memoizedHashCode != 0) {
234       return memoizedHashCode;
235     }
236     int hash = 41;
237     hash = (19 * hash) + getDescriptor().hashCode();
238     hash = (37 * hash) + PAYLOAD_FIELD_NUMBER;
239     hash = (53 * hash) + getPayload().hashCode();
240     hash = (37 * hash) + TAG_FIELD_NUMBER;
241     hash = (53 * hash) + getTag().hashCode();
242     hash = (29 * hash) + getUnknownFields().hashCode();
243     memoizedHashCode = hash;
244     return hash;
245   }
246 
parseFrom(java.nio.ByteBuffer data)247   public static com.google.cloud.tasks.v2beta2.PullMessage parseFrom(java.nio.ByteBuffer data)
248       throws com.google.protobuf.InvalidProtocolBufferException {
249     return PARSER.parseFrom(data);
250   }
251 
parseFrom( java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)252   public static com.google.cloud.tasks.v2beta2.PullMessage parseFrom(
253       java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
254       throws com.google.protobuf.InvalidProtocolBufferException {
255     return PARSER.parseFrom(data, extensionRegistry);
256   }
257 
parseFrom( com.google.protobuf.ByteString data)258   public static com.google.cloud.tasks.v2beta2.PullMessage parseFrom(
259       com.google.protobuf.ByteString data)
260       throws com.google.protobuf.InvalidProtocolBufferException {
261     return PARSER.parseFrom(data);
262   }
263 
parseFrom( com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)264   public static com.google.cloud.tasks.v2beta2.PullMessage parseFrom(
265       com.google.protobuf.ByteString data,
266       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
267       throws com.google.protobuf.InvalidProtocolBufferException {
268     return PARSER.parseFrom(data, extensionRegistry);
269   }
270 
parseFrom(byte[] data)271   public static com.google.cloud.tasks.v2beta2.PullMessage parseFrom(byte[] data)
272       throws com.google.protobuf.InvalidProtocolBufferException {
273     return PARSER.parseFrom(data);
274   }
275 
parseFrom( byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)276   public static com.google.cloud.tasks.v2beta2.PullMessage parseFrom(
277       byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
278       throws com.google.protobuf.InvalidProtocolBufferException {
279     return PARSER.parseFrom(data, extensionRegistry);
280   }
281 
parseFrom(java.io.InputStream input)282   public static com.google.cloud.tasks.v2beta2.PullMessage parseFrom(java.io.InputStream input)
283       throws java.io.IOException {
284     return com.google.protobuf.GeneratedMessageV3.parseWithIOException(PARSER, input);
285   }
286 
parseFrom( java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)287   public static com.google.cloud.tasks.v2beta2.PullMessage parseFrom(
288       java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
289       throws java.io.IOException {
290     return com.google.protobuf.GeneratedMessageV3.parseWithIOException(
291         PARSER, input, extensionRegistry);
292   }
293 
parseDelimitedFrom( java.io.InputStream input)294   public static com.google.cloud.tasks.v2beta2.PullMessage parseDelimitedFrom(
295       java.io.InputStream input) throws java.io.IOException {
296     return com.google.protobuf.GeneratedMessageV3.parseDelimitedWithIOException(PARSER, input);
297   }
298 
parseDelimitedFrom( java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)299   public static com.google.cloud.tasks.v2beta2.PullMessage parseDelimitedFrom(
300       java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
301       throws java.io.IOException {
302     return com.google.protobuf.GeneratedMessageV3.parseDelimitedWithIOException(
303         PARSER, input, extensionRegistry);
304   }
305 
parseFrom( com.google.protobuf.CodedInputStream input)306   public static com.google.cloud.tasks.v2beta2.PullMessage parseFrom(
307       com.google.protobuf.CodedInputStream input) throws java.io.IOException {
308     return com.google.protobuf.GeneratedMessageV3.parseWithIOException(PARSER, input);
309   }
310 
parseFrom( com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)311   public static com.google.cloud.tasks.v2beta2.PullMessage parseFrom(
312       com.google.protobuf.CodedInputStream input,
313       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
314       throws java.io.IOException {
315     return com.google.protobuf.GeneratedMessageV3.parseWithIOException(
316         PARSER, input, extensionRegistry);
317   }
318 
319   @java.lang.Override
newBuilderForType()320   public Builder newBuilderForType() {
321     return newBuilder();
322   }
323 
newBuilder()324   public static Builder newBuilder() {
325     return DEFAULT_INSTANCE.toBuilder();
326   }
327 
newBuilder(com.google.cloud.tasks.v2beta2.PullMessage prototype)328   public static Builder newBuilder(com.google.cloud.tasks.v2beta2.PullMessage prototype) {
329     return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
330   }
331 
332   @java.lang.Override
toBuilder()333   public Builder toBuilder() {
334     return this == DEFAULT_INSTANCE ? new Builder() : new Builder().mergeFrom(this);
335   }
336 
337   @java.lang.Override
newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)338   protected Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
339     Builder builder = new Builder(parent);
340     return builder;
341   }
342   /**
343    *
344    *
345    * <pre>
346    * The pull message contains data that can be used by the caller of
347    * [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] to process the
348    * task.
349    * This proto can only be used for tasks in a queue which has
350    * [pull_target][google.cloud.tasks.v2beta2.Queue.pull_target] set.
351    * </pre>
352    *
353    * Protobuf type {@code google.cloud.tasks.v2beta2.PullMessage}
354    */
355   public static final class Builder extends com.google.protobuf.GeneratedMessageV3.Builder<Builder>
356       implements
357       // @@protoc_insertion_point(builder_implements:google.cloud.tasks.v2beta2.PullMessage)
358       com.google.cloud.tasks.v2beta2.PullMessageOrBuilder {
getDescriptor()359     public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() {
360       return com.google.cloud.tasks.v2beta2.TargetProto
361           .internal_static_google_cloud_tasks_v2beta2_PullMessage_descriptor;
362     }
363 
364     @java.lang.Override
365     protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable()366         internalGetFieldAccessorTable() {
367       return com.google.cloud.tasks.v2beta2.TargetProto
368           .internal_static_google_cloud_tasks_v2beta2_PullMessage_fieldAccessorTable
369           .ensureFieldAccessorsInitialized(
370               com.google.cloud.tasks.v2beta2.PullMessage.class,
371               com.google.cloud.tasks.v2beta2.PullMessage.Builder.class);
372     }
373 
374     // Construct using com.google.cloud.tasks.v2beta2.PullMessage.newBuilder()
Builder()375     private Builder() {}
376 
Builder(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)377     private Builder(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
378       super(parent);
379     }
380 
381     @java.lang.Override
clear()382     public Builder clear() {
383       super.clear();
384       bitField0_ = 0;
385       payload_ = com.google.protobuf.ByteString.EMPTY;
386       tag_ = "";
387       return this;
388     }
389 
390     @java.lang.Override
getDescriptorForType()391     public com.google.protobuf.Descriptors.Descriptor getDescriptorForType() {
392       return com.google.cloud.tasks.v2beta2.TargetProto
393           .internal_static_google_cloud_tasks_v2beta2_PullMessage_descriptor;
394     }
395 
396     @java.lang.Override
getDefaultInstanceForType()397     public com.google.cloud.tasks.v2beta2.PullMessage getDefaultInstanceForType() {
398       return com.google.cloud.tasks.v2beta2.PullMessage.getDefaultInstance();
399     }
400 
401     @java.lang.Override
build()402     public com.google.cloud.tasks.v2beta2.PullMessage build() {
403       com.google.cloud.tasks.v2beta2.PullMessage result = buildPartial();
404       if (!result.isInitialized()) {
405         throw newUninitializedMessageException(result);
406       }
407       return result;
408     }
409 
410     @java.lang.Override
buildPartial()411     public com.google.cloud.tasks.v2beta2.PullMessage buildPartial() {
412       com.google.cloud.tasks.v2beta2.PullMessage result =
413           new com.google.cloud.tasks.v2beta2.PullMessage(this);
414       if (bitField0_ != 0) {
415         buildPartial0(result);
416       }
417       onBuilt();
418       return result;
419     }
420 
buildPartial0(com.google.cloud.tasks.v2beta2.PullMessage result)421     private void buildPartial0(com.google.cloud.tasks.v2beta2.PullMessage result) {
422       int from_bitField0_ = bitField0_;
423       if (((from_bitField0_ & 0x00000001) != 0)) {
424         result.payload_ = payload_;
425       }
426       if (((from_bitField0_ & 0x00000002) != 0)) {
427         result.tag_ = tag_;
428       }
429     }
430 
431     @java.lang.Override
clone()432     public Builder clone() {
433       return super.clone();
434     }
435 
436     @java.lang.Override
setField( com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value)437     public Builder setField(
438         com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value) {
439       return super.setField(field, value);
440     }
441 
442     @java.lang.Override
clearField(com.google.protobuf.Descriptors.FieldDescriptor field)443     public Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field) {
444       return super.clearField(field);
445     }
446 
447     @java.lang.Override
clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)448     public Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) {
449       return super.clearOneof(oneof);
450     }
451 
452     @java.lang.Override
setRepeatedField( com.google.protobuf.Descriptors.FieldDescriptor field, int index, java.lang.Object value)453     public Builder setRepeatedField(
454         com.google.protobuf.Descriptors.FieldDescriptor field, int index, java.lang.Object value) {
455       return super.setRepeatedField(field, index, value);
456     }
457 
458     @java.lang.Override
addRepeatedField( com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value)459     public Builder addRepeatedField(
460         com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value) {
461       return super.addRepeatedField(field, value);
462     }
463 
464     @java.lang.Override
mergeFrom(com.google.protobuf.Message other)465     public Builder mergeFrom(com.google.protobuf.Message other) {
466       if (other instanceof com.google.cloud.tasks.v2beta2.PullMessage) {
467         return mergeFrom((com.google.cloud.tasks.v2beta2.PullMessage) other);
468       } else {
469         super.mergeFrom(other);
470         return this;
471       }
472     }
473 
mergeFrom(com.google.cloud.tasks.v2beta2.PullMessage other)474     public Builder mergeFrom(com.google.cloud.tasks.v2beta2.PullMessage other) {
475       if (other == com.google.cloud.tasks.v2beta2.PullMessage.getDefaultInstance()) return this;
476       if (other.getPayload() != com.google.protobuf.ByteString.EMPTY) {
477         setPayload(other.getPayload());
478       }
479       if (!other.getTag().isEmpty()) {
480         tag_ = other.tag_;
481         bitField0_ |= 0x00000002;
482         onChanged();
483       }
484       this.mergeUnknownFields(other.getUnknownFields());
485       onChanged();
486       return this;
487     }
488 
489     @java.lang.Override
isInitialized()490     public final boolean isInitialized() {
491       return true;
492     }
493 
494     @java.lang.Override
mergeFrom( com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)495     public Builder mergeFrom(
496         com.google.protobuf.CodedInputStream input,
497         com.google.protobuf.ExtensionRegistryLite extensionRegistry)
498         throws java.io.IOException {
499       if (extensionRegistry == null) {
500         throw new java.lang.NullPointerException();
501       }
502       try {
503         boolean done = false;
504         while (!done) {
505           int tag = input.readTag();
506           switch (tag) {
507             case 0:
508               done = true;
509               break;
510             case 10:
511               {
512                 payload_ = input.readBytes();
513                 bitField0_ |= 0x00000001;
514                 break;
515               } // case 10
516             case 18:
517               {
518                 tag_ = input.readStringRequireUtf8();
519                 bitField0_ |= 0x00000002;
520                 break;
521               } // case 18
522             default:
523               {
524                 if (!super.parseUnknownField(input, extensionRegistry, tag)) {
525                   done = true; // was an endgroup tag
526                 }
527                 break;
528               } // default:
529           } // switch (tag)
530         } // while (!done)
531       } catch (com.google.protobuf.InvalidProtocolBufferException e) {
532         throw e.unwrapIOException();
533       } finally {
534         onChanged();
535       } // finally
536       return this;
537     }
538 
539     private int bitField0_;
540 
541     private com.google.protobuf.ByteString payload_ = com.google.protobuf.ByteString.EMPTY;
542     /**
543      *
544      *
545      * <pre>
546      * A data payload consumed by the worker to execute the task.
547      * </pre>
548      *
549      * <code>bytes payload = 1;</code>
550      *
551      * @return The payload.
552      */
553     @java.lang.Override
getPayload()554     public com.google.protobuf.ByteString getPayload() {
555       return payload_;
556     }
557     /**
558      *
559      *
560      * <pre>
561      * A data payload consumed by the worker to execute the task.
562      * </pre>
563      *
564      * <code>bytes payload = 1;</code>
565      *
566      * @param value The payload to set.
567      * @return This builder for chaining.
568      */
setPayload(com.google.protobuf.ByteString value)569     public Builder setPayload(com.google.protobuf.ByteString value) {
570       if (value == null) {
571         throw new NullPointerException();
572       }
573       payload_ = value;
574       bitField0_ |= 0x00000001;
575       onChanged();
576       return this;
577     }
578     /**
579      *
580      *
581      * <pre>
582      * A data payload consumed by the worker to execute the task.
583      * </pre>
584      *
585      * <code>bytes payload = 1;</code>
586      *
587      * @return This builder for chaining.
588      */
clearPayload()589     public Builder clearPayload() {
590       bitField0_ = (bitField0_ & ~0x00000001);
591       payload_ = getDefaultInstance().getPayload();
592       onChanged();
593       return this;
594     }
595 
596     private java.lang.Object tag_ = "";
597     /**
598      *
599      *
600      * <pre>
601      * The task's tag.
602      * Tags allow similar tasks to be processed in a batch. If you label
603      * tasks with a tag, your worker can
604      * [lease tasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] with the
605      * same tag using
606      * [filter][google.cloud.tasks.v2beta2.LeaseTasksRequest.filter]. For example,
607      * if you want to aggregate the events associated with a specific user once a
608      * day, you could tag tasks with the user ID.
609      * The task's tag can only be set when the
610      * [task is created][google.cloud.tasks.v2beta2.CloudTasks.CreateTask].
611      * The tag must be less than 500 characters.
612      * SDK compatibility: Although the SDK allows tags to be either
613      * string or
614      * [bytes](https://cloud.google.com/appengine/docs/standard/java/javadoc/com/google/appengine/api/taskqueue/TaskOptions.html#tag-byte:A-),
615      * only UTF-8 encoded tags can be used in Cloud Tasks. If a tag isn't UTF-8
616      * encoded, the tag will be empty when the task is returned by Cloud Tasks.
617      * </pre>
618      *
619      * <code>string tag = 2;</code>
620      *
621      * @return The tag.
622      */
getTag()623     public java.lang.String getTag() {
624       java.lang.Object ref = tag_;
625       if (!(ref instanceof java.lang.String)) {
626         com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref;
627         java.lang.String s = bs.toStringUtf8();
628         tag_ = s;
629         return s;
630       } else {
631         return (java.lang.String) ref;
632       }
633     }
634     /**
635      *
636      *
637      * <pre>
638      * The task's tag.
639      * Tags allow similar tasks to be processed in a batch. If you label
640      * tasks with a tag, your worker can
641      * [lease tasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] with the
642      * same tag using
643      * [filter][google.cloud.tasks.v2beta2.LeaseTasksRequest.filter]. For example,
644      * if you want to aggregate the events associated with a specific user once a
645      * day, you could tag tasks with the user ID.
646      * The task's tag can only be set when the
647      * [task is created][google.cloud.tasks.v2beta2.CloudTasks.CreateTask].
648      * The tag must be less than 500 characters.
649      * SDK compatibility: Although the SDK allows tags to be either
650      * string or
651      * [bytes](https://cloud.google.com/appengine/docs/standard/java/javadoc/com/google/appengine/api/taskqueue/TaskOptions.html#tag-byte:A-),
652      * only UTF-8 encoded tags can be used in Cloud Tasks. If a tag isn't UTF-8
653      * encoded, the tag will be empty when the task is returned by Cloud Tasks.
654      * </pre>
655      *
656      * <code>string tag = 2;</code>
657      *
658      * @return The bytes for tag.
659      */
getTagBytes()660     public com.google.protobuf.ByteString getTagBytes() {
661       java.lang.Object ref = tag_;
662       if (ref instanceof String) {
663         com.google.protobuf.ByteString b =
664             com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref);
665         tag_ = b;
666         return b;
667       } else {
668         return (com.google.protobuf.ByteString) ref;
669       }
670     }
671     /**
672      *
673      *
674      * <pre>
675      * The task's tag.
676      * Tags allow similar tasks to be processed in a batch. If you label
677      * tasks with a tag, your worker can
678      * [lease tasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] with the
679      * same tag using
680      * [filter][google.cloud.tasks.v2beta2.LeaseTasksRequest.filter]. For example,
681      * if you want to aggregate the events associated with a specific user once a
682      * day, you could tag tasks with the user ID.
683      * The task's tag can only be set when the
684      * [task is created][google.cloud.tasks.v2beta2.CloudTasks.CreateTask].
685      * The tag must be less than 500 characters.
686      * SDK compatibility: Although the SDK allows tags to be either
687      * string or
688      * [bytes](https://cloud.google.com/appengine/docs/standard/java/javadoc/com/google/appengine/api/taskqueue/TaskOptions.html#tag-byte:A-),
689      * only UTF-8 encoded tags can be used in Cloud Tasks. If a tag isn't UTF-8
690      * encoded, the tag will be empty when the task is returned by Cloud Tasks.
691      * </pre>
692      *
693      * <code>string tag = 2;</code>
694      *
695      * @param value The tag to set.
696      * @return This builder for chaining.
697      */
setTag(java.lang.String value)698     public Builder setTag(java.lang.String value) {
699       if (value == null) {
700         throw new NullPointerException();
701       }
702       tag_ = value;
703       bitField0_ |= 0x00000002;
704       onChanged();
705       return this;
706     }
707     /**
708      *
709      *
710      * <pre>
711      * The task's tag.
712      * Tags allow similar tasks to be processed in a batch. If you label
713      * tasks with a tag, your worker can
714      * [lease tasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] with the
715      * same tag using
716      * [filter][google.cloud.tasks.v2beta2.LeaseTasksRequest.filter]. For example,
717      * if you want to aggregate the events associated with a specific user once a
718      * day, you could tag tasks with the user ID.
719      * The task's tag can only be set when the
720      * [task is created][google.cloud.tasks.v2beta2.CloudTasks.CreateTask].
721      * The tag must be less than 500 characters.
722      * SDK compatibility: Although the SDK allows tags to be either
723      * string or
724      * [bytes](https://cloud.google.com/appengine/docs/standard/java/javadoc/com/google/appengine/api/taskqueue/TaskOptions.html#tag-byte:A-),
725      * only UTF-8 encoded tags can be used in Cloud Tasks. If a tag isn't UTF-8
726      * encoded, the tag will be empty when the task is returned by Cloud Tasks.
727      * </pre>
728      *
729      * <code>string tag = 2;</code>
730      *
731      * @return This builder for chaining.
732      */
clearTag()733     public Builder clearTag() {
734       tag_ = getDefaultInstance().getTag();
735       bitField0_ = (bitField0_ & ~0x00000002);
736       onChanged();
737       return this;
738     }
739     /**
740      *
741      *
742      * <pre>
743      * The task's tag.
744      * Tags allow similar tasks to be processed in a batch. If you label
745      * tasks with a tag, your worker can
746      * [lease tasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] with the
747      * same tag using
748      * [filter][google.cloud.tasks.v2beta2.LeaseTasksRequest.filter]. For example,
749      * if you want to aggregate the events associated with a specific user once a
750      * day, you could tag tasks with the user ID.
751      * The task's tag can only be set when the
752      * [task is created][google.cloud.tasks.v2beta2.CloudTasks.CreateTask].
753      * The tag must be less than 500 characters.
754      * SDK compatibility: Although the SDK allows tags to be either
755      * string or
756      * [bytes](https://cloud.google.com/appengine/docs/standard/java/javadoc/com/google/appengine/api/taskqueue/TaskOptions.html#tag-byte:A-),
757      * only UTF-8 encoded tags can be used in Cloud Tasks. If a tag isn't UTF-8
758      * encoded, the tag will be empty when the task is returned by Cloud Tasks.
759      * </pre>
760      *
761      * <code>string tag = 2;</code>
762      *
763      * @param value The bytes for tag to set.
764      * @return This builder for chaining.
765      */
setTagBytes(com.google.protobuf.ByteString value)766     public Builder setTagBytes(com.google.protobuf.ByteString value) {
767       if (value == null) {
768         throw new NullPointerException();
769       }
770       checkByteStringIsUtf8(value);
771       tag_ = value;
772       bitField0_ |= 0x00000002;
773       onChanged();
774       return this;
775     }
776 
777     @java.lang.Override
setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields)778     public final Builder setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) {
779       return super.setUnknownFields(unknownFields);
780     }
781 
782     @java.lang.Override
mergeUnknownFields( final com.google.protobuf.UnknownFieldSet unknownFields)783     public final Builder mergeUnknownFields(
784         final com.google.protobuf.UnknownFieldSet unknownFields) {
785       return super.mergeUnknownFields(unknownFields);
786     }
787 
788     // @@protoc_insertion_point(builder_scope:google.cloud.tasks.v2beta2.PullMessage)
789   }
790 
791   // @@protoc_insertion_point(class_scope:google.cloud.tasks.v2beta2.PullMessage)
792   private static final com.google.cloud.tasks.v2beta2.PullMessage DEFAULT_INSTANCE;
793 
794   static {
795     DEFAULT_INSTANCE = new com.google.cloud.tasks.v2beta2.PullMessage();
796   }
797 
getDefaultInstance()798   public static com.google.cloud.tasks.v2beta2.PullMessage getDefaultInstance() {
799     return DEFAULT_INSTANCE;
800   }
801 
802   private static final com.google.protobuf.Parser<PullMessage> PARSER =
803       new com.google.protobuf.AbstractParser<PullMessage>() {
804         @java.lang.Override
805         public PullMessage parsePartialFrom(
806             com.google.protobuf.CodedInputStream input,
807             com.google.protobuf.ExtensionRegistryLite extensionRegistry)
808             throws com.google.protobuf.InvalidProtocolBufferException {
809           Builder builder = newBuilder();
810           try {
811             builder.mergeFrom(input, extensionRegistry);
812           } catch (com.google.protobuf.InvalidProtocolBufferException e) {
813             throw e.setUnfinishedMessage(builder.buildPartial());
814           } catch (com.google.protobuf.UninitializedMessageException e) {
815             throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial());
816           } catch (java.io.IOException e) {
817             throw new com.google.protobuf.InvalidProtocolBufferException(e)
818                 .setUnfinishedMessage(builder.buildPartial());
819           }
820           return builder.buildPartial();
821         }
822       };
823 
parser()824   public static com.google.protobuf.Parser<PullMessage> parser() {
825     return PARSER;
826   }
827 
828   @java.lang.Override
getParserForType()829   public com.google.protobuf.Parser<PullMessage> getParserForType() {
830     return PARSER;
831   }
832 
833   @java.lang.Override
getDefaultInstanceForType()834   public com.google.cloud.tasks.v2beta2.PullMessage getDefaultInstanceForType() {
835     return DEFAULT_INSTANCE;
836   }
837 }
838