001/**
002 * Copyright (c) 2012, The University of Southampton and the individual contributors.
003 * All rights reserved.
004 *
005 * Redistribution and use in source and binary forms, with or without modification,
006 * are permitted provided that the following conditions are met:
007 *
008 *   *  Redistributions of source code must retain the above copyright notice,
009 *      this list of conditions and the following disclaimer.
010 *
011 *   *  Redistributions in binary form must reproduce the above copyright notice,
012 *      this list of conditions and the following disclaimer in the documentation
013 *      and/or other materials provided with the distribution.
014 *
015 *   *  Neither the name of the University of Southampton nor the names of its
016 *      contributors may be used to endorse or promote products derived from this
017 *      software without specific prior written permission.
018 *
019 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
020 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
021 * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
022 * DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR
023 * ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
024 * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
025 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON
026 * ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
027 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
028 * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
029 */
030/**
031 * Autogenerated by Thrift Compiler (0.7.0)
032 *
033 * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
034 */
035package net.lag.kestrel.thrift;
036
037import java.nio.ByteBuffer;
038import java.util.ArrayList;
039import java.util.BitSet;
040import java.util.Collections;
041import java.util.EnumMap;
042import java.util.EnumSet;
043import java.util.HashMap;
044import java.util.HashSet;
045import java.util.List;
046import java.util.Map;
047import java.util.Set;
048
049import org.apache.commons.lang.builder.HashCodeBuilder;
050import org.slf4j.Logger;
051import org.slf4j.LoggerFactory;
052
053@SuppressWarnings({ "javadoc", "rawtypes", "unused", "unchecked", "serial" })
054public class Kestrel {
055
056        public interface Iface {
057
058                public int put(String queue_name, List<ByteBuffer> items, int expiration_msec)
059                                throws org.apache.thrift7.TException;
060
061                public List<Item> get(String queue_name, int max_items, int timeout_msec, int auto_abort_msec)
062                                throws org.apache.thrift7.TException;
063
064                public int confirm(String queue_name, Set<Long> ids) throws org.apache.thrift7.TException;
065
066                public int abort(String queue_name, Set<Long> ids) throws org.apache.thrift7.TException;
067
068                public QueueInfo peek(String queue_name) throws org.apache.thrift7.TException;
069
070                public void flush_queue(String queue_name) throws org.apache.thrift7.TException;
071
072                public void flush_all_queues() throws org.apache.thrift7.TException;
073
074                public void delete_queue(String queue_name) throws org.apache.thrift7.TException;
075
076                public String get_version() throws org.apache.thrift7.TException;
077
078        }
079
080        public interface AsyncIface {
081
082                public void put(String queue_name, List<ByteBuffer> items, int expiration_msec,
083                                org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.put_call> resultHandler)
084                                throws org.apache.thrift7.TException;
085
086                public void get(String queue_name, int max_items, int timeout_msec, int auto_abort_msec,
087                                org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.get_call> resultHandler)
088                                throws org.apache.thrift7.TException;
089
090                public void confirm(String queue_name, Set<Long> ids,
091                                org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.confirm_call> resultHandler)
092                                throws org.apache.thrift7.TException;
093
094                public void abort(String queue_name, Set<Long> ids,
095                                org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.abort_call> resultHandler)
096                                throws org.apache.thrift7.TException;
097
098                public void peek(String queue_name,
099                                org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.peek_call> resultHandler)
100                                throws org.apache.thrift7.TException;
101
102                public void flush_queue(String queue_name,
103                                org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.flush_queue_call> resultHandler)
104                                throws org.apache.thrift7.TException;
105
106                public void flush_all_queues(
107                                org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.flush_all_queues_call> resultHandler)
108                                throws org.apache.thrift7.TException;
109
110                public void delete_queue(String queue_name,
111                                org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.delete_queue_call> resultHandler)
112                                throws org.apache.thrift7.TException;
113
114                public void get_version(org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.get_version_call> resultHandler)
115                                throws org.apache.thrift7.TException;
116
117        }
118
119        public static class Client extends org.apache.thrift7.TServiceClient implements Iface {
120                public static class Factory implements org.apache.thrift7.TServiceClientFactory<Client> {
121                        public Factory() {
122                        }
123
124                        @Override
125                        public Client getClient(org.apache.thrift7.protocol.TProtocol prot) {
126                                return new Client(prot);
127                        }
128
129                        @Override
130                        public Client getClient(org.apache.thrift7.protocol.TProtocol iprot,
131                                        org.apache.thrift7.protocol.TProtocol oprot)
132                        {
133                                return new Client(iprot, oprot);
134                        }
135                }
136
137                public Client(org.apache.thrift7.protocol.TProtocol prot)
138                {
139                        super(prot, prot);
140                }
141
142                public Client(org.apache.thrift7.protocol.TProtocol iprot, org.apache.thrift7.protocol.TProtocol oprot) {
143                        super(iprot, oprot);
144                }
145
146                @Override
147                public int put(String queue_name, List<ByteBuffer> items, int expiration_msec)
148                                throws org.apache.thrift7.TException
149                {
150                        send_put(queue_name, items, expiration_msec);
151                        return recv_put();
152                }
153
154                public void send_put(String queue_name, List<ByteBuffer> items, int expiration_msec)
155                                throws org.apache.thrift7.TException
156                {
157                        final put_args args = new put_args();
158                        args.set_queue_name(queue_name);
159                        args.set_items(items);
160                        args.set_expiration_msec(expiration_msec);
161                        sendBase("put", args);
162                }
163
164                public int recv_put() throws org.apache.thrift7.TException
165                {
166                        final put_result result = new put_result();
167                        receiveBase(result, "put");
168                        if (result.is_set_success()) {
169                                return result.success;
170                        }
171                        throw new org.apache.thrift7.TApplicationException(org.apache.thrift7.TApplicationException.MISSING_RESULT,
172                                        "put failed: unknown result");
173                }
174
175                @Override
176                public List<Item> get(String queue_name, int max_items, int timeout_msec, int auto_abort_msec)
177                                throws org.apache.thrift7.TException
178                {
179                        send_get(queue_name, max_items, timeout_msec, auto_abort_msec);
180                        return recv_get();
181                }
182
183                public void send_get(String queue_name, int max_items, int timeout_msec, int auto_abort_msec)
184                                throws org.apache.thrift7.TException
185                {
186                        final get_args args = new get_args();
187                        args.set_queue_name(queue_name);
188                        args.set_max_items(max_items);
189                        args.set_timeout_msec(timeout_msec);
190                        args.set_auto_abort_msec(auto_abort_msec);
191                        sendBase("get", args);
192                }
193
194                public List<Item> recv_get() throws org.apache.thrift7.TException
195                {
196                        final get_result result = new get_result();
197                        receiveBase(result, "get");
198                        if (result.is_set_success()) {
199                                return result.success;
200                        }
201                        throw new org.apache.thrift7.TApplicationException(org.apache.thrift7.TApplicationException.MISSING_RESULT,
202                                        "get failed: unknown result");
203                }
204
205                @Override
206                public int confirm(String queue_name, Set<Long> ids) throws org.apache.thrift7.TException
207                {
208                        send_confirm(queue_name, ids);
209                        return recv_confirm();
210                }
211
212                public void send_confirm(String queue_name, Set<Long> ids) throws org.apache.thrift7.TException
213                {
214                        final confirm_args args = new confirm_args();
215                        args.set_queue_name(queue_name);
216                        args.set_ids(ids);
217                        sendBase("confirm", args);
218                }
219
220                public int recv_confirm() throws org.apache.thrift7.TException
221                {
222                        final confirm_result result = new confirm_result();
223                        receiveBase(result, "confirm");
224                        if (result.is_set_success()) {
225                                return result.success;
226                        }
227                        throw new org.apache.thrift7.TApplicationException(org.apache.thrift7.TApplicationException.MISSING_RESULT,
228                                        "confirm failed: unknown result");
229                }
230
231                @Override
232                public int abort(String queue_name, Set<Long> ids) throws org.apache.thrift7.TException
233                {
234                        send_abort(queue_name, ids);
235                        return recv_abort();
236                }
237
238                public void send_abort(String queue_name, Set<Long> ids) throws org.apache.thrift7.TException
239                {
240                        final abort_args args = new abort_args();
241                        args.set_queue_name(queue_name);
242                        args.set_ids(ids);
243                        sendBase("abort", args);
244                }
245
246                public int recv_abort() throws org.apache.thrift7.TException
247                {
248                        final abort_result result = new abort_result();
249                        receiveBase(result, "abort");
250                        if (result.is_set_success()) {
251                                return result.success;
252                        }
253                        throw new org.apache.thrift7.TApplicationException(org.apache.thrift7.TApplicationException.MISSING_RESULT,
254                                        "abort failed: unknown result");
255                }
256
257                @Override
258                public QueueInfo peek(String queue_name) throws org.apache.thrift7.TException
259                {
260                        send_peek(queue_name);
261                        return recv_peek();
262                }
263
264                public void send_peek(String queue_name) throws org.apache.thrift7.TException
265                {
266                        final peek_args args = new peek_args();
267                        args.set_queue_name(queue_name);
268                        sendBase("peek", args);
269                }
270
271                public QueueInfo recv_peek() throws org.apache.thrift7.TException
272                {
273                        final peek_result result = new peek_result();
274                        receiveBase(result, "peek");
275                        if (result.is_set_success()) {
276                                return result.success;
277                        }
278                        throw new org.apache.thrift7.TApplicationException(org.apache.thrift7.TApplicationException.MISSING_RESULT,
279                                        "peek failed: unknown result");
280                }
281
282                @Override
283                public void flush_queue(String queue_name) throws org.apache.thrift7.TException
284                {
285                        send_flush_queue(queue_name);
286                        recv_flush_queue();
287                }
288
289                public void send_flush_queue(String queue_name) throws org.apache.thrift7.TException
290                {
291                        final flush_queue_args args = new flush_queue_args();
292                        args.set_queue_name(queue_name);
293                        sendBase("flush_queue", args);
294                }
295
296                public void recv_flush_queue() throws org.apache.thrift7.TException
297                {
298                        final flush_queue_result result = new flush_queue_result();
299                        receiveBase(result, "flush_queue");
300                        return;
301                }
302
303                @Override
304                public void flush_all_queues() throws org.apache.thrift7.TException
305                {
306                        send_flush_all_queues();
307                        recv_flush_all_queues();
308                }
309
310                public void send_flush_all_queues() throws org.apache.thrift7.TException
311                {
312                        final flush_all_queues_args args = new flush_all_queues_args();
313                        sendBase("flush_all_queues", args);
314                }
315
316                public void recv_flush_all_queues() throws org.apache.thrift7.TException
317                {
318                        final flush_all_queues_result result = new flush_all_queues_result();
319                        receiveBase(result, "flush_all_queues");
320                        return;
321                }
322
323                @Override
324                public void delete_queue(String queue_name) throws org.apache.thrift7.TException
325                {
326                        send_delete_queue(queue_name);
327                        recv_delete_queue();
328                }
329
330                public void send_delete_queue(String queue_name) throws org.apache.thrift7.TException
331                {
332                        final delete_queue_args args = new delete_queue_args();
333                        args.set_queue_name(queue_name);
334                        sendBase("delete_queue", args);
335                }
336
337                public void recv_delete_queue() throws org.apache.thrift7.TException
338                {
339                        final delete_queue_result result = new delete_queue_result();
340                        receiveBase(result, "delete_queue");
341                        return;
342                }
343
344                @Override
345                public String get_version() throws org.apache.thrift7.TException
346                {
347                        send_get_version();
348                        return recv_get_version();
349                }
350
351                public void send_get_version() throws org.apache.thrift7.TException
352                {
353                        final get_version_args args = new get_version_args();
354                        sendBase("get_version", args);
355                }
356
357                public String recv_get_version() throws org.apache.thrift7.TException
358                {
359                        final get_version_result result = new get_version_result();
360                        receiveBase(result, "get_version");
361                        if (result.is_set_success()) {
362                                return result.success;
363                        }
364                        throw new org.apache.thrift7.TApplicationException(org.apache.thrift7.TApplicationException.MISSING_RESULT,
365                                        "get_version failed: unknown result");
366                }
367
368        }
369
370        public static class AsyncClient extends org.apache.thrift7.async.TAsyncClient implements AsyncIface {
371                public static class Factory implements org.apache.thrift7.async.TAsyncClientFactory<AsyncClient> {
372                        private org.apache.thrift7.async.TAsyncClientManager clientManager;
373                        private org.apache.thrift7.protocol.TProtocolFactory protocolFactory;
374
375                        public Factory(org.apache.thrift7.async.TAsyncClientManager clientManager,
376                                        org.apache.thrift7.protocol.TProtocolFactory protocolFactory)
377                        {
378                                this.clientManager = clientManager;
379                                this.protocolFactory = protocolFactory;
380                        }
381
382                        @Override
383                        public AsyncClient getAsyncClient(org.apache.thrift7.transport.TNonblockingTransport transport) {
384                                return new AsyncClient(protocolFactory, clientManager, transport);
385                        }
386                }
387
388                public AsyncClient(org.apache.thrift7.protocol.TProtocolFactory protocolFactory,
389                                org.apache.thrift7.async.TAsyncClientManager clientManager,
390                                org.apache.thrift7.transport.TNonblockingTransport transport)
391                {
392                        super(protocolFactory, clientManager, transport);
393                }
394
395                @Override
396                public void put(String queue_name, List<ByteBuffer> items, int expiration_msec,
397                                org.apache.thrift7.async.AsyncMethodCallback<put_call> resultHandler)
398                                throws org.apache.thrift7.TException
399                {
400                        checkReady();
401                        final put_call method_call = new put_call(queue_name, items, expiration_msec, resultHandler, this,
402                                        ___protocolFactory, ___transport);
403                        this.___currentMethod = method_call;
404                        ___manager.call(method_call);
405                }
406
407                public static class put_call extends org.apache.thrift7.async.TAsyncMethodCall {
408                        private String queue_name;
409                        private List<ByteBuffer> items;
410                        private int expiration_msec;
411
412                        public put_call(String queue_name, List<ByteBuffer> items, int expiration_msec,
413                                        org.apache.thrift7.async.AsyncMethodCallback<put_call> resultHandler,
414                                        org.apache.thrift7.async.TAsyncClient client,
415                                        org.apache.thrift7.protocol.TProtocolFactory protocolFactory,
416                                        org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException
417                        {
418                                super(client, protocolFactory, transport, resultHandler, false);
419                                this.queue_name = queue_name;
420                                this.items = items;
421                                this.expiration_msec = expiration_msec;
422                        }
423
424                        @Override
425                        public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
426                                prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("put",
427                                                org.apache.thrift7.protocol.TMessageType.CALL, 0));
428                                final put_args args = new put_args();
429                                args.set_queue_name(queue_name);
430                                args.set_items(items);
431                                args.set_expiration_msec(expiration_msec);
432                                args.write(prot);
433                                prot.writeMessageEnd();
434                        }
435
436                        public int getResult() throws org.apache.thrift7.TException {
437                                if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
438                                        throw new IllegalStateException("Method call not finished!");
439                                }
440                                final org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(
441                                                getFrameBuffer().array());
442                                final org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(
443                                                memoryTransport);
444                                return (new Client(prot)).recv_put();
445                        }
446                }
447
448                @Override
449                public void get(String queue_name, int max_items, int timeout_msec, int auto_abort_msec,
450                                org.apache.thrift7.async.AsyncMethodCallback<get_call> resultHandler)
451                                throws org.apache.thrift7.TException
452                {
453                        checkReady();
454                        final get_call method_call = new get_call(queue_name, max_items, timeout_msec, auto_abort_msec,
455                                        resultHandler, this, ___protocolFactory, ___transport);
456                        this.___currentMethod = method_call;
457                        ___manager.call(method_call);
458                }
459
460                public static class get_call extends org.apache.thrift7.async.TAsyncMethodCall {
461                        private String queue_name;
462                        private int max_items;
463                        private int timeout_msec;
464                        private int auto_abort_msec;
465
466                        public get_call(String queue_name, int max_items, int timeout_msec, int auto_abort_msec,
467                                        org.apache.thrift7.async.AsyncMethodCallback<get_call> resultHandler,
468                                        org.apache.thrift7.async.TAsyncClient client,
469                                        org.apache.thrift7.protocol.TProtocolFactory protocolFactory,
470                                        org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException
471                        {
472                                super(client, protocolFactory, transport, resultHandler, false);
473                                this.queue_name = queue_name;
474                                this.max_items = max_items;
475                                this.timeout_msec = timeout_msec;
476                                this.auto_abort_msec = auto_abort_msec;
477                        }
478
479                        @Override
480                        public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
481                                prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("get",
482                                                org.apache.thrift7.protocol.TMessageType.CALL, 0));
483                                final get_args args = new get_args();
484                                args.set_queue_name(queue_name);
485                                args.set_max_items(max_items);
486                                args.set_timeout_msec(timeout_msec);
487                                args.set_auto_abort_msec(auto_abort_msec);
488                                args.write(prot);
489                                prot.writeMessageEnd();
490                        }
491
492                        public List<Item> getResult() throws org.apache.thrift7.TException {
493                                if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
494                                        throw new IllegalStateException("Method call not finished!");
495                                }
496                                final org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(
497                                                getFrameBuffer().array());
498                                final org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(
499                                                memoryTransport);
500                                return (new Client(prot)).recv_get();
501                        }
502                }
503
504                @Override
505                public void confirm(String queue_name, Set<Long> ids,
506                                org.apache.thrift7.async.AsyncMethodCallback<confirm_call> resultHandler)
507                                throws org.apache.thrift7.TException
508                {
509                        checkReady();
510                        final confirm_call method_call = new confirm_call(queue_name, ids, resultHandler, this, ___protocolFactory,
511                                        ___transport);
512                        this.___currentMethod = method_call;
513                        ___manager.call(method_call);
514                }
515
516                public static class confirm_call extends org.apache.thrift7.async.TAsyncMethodCall {
517                        private String queue_name;
518                        private Set<Long> ids;
519
520                        public confirm_call(String queue_name, Set<Long> ids,
521                                        org.apache.thrift7.async.AsyncMethodCallback<confirm_call> resultHandler,
522                                        org.apache.thrift7.async.TAsyncClient client,
523                                        org.apache.thrift7.protocol.TProtocolFactory protocolFactory,
524                                        org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException
525                        {
526                                super(client, protocolFactory, transport, resultHandler, false);
527                                this.queue_name = queue_name;
528                                this.ids = ids;
529                        }
530
531                        @Override
532                        public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
533                                prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("confirm",
534                                                org.apache.thrift7.protocol.TMessageType.CALL, 0));
535                                final confirm_args args = new confirm_args();
536                                args.set_queue_name(queue_name);
537                                args.set_ids(ids);
538                                args.write(prot);
539                                prot.writeMessageEnd();
540                        }
541
542                        public int getResult() throws org.apache.thrift7.TException {
543                                if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
544                                        throw new IllegalStateException("Method call not finished!");
545                                }
546                                final org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(
547                                                getFrameBuffer().array());
548                                final org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(
549                                                memoryTransport);
550                                return (new Client(prot)).recv_confirm();
551                        }
552                }
553
554                @Override
555                public void abort(String queue_name, Set<Long> ids,
556                                org.apache.thrift7.async.AsyncMethodCallback<abort_call> resultHandler)
557                                throws org.apache.thrift7.TException
558                {
559                        checkReady();
560                        final abort_call method_call = new abort_call(queue_name, ids, resultHandler, this, ___protocolFactory,
561                                        ___transport);
562                        this.___currentMethod = method_call;
563                        ___manager.call(method_call);
564                }
565
566                public static class abort_call extends org.apache.thrift7.async.TAsyncMethodCall {
567                        private String queue_name;
568                        private Set<Long> ids;
569
570                        public abort_call(String queue_name, Set<Long> ids,
571                                        org.apache.thrift7.async.AsyncMethodCallback<abort_call> resultHandler,
572                                        org.apache.thrift7.async.TAsyncClient client,
573                                        org.apache.thrift7.protocol.TProtocolFactory protocolFactory,
574                                        org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException
575                        {
576                                super(client, protocolFactory, transport, resultHandler, false);
577                                this.queue_name = queue_name;
578                                this.ids = ids;
579                        }
580
581                        @Override
582                        public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
583                                prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("abort",
584                                                org.apache.thrift7.protocol.TMessageType.CALL, 0));
585                                final abort_args args = new abort_args();
586                                args.set_queue_name(queue_name);
587                                args.set_ids(ids);
588                                args.write(prot);
589                                prot.writeMessageEnd();
590                        }
591
592                        public int getResult() throws org.apache.thrift7.TException {
593                                if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
594                                        throw new IllegalStateException("Method call not finished!");
595                                }
596                                final org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(
597                                                getFrameBuffer().array());
598                                final org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(
599                                                memoryTransport);
600                                return (new Client(prot)).recv_abort();
601                        }
602                }
603
604                @Override
605                public void peek(String queue_name, org.apache.thrift7.async.AsyncMethodCallback<peek_call> resultHandler)
606                                throws org.apache.thrift7.TException
607                {
608                        checkReady();
609                        final peek_call method_call = new peek_call(queue_name, resultHandler, this, ___protocolFactory, ___transport);
610                        this.___currentMethod = method_call;
611                        ___manager.call(method_call);
612                }
613
614                public static class peek_call extends org.apache.thrift7.async.TAsyncMethodCall {
615                        private String queue_name;
616
617                        public peek_call(String queue_name, org.apache.thrift7.async.AsyncMethodCallback<peek_call> resultHandler,
618                                        org.apache.thrift7.async.TAsyncClient client,
619                                        org.apache.thrift7.protocol.TProtocolFactory protocolFactory,
620                                        org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException
621                        {
622                                super(client, protocolFactory, transport, resultHandler, false);
623                                this.queue_name = queue_name;
624                        }
625
626                        @Override
627                        public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
628                                prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("peek",
629                                                org.apache.thrift7.protocol.TMessageType.CALL, 0));
630                                final peek_args args = new peek_args();
631                                args.set_queue_name(queue_name);
632                                args.write(prot);
633                                prot.writeMessageEnd();
634                        }
635
636                        public QueueInfo getResult() throws org.apache.thrift7.TException {
637                                if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
638                                        throw new IllegalStateException("Method call not finished!");
639                                }
640                                final org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(
641                                                getFrameBuffer().array());
642                                final org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(
643                                                memoryTransport);
644                                return (new Client(prot)).recv_peek();
645                        }
646                }
647
648                @Override
649                public void flush_queue(String queue_name,
650                                org.apache.thrift7.async.AsyncMethodCallback<flush_queue_call> resultHandler)
651                                throws org.apache.thrift7.TException
652                {
653                        checkReady();
654                        final flush_queue_call method_call = new flush_queue_call(queue_name, resultHandler, this,
655                                        ___protocolFactory, ___transport);
656                        this.___currentMethod = method_call;
657                        ___manager.call(method_call);
658                }
659
660                public static class flush_queue_call extends org.apache.thrift7.async.TAsyncMethodCall {
661                        private String queue_name;
662
663                        public flush_queue_call(String queue_name,
664                                        org.apache.thrift7.async.AsyncMethodCallback<flush_queue_call> resultHandler,
665                                        org.apache.thrift7.async.TAsyncClient client,
666                                        org.apache.thrift7.protocol.TProtocolFactory protocolFactory,
667                                        org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException
668                        {
669                                super(client, protocolFactory, transport, resultHandler, false);
670                                this.queue_name = queue_name;
671                        }
672
673                        @Override
674                        public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
675                                prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("flush_queue",
676                                                org.apache.thrift7.protocol.TMessageType.CALL, 0));
677                                final flush_queue_args args = new flush_queue_args();
678                                args.set_queue_name(queue_name);
679                                args.write(prot);
680                                prot.writeMessageEnd();
681                        }
682
683                        public void getResult() throws org.apache.thrift7.TException {
684                                if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
685                                        throw new IllegalStateException("Method call not finished!");
686                                }
687                                final org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(
688                                                getFrameBuffer().array());
689                                final org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(
690                                                memoryTransport);
691                                (new Client(prot)).recv_flush_queue();
692                        }
693                }
694
695                @Override
696                public void flush_all_queues(org.apache.thrift7.async.AsyncMethodCallback<flush_all_queues_call> resultHandler)
697                                throws org.apache.thrift7.TException
698                {
699                        checkReady();
700                        final flush_all_queues_call method_call = new flush_all_queues_call(resultHandler, this, ___protocolFactory,
701                                        ___transport);
702                        this.___currentMethod = method_call;
703                        ___manager.call(method_call);
704                }
705
706                public static class flush_all_queues_call extends org.apache.thrift7.async.TAsyncMethodCall {
707                        public flush_all_queues_call(
708                                        org.apache.thrift7.async.AsyncMethodCallback<flush_all_queues_call> resultHandler,
709                                        org.apache.thrift7.async.TAsyncClient client,
710                                        org.apache.thrift7.protocol.TProtocolFactory protocolFactory,
711                                        org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException
712                        {
713                                super(client, protocolFactory, transport, resultHandler, false);
714                        }
715
716                        @Override
717                        public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
718                                prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("flush_all_queues",
719                                                org.apache.thrift7.protocol.TMessageType.CALL, 0));
720                                final flush_all_queues_args args = new flush_all_queues_args();
721                                args.write(prot);
722                                prot.writeMessageEnd();
723                        }
724
725                        public void getResult() throws org.apache.thrift7.TException {
726                                if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
727                                        throw new IllegalStateException("Method call not finished!");
728                                }
729                                final org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(
730                                                getFrameBuffer().array());
731                                final org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(
732                                                memoryTransport);
733                                (new Client(prot)).recv_flush_all_queues();
734                        }
735                }
736
737                @Override
738                public void delete_queue(String queue_name,
739                                org.apache.thrift7.async.AsyncMethodCallback<delete_queue_call> resultHandler)
740                                throws org.apache.thrift7.TException
741                {
742                        checkReady();
743                        final delete_queue_call method_call = new delete_queue_call(queue_name, resultHandler, this,
744                                        ___protocolFactory, ___transport);
745                        this.___currentMethod = method_call;
746                        ___manager.call(method_call);
747                }
748
749                public static class delete_queue_call extends org.apache.thrift7.async.TAsyncMethodCall {
750                        private String queue_name;
751
752                        public delete_queue_call(String queue_name,
753                                        org.apache.thrift7.async.AsyncMethodCallback<delete_queue_call> resultHandler,
754                                        org.apache.thrift7.async.TAsyncClient client,
755                                        org.apache.thrift7.protocol.TProtocolFactory protocolFactory,
756                                        org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException
757                        {
758                                super(client, protocolFactory, transport, resultHandler, false);
759                                this.queue_name = queue_name;
760                        }
761
762                        @Override
763                        public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
764                                prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("delete_queue",
765                                                org.apache.thrift7.protocol.TMessageType.CALL, 0));
766                                final delete_queue_args args = new delete_queue_args();
767                                args.set_queue_name(queue_name);
768                                args.write(prot);
769                                prot.writeMessageEnd();
770                        }
771
772                        public void getResult() throws org.apache.thrift7.TException {
773                                if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
774                                        throw new IllegalStateException("Method call not finished!");
775                                }
776                                final org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(
777                                                getFrameBuffer().array());
778                                final org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(
779                                                memoryTransport);
780                                (new Client(prot)).recv_delete_queue();
781                        }
782                }
783
784                @Override
785                public void get_version(org.apache.thrift7.async.AsyncMethodCallback<get_version_call> resultHandler)
786                                throws org.apache.thrift7.TException
787                {
788                        checkReady();
789                        final get_version_call method_call = new get_version_call(resultHandler, this, ___protocolFactory,
790                                        ___transport);
791                        this.___currentMethod = method_call;
792                        ___manager.call(method_call);
793                }
794
795                public static class get_version_call extends org.apache.thrift7.async.TAsyncMethodCall {
796                        public get_version_call(org.apache.thrift7.async.AsyncMethodCallback<get_version_call> resultHandler,
797                                        org.apache.thrift7.async.TAsyncClient client,
798                                        org.apache.thrift7.protocol.TProtocolFactory protocolFactory,
799                                        org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException
800                        {
801                                super(client, protocolFactory, transport, resultHandler, false);
802                        }
803
804                        @Override
805                        public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
806                                prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("get_version",
807                                                org.apache.thrift7.protocol.TMessageType.CALL, 0));
808                                final get_version_args args = new get_version_args();
809                                args.write(prot);
810                                prot.writeMessageEnd();
811                        }
812
813                        public String getResult() throws org.apache.thrift7.TException {
814                                if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
815                                        throw new IllegalStateException("Method call not finished!");
816                                }
817                                final org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(
818                                                getFrameBuffer().array());
819                                final org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(
820                                                memoryTransport);
821                                return (new Client(prot)).recv_get_version();
822                        }
823                }
824
825        }
826
827        public static class Processor<I extends Iface> extends org.apache.thrift7.TBaseProcessor
828                        implements
829                                org.apache.thrift7.TProcessor
830        {
831                private static final Logger LOGGER = LoggerFactory.getLogger(Processor.class.getName());
832
833                public Processor(I iface) {
834                        super(
835                                        iface,
836                                        getProcessMap(new HashMap<String, org.apache.thrift7.ProcessFunction<I, ? extends org.apache.thrift7.TBase>>()));
837                }
838
839                protected Processor(I iface,
840                                Map<String, org.apache.thrift7.ProcessFunction<I, ? extends org.apache.thrift7.TBase>> processMap)
841                {
842                        super(iface, getProcessMap(processMap));
843                }
844
845                private static <I extends Iface>
846                                Map<String, org.apache.thrift7.ProcessFunction<I, ? extends org.apache.thrift7.TBase>>
847                                getProcessMap(
848                                                Map<String, org.apache.thrift7.ProcessFunction<I, ? extends org.apache.thrift7.TBase>> processMap)
849                {
850                        processMap.put("put", new put());
851                        processMap.put("get", new get());
852                        processMap.put("confirm", new confirm());
853                        processMap.put("abort", new abort());
854                        processMap.put("peek", new peek());
855                        processMap.put("flush_queue", new flush_queue());
856                        processMap.put("flush_all_queues", new flush_all_queues());
857                        processMap.put("delete_queue", new delete_queue());
858                        processMap.put("get_version", new get_version());
859                        return processMap;
860                }
861
862                private static class put<I extends Iface> extends org.apache.thrift7.ProcessFunction<I, put_args> {
863                        public put() {
864                                super("put");
865                        }
866
867                        @Override
868                        protected put_args getEmptyArgsInstance() {
869                                return new put_args();
870                        }
871
872                        @Override
873                        protected put_result getResult(I iface, put_args args) throws org.apache.thrift7.TException {
874                                final put_result result = new put_result();
875                                result.success = iface.put(args.queue_name, args.items, args.expiration_msec);
876                                result.set_success_isSet(true);
877                                return result;
878                        }
879                }
880
881                private static class get<I extends Iface> extends org.apache.thrift7.ProcessFunction<I, get_args> {
882                        public get() {
883                                super("get");
884                        }
885
886                        @Override
887                        protected get_args getEmptyArgsInstance() {
888                                return new get_args();
889                        }
890
891                        @Override
892                        protected get_result getResult(I iface, get_args args) throws org.apache.thrift7.TException {
893                                final get_result result = new get_result();
894                                result.success = iface.get(args.queue_name, args.max_items, args.timeout_msec, args.auto_abort_msec);
895                                return result;
896                        }
897                }
898
899                private static class confirm<I extends Iface> extends org.apache.thrift7.ProcessFunction<I, confirm_args> {
900                        public confirm() {
901                                super("confirm");
902                        }
903
904                        @Override
905                        protected confirm_args getEmptyArgsInstance() {
906                                return new confirm_args();
907                        }
908
909                        @Override
910                        protected confirm_result getResult(I iface, confirm_args args) throws org.apache.thrift7.TException {
911                                final confirm_result result = new confirm_result();
912                                result.success = iface.confirm(args.queue_name, args.ids);
913                                result.set_success_isSet(true);
914                                return result;
915                        }
916                }
917
918                private static class abort<I extends Iface> extends org.apache.thrift7.ProcessFunction<I, abort_args> {
919                        public abort() {
920                                super("abort");
921                        }
922
923                        @Override
924                        protected abort_args getEmptyArgsInstance() {
925                                return new abort_args();
926                        }
927
928                        @Override
929                        protected abort_result getResult(I iface, abort_args args) throws org.apache.thrift7.TException {
930                                final abort_result result = new abort_result();
931                                result.success = iface.abort(args.queue_name, args.ids);
932                                result.set_success_isSet(true);
933                                return result;
934                        }
935                }
936
937                private static class peek<I extends Iface> extends org.apache.thrift7.ProcessFunction<I, peek_args> {
938                        public peek() {
939                                super("peek");
940                        }
941
942                        @Override
943                        protected peek_args getEmptyArgsInstance() {
944                                return new peek_args();
945                        }
946
947                        @Override
948                        protected peek_result getResult(I iface, peek_args args) throws org.apache.thrift7.TException {
949                                final peek_result result = new peek_result();
950                                result.success = iface.peek(args.queue_name);
951                                return result;
952                        }
953                }
954
955                private static class flush_queue<I extends Iface> extends org.apache.thrift7.ProcessFunction<I, flush_queue_args>
956                {
957                        public flush_queue() {
958                                super("flush_queue");
959                        }
960
961                        @Override
962                        protected flush_queue_args getEmptyArgsInstance() {
963                                return new flush_queue_args();
964                        }
965
966                        @Override
967                        protected flush_queue_result getResult(I iface, flush_queue_args args) throws org.apache.thrift7.TException {
968                                final flush_queue_result result = new flush_queue_result();
969                                iface.flush_queue(args.queue_name);
970                                return result;
971                        }
972                }
973
974                private static class flush_all_queues<I extends Iface>
975                                extends
976                                        org.apache.thrift7.ProcessFunction<I, flush_all_queues_args>
977                {
978                        public flush_all_queues() {
979                                super("flush_all_queues");
980                        }
981
982                        @Override
983                        protected flush_all_queues_args getEmptyArgsInstance() {
984                                return new flush_all_queues_args();
985                        }
986
987                        @Override
988                        protected flush_all_queues_result getResult(I iface, flush_all_queues_args args)
989                                        throws org.apache.thrift7.TException
990                        {
991                                final flush_all_queues_result result = new flush_all_queues_result();
992                                iface.flush_all_queues();
993                                return result;
994                        }
995                }
996
997                private static class delete_queue<I extends Iface>
998                                extends
999                                        org.apache.thrift7.ProcessFunction<I, delete_queue_args>
1000                {
1001                        public delete_queue() {
1002                                super("delete_queue");
1003                        }
1004
1005                        @Override
1006                        protected delete_queue_args getEmptyArgsInstance() {
1007                                return new delete_queue_args();
1008                        }
1009
1010                        @Override
1011                        protected delete_queue_result getResult(I iface, delete_queue_args args) throws org.apache.thrift7.TException
1012                        {
1013                                final delete_queue_result result = new delete_queue_result();
1014                                iface.delete_queue(args.queue_name);
1015                                return result;
1016                        }
1017                }
1018
1019                private static class get_version<I extends Iface> extends org.apache.thrift7.ProcessFunction<I, get_version_args>
1020                {
1021                        public get_version() {
1022                                super("get_version");
1023                        }
1024
1025                        @Override
1026                        protected get_version_args getEmptyArgsInstance() {
1027                                return new get_version_args();
1028                        }
1029
1030                        @Override
1031                        protected get_version_result getResult(I iface, get_version_args args) throws org.apache.thrift7.TException {
1032                                final get_version_result result = new get_version_result();
1033                                result.success = iface.get_version();
1034                                return result;
1035                        }
1036                }
1037
1038        }
1039
1040        public static class put_args
1041                        implements
1042                                org.apache.thrift7.TBase<put_args, put_args._Fields>,
1043                                java.io.Serializable,
1044                                Cloneable
1045        {
1046                private static final org.apache.thrift7.protocol.TStruct STRUCT_DESC = new org.apache.thrift7.protocol.TStruct(
1047                                "put_args");
1048
1049                private static final org.apache.thrift7.protocol.TField QUEUE_NAME_FIELD_DESC = new org.apache.thrift7.protocol.TField(
1050                                "queue_name", org.apache.thrift7.protocol.TType.STRING, (short) 1);
1051                private static final org.apache.thrift7.protocol.TField ITEMS_FIELD_DESC = new org.apache.thrift7.protocol.TField(
1052                                "items", org.apache.thrift7.protocol.TType.LIST, (short) 2);
1053                private static final org.apache.thrift7.protocol.TField EXPIRATION_MSEC_FIELD_DESC = new org.apache.thrift7.protocol.TField(
1054                                "expiration_msec", org.apache.thrift7.protocol.TType.I32, (short) 3);
1055
1056                private String queue_name; // required
1057                private List<ByteBuffer> items; // required
1058                private int expiration_msec; // required
1059
1060                /**
1061                 * The set of fields this struct contains, along with convenience
1062                 * methods for finding and manipulating them.
1063                 */
1064                public enum _Fields implements org.apache.thrift7.TFieldIdEnum {
1065                        QUEUE_NAME((short) 1, "queue_name"),
1066                        ITEMS((short) 2, "items"),
1067                        EXPIRATION_MSEC((short) 3, "expiration_msec");
1068
1069                        private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
1070
1071                        static {
1072                                for (final _Fields field : EnumSet.allOf(_Fields.class)) {
1073                                        byName.put(field.getFieldName(), field);
1074                                }
1075                        }
1076
1077                        /**
1078                         * Find the _Fields constant that matches fieldId, or null if its
1079                         * not found.
1080                         */
1081                        public static _Fields findByThriftId(int fieldId) {
1082                                switch (fieldId) {
1083                                case 1: // QUEUE_NAME
1084                                        return QUEUE_NAME;
1085                                case 2: // ITEMS
1086                                        return ITEMS;
1087                                case 3: // EXPIRATION_MSEC
1088                                        return EXPIRATION_MSEC;
1089                                default:
1090                                        return null;
1091                                }
1092                        }
1093
1094                        /**
1095                         * Find the _Fields constant that matches fieldId, throwing an
1096                         * exception if it is not found.
1097                         */
1098                        public static _Fields findByThriftIdOrThrow(int fieldId) {
1099                                final _Fields fields = findByThriftId(fieldId);
1100                                if (fields == null)
1101                                        throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
1102                                return fields;
1103                        }
1104
1105                        /**
1106                         * Find the _Fields constant that matches name, or null if its not
1107                         * found.
1108                         */
1109                        public static _Fields findByName(String name) {
1110                                return byName.get(name);
1111                        }
1112
1113                        private final short _thriftId;
1114                        private final String _fieldName;
1115
1116                        _Fields(short thriftId, String fieldName) {
1117                                _thriftId = thriftId;
1118                                _fieldName = fieldName;
1119                        }
1120
1121                        @Override
1122                        public short getThriftFieldId() {
1123                                return _thriftId;
1124                        }
1125
1126                        @Override
1127                        public String getFieldName() {
1128                                return _fieldName;
1129                        }
1130                }
1131
1132                // isset id assignments
1133                private static final int __EXPIRATION_MSEC_ISSET_ID = 0;
1134                private BitSet __isset_bit_vector = new BitSet(1);
1135
1136                public static final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> metaDataMap;
1137                static {
1138                        final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift7.meta_data.FieldMetaData>(
1139                                        _Fields.class);
1140                        tmpMap.put(_Fields.QUEUE_NAME, new org.apache.thrift7.meta_data.FieldMetaData("queue_name",
1141                                        org.apache.thrift7.TFieldRequirementType.DEFAULT,
1142                                        new org.apache.thrift7.meta_data.FieldValueMetaData(org.apache.thrift7.protocol.TType.STRING)));
1143                        tmpMap.put(_Fields.ITEMS, new org.apache.thrift7.meta_data.FieldMetaData("items",
1144                                        org.apache.thrift7.TFieldRequirementType.DEFAULT,
1145                                        new org.apache.thrift7.meta_data.ListMetaData(org.apache.thrift7.protocol.TType.LIST,
1146                                                        new org.apache.thrift7.meta_data.FieldValueMetaData(org.apache.thrift7.protocol.TType.STRING,
1147                                                                        true))));
1148                        tmpMap.put(_Fields.EXPIRATION_MSEC, new org.apache.thrift7.meta_data.FieldMetaData("expiration_msec",
1149                                        org.apache.thrift7.TFieldRequirementType.DEFAULT,
1150                                        new org.apache.thrift7.meta_data.FieldValueMetaData(org.apache.thrift7.protocol.TType.I32)));
1151                        metaDataMap = Collections.unmodifiableMap(tmpMap);
1152                        org.apache.thrift7.meta_data.FieldMetaData.addStructMetaDataMap(put_args.class, metaDataMap);
1153                }
1154
1155                public put_args() {
1156                        this.expiration_msec = 0;
1157
1158                }
1159
1160                public put_args(
1161                                String queue_name,
1162                                List<ByteBuffer> items,
1163                                int expiration_msec)
1164                {
1165                        this();
1166                        this.queue_name = queue_name;
1167                        this.items = items;
1168                        this.expiration_msec = expiration_msec;
1169                        set_expiration_msec_isSet(true);
1170                }
1171
1172                /**
1173                 * Performs a deep copy on <i>other</i>.
1174                 */
1175                public put_args(put_args other) {
1176                        __isset_bit_vector.clear();
1177                        __isset_bit_vector.or(other.__isset_bit_vector);
1178                        if (other.is_set_queue_name()) {
1179                                this.queue_name = other.queue_name;
1180                        }
1181                        if (other.is_set_items()) {
1182                                final List<ByteBuffer> __this__items = new ArrayList<ByteBuffer>();
1183                                for (final ByteBuffer other_element : other.items) {
1184                                        final ByteBuffer temp_binary_element = org.apache.thrift7.TBaseHelper.copyBinary(other_element);
1185                                        ;
1186                                        __this__items.add(temp_binary_element);
1187                                }
1188                                this.items = __this__items;
1189                        }
1190                        this.expiration_msec = other.expiration_msec;
1191                }
1192
1193                @Override
1194                public put_args deepCopy() {
1195                        return new put_args(this);
1196                }
1197
1198                @Override
1199                public void clear() {
1200                        this.queue_name = null;
1201                        this.items = null;
1202                        this.expiration_msec = 0;
1203
1204                }
1205
1206                public String get_queue_name() {
1207                        return this.queue_name;
1208                }
1209
1210                public void set_queue_name(String queue_name) {
1211                        this.queue_name = queue_name;
1212                }
1213
1214                public void unset_queue_name() {
1215                        this.queue_name = null;
1216                }
1217
1218                /**
1219                 * Returns true if field queue_name is set (has been assigned a value)
1220                 * and false otherwise
1221                 */
1222                public boolean is_set_queue_name() {
1223                        return this.queue_name != null;
1224                }
1225
1226                public void set_queue_name_isSet(boolean value) {
1227                        if (!value) {
1228                                this.queue_name = null;
1229                        }
1230                }
1231
1232                public int get_items_size() {
1233                        return (this.items == null) ? 0 : this.items.size();
1234                }
1235
1236                public java.util.Iterator<ByteBuffer> get_items_iterator() {
1237                        return (this.items == null) ? null : this.items.iterator();
1238                }
1239
1240                public void add_to_items(ByteBuffer elem) {
1241                        if (this.items == null) {
1242                                this.items = new ArrayList<ByteBuffer>();
1243                        }
1244                        this.items.add(elem);
1245                }
1246
1247                public List<ByteBuffer> get_items() {
1248                        return this.items;
1249                }
1250
1251                public void set_items(List<ByteBuffer> items) {
1252                        this.items = items;
1253                }
1254
1255                public void unset_items() {
1256                        this.items = null;
1257                }
1258
1259                /**
1260                 * Returns true if field items is set (has been assigned a value) and
1261                 * false otherwise
1262                 */
1263                public boolean is_set_items() {
1264                        return this.items != null;
1265                }
1266
1267                public void set_items_isSet(boolean value) {
1268                        if (!value) {
1269                                this.items = null;
1270                        }
1271                }
1272
1273                public int get_expiration_msec() {
1274                        return this.expiration_msec;
1275                }
1276
1277                public void set_expiration_msec(int expiration_msec) {
1278                        this.expiration_msec = expiration_msec;
1279                        set_expiration_msec_isSet(true);
1280                }
1281
1282                public void unset_expiration_msec() {
1283                        __isset_bit_vector.clear(__EXPIRATION_MSEC_ISSET_ID);
1284                }
1285
1286                /**
1287                 * Returns true if field expiration_msec is set (has been assigned a
1288                 * value) and false otherwise
1289                 */
1290                public boolean is_set_expiration_msec() {
1291                        return __isset_bit_vector.get(__EXPIRATION_MSEC_ISSET_ID);
1292                }
1293
1294                public void set_expiration_msec_isSet(boolean value) {
1295                        __isset_bit_vector.set(__EXPIRATION_MSEC_ISSET_ID, value);
1296                }
1297
1298                @Override
1299                public void setFieldValue(_Fields field, Object value) {
1300                        switch (field) {
1301                        case QUEUE_NAME:
1302                                if (value == null) {
1303                                        unset_queue_name();
1304                                } else {
1305                                        set_queue_name((String) value);
1306                                }
1307                                break;
1308
1309                        case ITEMS:
1310                                if (value == null) {
1311                                        unset_items();
1312                                } else {
1313                                        set_items((List<ByteBuffer>) value);
1314                                }
1315                                break;
1316
1317                        case EXPIRATION_MSEC:
1318                                if (value == null) {
1319                                        unset_expiration_msec();
1320                                } else {
1321                                        set_expiration_msec((Integer) value);
1322                                }
1323                                break;
1324
1325                        }
1326                }
1327
1328                @Override
1329                public Object getFieldValue(_Fields field) {
1330                        switch (field) {
1331                        case QUEUE_NAME:
1332                                return get_queue_name();
1333
1334                        case ITEMS:
1335                                return get_items();
1336
1337                        case EXPIRATION_MSEC:
1338                                return Integer.valueOf(get_expiration_msec());
1339
1340                        }
1341                        throw new IllegalStateException();
1342                }
1343
1344                /**
1345                 * Returns true if field corresponding to fieldID is set (has been
1346                 * assigned a value) and false otherwise
1347                 */
1348                @Override
1349                public boolean isSet(_Fields field) {
1350                        if (field == null) {
1351                                throw new IllegalArgumentException();
1352                        }
1353
1354                        switch (field) {
1355                        case QUEUE_NAME:
1356                                return is_set_queue_name();
1357                        case ITEMS:
1358                                return is_set_items();
1359                        case EXPIRATION_MSEC:
1360                                return is_set_expiration_msec();
1361                        }
1362                        throw new IllegalStateException();
1363                }
1364
1365                @Override
1366                public boolean equals(Object that) {
1367                        if (that == null)
1368                                return false;
1369                        if (that instanceof put_args)
1370                                return this.equals((put_args) that);
1371                        return false;
1372                }
1373
1374                public boolean equals(put_args that) {
1375                        if (that == null)
1376                                return false;
1377
1378                        final boolean this_present_queue_name = true && this.is_set_queue_name();
1379                        final boolean that_present_queue_name = true && that.is_set_queue_name();
1380                        if (this_present_queue_name || that_present_queue_name) {
1381                                if (!(this_present_queue_name && that_present_queue_name))
1382                                        return false;
1383                                if (!this.queue_name.equals(that.queue_name))
1384                                        return false;
1385                        }
1386
1387                        final boolean this_present_items = true && this.is_set_items();
1388                        final boolean that_present_items = true && that.is_set_items();
1389                        if (this_present_items || that_present_items) {
1390                                if (!(this_present_items && that_present_items))
1391                                        return false;
1392                                if (!this.items.equals(that.items))
1393                                        return false;
1394                        }
1395
1396                        final boolean this_present_expiration_msec = true;
1397                        final boolean that_present_expiration_msec = true;
1398                        if (this_present_expiration_msec || that_present_expiration_msec) {
1399                                if (!(this_present_expiration_msec && that_present_expiration_msec))
1400                                        return false;
1401                                if (this.expiration_msec != that.expiration_msec)
1402                                        return false;
1403                        }
1404
1405                        return true;
1406                }
1407
1408                @Override
1409                public int hashCode() {
1410                        final HashCodeBuilder builder = new HashCodeBuilder();
1411
1412                        final boolean present_queue_name = true && (is_set_queue_name());
1413                        builder.append(present_queue_name);
1414                        if (present_queue_name)
1415                                builder.append(queue_name);
1416
1417                        final boolean present_items = true && (is_set_items());
1418                        builder.append(present_items);
1419                        if (present_items)
1420                                builder.append(items);
1421
1422                        final boolean present_expiration_msec = true;
1423                        builder.append(present_expiration_msec);
1424                        if (present_expiration_msec)
1425                                builder.append(expiration_msec);
1426
1427                        return builder.toHashCode();
1428                }
1429
1430                @Override
1431                public int compareTo(put_args other) {
1432                        if (!getClass().equals(other.getClass())) {
1433                                return getClass().getName().compareTo(other.getClass().getName());
1434                        }
1435
1436                        int lastComparison = 0;
1437                        final put_args typedOther = other;
1438
1439                        lastComparison = Boolean.valueOf(is_set_queue_name()).compareTo(typedOther.is_set_queue_name());
1440                        if (lastComparison != 0) {
1441                                return lastComparison;
1442                        }
1443                        if (is_set_queue_name()) {
1444                                lastComparison = org.apache.thrift7.TBaseHelper.compareTo(this.queue_name, typedOther.queue_name);
1445                                if (lastComparison != 0) {
1446                                        return lastComparison;
1447                                }
1448                        }
1449                        lastComparison = Boolean.valueOf(is_set_items()).compareTo(typedOther.is_set_items());
1450                        if (lastComparison != 0) {
1451                                return lastComparison;
1452                        }
1453                        if (is_set_items()) {
1454                                lastComparison = org.apache.thrift7.TBaseHelper.compareTo(this.items, typedOther.items);
1455                                if (lastComparison != 0) {
1456                                        return lastComparison;
1457                                }
1458                        }
1459                        lastComparison = Boolean.valueOf(is_set_expiration_msec()).compareTo(typedOther.is_set_expiration_msec());
1460                        if (lastComparison != 0) {
1461                                return lastComparison;
1462                        }
1463                        if (is_set_expiration_msec()) {
1464                                lastComparison = org.apache.thrift7.TBaseHelper.compareTo(this.expiration_msec,
1465                                                typedOther.expiration_msec);
1466                                if (lastComparison != 0) {
1467                                        return lastComparison;
1468                                }
1469                        }
1470                        return 0;
1471                }
1472
1473                @Override
1474                public _Fields fieldForId(int fieldId) {
1475                        return _Fields.findByThriftId(fieldId);
1476                }
1477
1478                @Override
1479                public void read(org.apache.thrift7.protocol.TProtocol iprot) throws org.apache.thrift7.TException {
1480                        org.apache.thrift7.protocol.TField field;
1481                        iprot.readStructBegin();
1482                        while (true)
1483                        {
1484                                field = iprot.readFieldBegin();
1485                                if (field.type == org.apache.thrift7.protocol.TType.STOP) {
1486                                        break;
1487                                }
1488                                switch (field.id) {
1489                                case 1: // QUEUE_NAME
1490                                        if (field.type == org.apache.thrift7.protocol.TType.STRING) {
1491                                                this.queue_name = iprot.readString();
1492                                        } else {
1493                                                org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
1494                                        }
1495                                        break;
1496                                case 2: // ITEMS
1497                                        if (field.type == org.apache.thrift7.protocol.TType.LIST) {
1498                                                {
1499                                                        final org.apache.thrift7.protocol.TList _list0 = iprot.readListBegin();
1500                                                        this.items = new ArrayList<ByteBuffer>(_list0.size);
1501                                                        for (int _i1 = 0; _i1 < _list0.size; ++_i1)
1502                                                        {
1503                                                                ByteBuffer _elem2; // required
1504                                                                _elem2 = iprot.readBinary();
1505                                                                this.items.add(_elem2);
1506                                                        }
1507                                                        iprot.readListEnd();
1508                                                }
1509                                        } else {
1510                                                org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
1511                                        }
1512                                        break;
1513                                case 3: // EXPIRATION_MSEC
1514                                        if (field.type == org.apache.thrift7.protocol.TType.I32) {
1515                                                this.expiration_msec = iprot.readI32();
1516                                                set_expiration_msec_isSet(true);
1517                                        } else {
1518                                                org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
1519                                        }
1520                                        break;
1521                                default:
1522                                        org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
1523                                }
1524                                iprot.readFieldEnd();
1525                        }
1526                        iprot.readStructEnd();
1527                        validate();
1528                }
1529
1530                @Override
1531                public void write(org.apache.thrift7.protocol.TProtocol oprot) throws org.apache.thrift7.TException {
1532                        validate();
1533
1534                        oprot.writeStructBegin(STRUCT_DESC);
1535                        if (this.queue_name != null) {
1536                                oprot.writeFieldBegin(QUEUE_NAME_FIELD_DESC);
1537                                oprot.writeString(this.queue_name);
1538                                oprot.writeFieldEnd();
1539                        }
1540                        if (this.items != null) {
1541                                oprot.writeFieldBegin(ITEMS_FIELD_DESC);
1542                                {
1543                                        oprot.writeListBegin(new org.apache.thrift7.protocol.TList(org.apache.thrift7.protocol.TType.STRING,
1544                                                        this.items.size()));
1545                                        for (final ByteBuffer _iter3 : this.items)
1546                                        {
1547                                                oprot.writeBinary(_iter3);
1548                                        }
1549                                        oprot.writeListEnd();
1550                                }
1551                                oprot.writeFieldEnd();
1552                        }
1553                        oprot.writeFieldBegin(EXPIRATION_MSEC_FIELD_DESC);
1554                        oprot.writeI32(this.expiration_msec);
1555                        oprot.writeFieldEnd();
1556                        oprot.writeFieldStop();
1557                        oprot.writeStructEnd();
1558                }
1559
1560                @Override
1561                public String toString() {
1562                        final StringBuilder sb = new StringBuilder("put_args(");
1563                        boolean first = true;
1564
1565                        sb.append("queue_name:");
1566                        if (this.queue_name == null) {
1567                                sb.append("null");
1568                        } else {
1569                                sb.append(this.queue_name);
1570                        }
1571                        first = false;
1572                        if (!first)
1573                                sb.append(", ");
1574                        sb.append("items:");
1575                        if (this.items == null) {
1576                                sb.append("null");
1577                        } else {
1578                                sb.append(this.items);
1579                        }
1580                        first = false;
1581                        if (!first)
1582                                sb.append(", ");
1583                        sb.append("expiration_msec:");
1584                        sb.append(this.expiration_msec);
1585                        first = false;
1586                        sb.append(")");
1587                        return sb.toString();
1588                }
1589
1590                public void validate() throws org.apache.thrift7.TException {
1591                        // check for required fields
1592                }
1593
1594                private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
1595                        try {
1596                                write(new org.apache.thrift7.protocol.TCompactProtocol(
1597                                                new org.apache.thrift7.transport.TIOStreamTransport(out)));
1598                        } catch (final org.apache.thrift7.TException te) {
1599                                throw new java.io.IOException(te);
1600                        }
1601                }
1602
1603                private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
1604                        try {
1605                                // it doesn't seem like you should have to do this, but java
1606                                // serialization is wacky, and doesn't call the default
1607                                // constructor.
1608                                __isset_bit_vector = new BitSet(1);
1609                                read(new org.apache.thrift7.protocol.TCompactProtocol(
1610                                                new org.apache.thrift7.transport.TIOStreamTransport(in)));
1611                        } catch (final org.apache.thrift7.TException te) {
1612                                throw new java.io.IOException(te);
1613                        }
1614                }
1615
1616        }
1617
1618        public static class put_result
1619                        implements
1620                                org.apache.thrift7.TBase<put_result, put_result._Fields>,
1621                                java.io.Serializable,
1622                                Cloneable
1623        {
1624                private static final org.apache.thrift7.protocol.TStruct STRUCT_DESC = new org.apache.thrift7.protocol.TStruct(
1625                                "put_result");
1626
1627                private static final org.apache.thrift7.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift7.protocol.TField(
1628                                "success", org.apache.thrift7.protocol.TType.I32, (short) 0);
1629
1630                private int success; // required
1631
1632                /**
1633                 * The set of fields this struct contains, along with convenience
1634                 * methods for finding and manipulating them.
1635                 */
1636                public enum _Fields implements org.apache.thrift7.TFieldIdEnum {
1637                        SUCCESS((short) 0, "success");
1638
1639                        private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
1640
1641                        static {
1642                                for (final _Fields field : EnumSet.allOf(_Fields.class)) {
1643                                        byName.put(field.getFieldName(), field);
1644                                }
1645                        }
1646
1647                        /**
1648                         * Find the _Fields constant that matches fieldId, or null if its
1649                         * not found.
1650                         */
1651                        public static _Fields findByThriftId(int fieldId) {
1652                                switch (fieldId) {
1653                                case 0: // SUCCESS
1654                                        return SUCCESS;
1655                                default:
1656                                        return null;
1657                                }
1658                        }
1659
1660                        /**
1661                         * Find the _Fields constant that matches fieldId, throwing an
1662                         * exception if it is not found.
1663                         */
1664                        public static _Fields findByThriftIdOrThrow(int fieldId) {
1665                                final _Fields fields = findByThriftId(fieldId);
1666                                if (fields == null)
1667                                        throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
1668                                return fields;
1669                        }
1670
1671                        /**
1672                         * Find the _Fields constant that matches name, or null if its not
1673                         * found.
1674                         */
1675                        public static _Fields findByName(String name) {
1676                                return byName.get(name);
1677                        }
1678
1679                        private final short _thriftId;
1680                        private final String _fieldName;
1681
1682                        _Fields(short thriftId, String fieldName) {
1683                                _thriftId = thriftId;
1684                                _fieldName = fieldName;
1685                        }
1686
1687                        @Override
1688                        public short getThriftFieldId() {
1689                                return _thriftId;
1690                        }
1691
1692                        @Override
1693                        public String getFieldName() {
1694                                return _fieldName;
1695                        }
1696                }
1697
1698                // isset id assignments
1699                private static final int __SUCCESS_ISSET_ID = 0;
1700                private BitSet __isset_bit_vector = new BitSet(1);
1701
1702                public static final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> metaDataMap;
1703                static {
1704                        final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift7.meta_data.FieldMetaData>(
1705                                        _Fields.class);
1706                        tmpMap.put(_Fields.SUCCESS, new org.apache.thrift7.meta_data.FieldMetaData("success",
1707                                        org.apache.thrift7.TFieldRequirementType.DEFAULT,
1708                                        new org.apache.thrift7.meta_data.FieldValueMetaData(org.apache.thrift7.protocol.TType.I32)));
1709                        metaDataMap = Collections.unmodifiableMap(tmpMap);
1710                        org.apache.thrift7.meta_data.FieldMetaData.addStructMetaDataMap(put_result.class, metaDataMap);
1711                }
1712
1713                public put_result() {
1714                }
1715
1716                public put_result(
1717                                int success)
1718                {
1719                        this();
1720                        this.success = success;
1721                        set_success_isSet(true);
1722                }
1723
1724                /**
1725                 * Performs a deep copy on <i>other</i>.
1726                 */
1727                public put_result(put_result other) {
1728                        __isset_bit_vector.clear();
1729                        __isset_bit_vector.or(other.__isset_bit_vector);
1730                        this.success = other.success;
1731                }
1732
1733                @Override
1734                public put_result deepCopy() {
1735                        return new put_result(this);
1736                }
1737
1738                @Override
1739                public void clear() {
1740                        set_success_isSet(false);
1741                        this.success = 0;
1742                }
1743
1744                public int get_success() {
1745                        return this.success;
1746                }
1747
1748                public void set_success(int success) {
1749                        this.success = success;
1750                        set_success_isSet(true);
1751                }
1752
1753                public void unset_success() {
1754                        __isset_bit_vector.clear(__SUCCESS_ISSET_ID);
1755                }
1756
1757                /**
1758                 * Returns true if field success is set (has been assigned a value) and
1759                 * false otherwise
1760                 */
1761                public boolean is_set_success() {
1762                        return __isset_bit_vector.get(__SUCCESS_ISSET_ID);
1763                }
1764
1765                public void set_success_isSet(boolean value) {
1766                        __isset_bit_vector.set(__SUCCESS_ISSET_ID, value);
1767                }
1768
1769                @Override
1770                public void setFieldValue(_Fields field, Object value) {
1771                        switch (field) {
1772                        case SUCCESS:
1773                                if (value == null) {
1774                                        unset_success();
1775                                } else {
1776                                        set_success((Integer) value);
1777                                }
1778                                break;
1779
1780                        }
1781                }
1782
1783                @Override
1784                public Object getFieldValue(_Fields field) {
1785                        switch (field) {
1786                        case SUCCESS:
1787                                return Integer.valueOf(get_success());
1788
1789                        }
1790                        throw new IllegalStateException();
1791                }
1792
1793                /**
1794                 * Returns true if field corresponding to fieldID is set (has been
1795                 * assigned a value) and false otherwise
1796                 */
1797                @Override
1798                public boolean isSet(_Fields field) {
1799                        if (field == null) {
1800                                throw new IllegalArgumentException();
1801                        }
1802
1803                        switch (field) {
1804                        case SUCCESS:
1805                                return is_set_success();
1806                        }
1807                        throw new IllegalStateException();
1808                }
1809
1810                @Override
1811                public boolean equals(Object that) {
1812                        if (that == null)
1813                                return false;
1814                        if (that instanceof put_result)
1815                                return this.equals((put_result) that);
1816                        return false;
1817                }
1818
1819                public boolean equals(put_result that) {
1820                        if (that == null)
1821                                return false;
1822
1823                        final boolean this_present_success = true;
1824                        final boolean that_present_success = true;
1825                        if (this_present_success || that_present_success) {
1826                                if (!(this_present_success && that_present_success))
1827                                        return false;
1828                                if (this.success != that.success)
1829                                        return false;
1830                        }
1831
1832                        return true;
1833                }
1834
1835                @Override
1836                public int hashCode() {
1837                        final HashCodeBuilder builder = new HashCodeBuilder();
1838
1839                        final boolean present_success = true;
1840                        builder.append(present_success);
1841                        if (present_success)
1842                                builder.append(success);
1843
1844                        return builder.toHashCode();
1845                }
1846
1847                @Override
1848                public int compareTo(put_result other) {
1849                        if (!getClass().equals(other.getClass())) {
1850                                return getClass().getName().compareTo(other.getClass().getName());
1851                        }
1852
1853                        int lastComparison = 0;
1854                        final put_result typedOther = other;
1855
1856                        lastComparison = Boolean.valueOf(is_set_success()).compareTo(typedOther.is_set_success());
1857                        if (lastComparison != 0) {
1858                                return lastComparison;
1859                        }
1860                        if (is_set_success()) {
1861                                lastComparison = org.apache.thrift7.TBaseHelper.compareTo(this.success, typedOther.success);
1862                                if (lastComparison != 0) {
1863                                        return lastComparison;
1864                                }
1865                        }
1866                        return 0;
1867                }
1868
1869                @Override
1870                public _Fields fieldForId(int fieldId) {
1871                        return _Fields.findByThriftId(fieldId);
1872                }
1873
1874                @Override
1875                public void read(org.apache.thrift7.protocol.TProtocol iprot) throws org.apache.thrift7.TException {
1876                        org.apache.thrift7.protocol.TField field;
1877                        iprot.readStructBegin();
1878                        while (true)
1879                        {
1880                                field = iprot.readFieldBegin();
1881                                if (field.type == org.apache.thrift7.protocol.TType.STOP) {
1882                                        break;
1883                                }
1884                                switch (field.id) {
1885                                case 0: // SUCCESS
1886                                        if (field.type == org.apache.thrift7.protocol.TType.I32) {
1887                                                this.success = iprot.readI32();
1888                                                set_success_isSet(true);
1889                                        } else {
1890                                                org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
1891                                        }
1892                                        break;
1893                                default:
1894                                        org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
1895                                }
1896                                iprot.readFieldEnd();
1897                        }
1898                        iprot.readStructEnd();
1899                        validate();
1900                }
1901
1902                @Override
1903                public void write(org.apache.thrift7.protocol.TProtocol oprot) throws org.apache.thrift7.TException {
1904                        oprot.writeStructBegin(STRUCT_DESC);
1905
1906                        if (this.is_set_success()) {
1907                                oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
1908                                oprot.writeI32(this.success);
1909                                oprot.writeFieldEnd();
1910                        }
1911                        oprot.writeFieldStop();
1912                        oprot.writeStructEnd();
1913                }
1914
1915                @Override
1916                public String toString() {
1917                        final StringBuilder sb = new StringBuilder("put_result(");
1918                        boolean first = true;
1919
1920                        sb.append("success:");
1921                        sb.append(this.success);
1922                        first = false;
1923                        sb.append(")");
1924                        return sb.toString();
1925                }
1926
1927                public void validate() throws org.apache.thrift7.TException {
1928                        // check for required fields
1929                }
1930
1931                private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
1932                        try {
1933                                write(new org.apache.thrift7.protocol.TCompactProtocol(
1934                                                new org.apache.thrift7.transport.TIOStreamTransport(out)));
1935                        } catch (final org.apache.thrift7.TException te) {
1936                                throw new java.io.IOException(te);
1937                        }
1938                }
1939
1940                private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
1941                        try {
1942                                read(new org.apache.thrift7.protocol.TCompactProtocol(
1943                                                new org.apache.thrift7.transport.TIOStreamTransport(in)));
1944                        } catch (final org.apache.thrift7.TException te) {
1945                                throw new java.io.IOException(te);
1946                        }
1947                }
1948
1949        }
1950
1951        public static class get_args
1952                        implements
1953                                org.apache.thrift7.TBase<get_args, get_args._Fields>,
1954                                java.io.Serializable,
1955                                Cloneable
1956        {
1957                private static final org.apache.thrift7.protocol.TStruct STRUCT_DESC = new org.apache.thrift7.protocol.TStruct(
1958                                "get_args");
1959
1960                private static final org.apache.thrift7.protocol.TField QUEUE_NAME_FIELD_DESC = new org.apache.thrift7.protocol.TField(
1961                                "queue_name", org.apache.thrift7.protocol.TType.STRING, (short) 1);
1962                private static final org.apache.thrift7.protocol.TField MAX_ITEMS_FIELD_DESC = new org.apache.thrift7.protocol.TField(
1963                                "max_items", org.apache.thrift7.protocol.TType.I32, (short) 2);
1964                private static final org.apache.thrift7.protocol.TField TIMEOUT_MSEC_FIELD_DESC = new org.apache.thrift7.protocol.TField(
1965                                "timeout_msec", org.apache.thrift7.protocol.TType.I32, (short) 3);
1966                private static final org.apache.thrift7.protocol.TField AUTO_ABORT_MSEC_FIELD_DESC = new org.apache.thrift7.protocol.TField(
1967                                "auto_abort_msec", org.apache.thrift7.protocol.TType.I32, (short) 4);
1968
1969                private String queue_name; // required
1970                private int max_items; // required
1971                private int timeout_msec; // required
1972                private int auto_abort_msec; // required
1973
1974                /**
1975                 * The set of fields this struct contains, along with convenience
1976                 * methods for finding and manipulating them.
1977                 */
1978                public enum _Fields implements org.apache.thrift7.TFieldIdEnum {
1979                        QUEUE_NAME((short) 1, "queue_name"),
1980                        MAX_ITEMS((short) 2, "max_items"),
1981                        TIMEOUT_MSEC((short) 3, "timeout_msec"),
1982                        AUTO_ABORT_MSEC((short) 4, "auto_abort_msec");
1983
1984                        private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
1985
1986                        static {
1987                                for (final _Fields field : EnumSet.allOf(_Fields.class)) {
1988                                        byName.put(field.getFieldName(), field);
1989                                }
1990                        }
1991
1992                        /**
1993                         * Find the _Fields constant that matches fieldId, or null if its
1994                         * not found.
1995                         */
1996                        public static _Fields findByThriftId(int fieldId) {
1997                                switch (fieldId) {
1998                                case 1: // QUEUE_NAME
1999                                        return QUEUE_NAME;
2000                                case 2: // MAX_ITEMS
2001                                        return MAX_ITEMS;
2002                                case 3: // TIMEOUT_MSEC
2003                                        return TIMEOUT_MSEC;
2004                                case 4: // AUTO_ABORT_MSEC
2005                                        return AUTO_ABORT_MSEC;
2006                                default:
2007                                        return null;
2008                                }
2009                        }
2010
2011                        /**
2012                         * Find the _Fields constant that matches fieldId, throwing an
2013                         * exception if it is not found.
2014                         */
2015                        public static _Fields findByThriftIdOrThrow(int fieldId) {
2016                                final _Fields fields = findByThriftId(fieldId);
2017                                if (fields == null)
2018                                        throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
2019                                return fields;
2020                        }
2021
2022                        /**
2023                         * Find the _Fields constant that matches name, or null if its not
2024                         * found.
2025                         */
2026                        public static _Fields findByName(String name) {
2027                                return byName.get(name);
2028                        }
2029
2030                        private final short _thriftId;
2031                        private final String _fieldName;
2032
2033                        _Fields(short thriftId, String fieldName) {
2034                                _thriftId = thriftId;
2035                                _fieldName = fieldName;
2036                        }
2037
2038                        @Override
2039                        public short getThriftFieldId() {
2040                                return _thriftId;
2041                        }
2042
2043                        @Override
2044                        public String getFieldName() {
2045                                return _fieldName;
2046                        }
2047                }
2048
2049                // isset id assignments
2050                private static final int __MAX_ITEMS_ISSET_ID = 0;
2051                private static final int __TIMEOUT_MSEC_ISSET_ID = 1;
2052                private static final int __AUTO_ABORT_MSEC_ISSET_ID = 2;
2053                private BitSet __isset_bit_vector = new BitSet(3);
2054
2055                public static final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> metaDataMap;
2056                static {
2057                        final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift7.meta_data.FieldMetaData>(
2058                                        _Fields.class);
2059                        tmpMap.put(_Fields.QUEUE_NAME, new org.apache.thrift7.meta_data.FieldMetaData("queue_name",
2060                                        org.apache.thrift7.TFieldRequirementType.DEFAULT,
2061                                        new org.apache.thrift7.meta_data.FieldValueMetaData(org.apache.thrift7.protocol.TType.STRING)));
2062                        tmpMap.put(_Fields.MAX_ITEMS, new org.apache.thrift7.meta_data.FieldMetaData("max_items",
2063                                        org.apache.thrift7.TFieldRequirementType.DEFAULT,
2064                                        new org.apache.thrift7.meta_data.FieldValueMetaData(org.apache.thrift7.protocol.TType.I32)));
2065                        tmpMap.put(_Fields.TIMEOUT_MSEC, new org.apache.thrift7.meta_data.FieldMetaData("timeout_msec",
2066                                        org.apache.thrift7.TFieldRequirementType.DEFAULT,
2067                                        new org.apache.thrift7.meta_data.FieldValueMetaData(org.apache.thrift7.protocol.TType.I32)));
2068                        tmpMap.put(_Fields.AUTO_ABORT_MSEC, new org.apache.thrift7.meta_data.FieldMetaData("auto_abort_msec",
2069                                        org.apache.thrift7.TFieldRequirementType.DEFAULT,
2070                                        new org.apache.thrift7.meta_data.FieldValueMetaData(org.apache.thrift7.protocol.TType.I32)));
2071                        metaDataMap = Collections.unmodifiableMap(tmpMap);
2072                        org.apache.thrift7.meta_data.FieldMetaData.addStructMetaDataMap(get_args.class, metaDataMap);
2073                }
2074
2075                public get_args() {
2076                        this.timeout_msec = 0;
2077
2078                        this.auto_abort_msec = 0;
2079
2080                }
2081
2082                public get_args(
2083                                String queue_name,
2084                                int max_items,
2085                                int timeout_msec,
2086                                int auto_abort_msec)
2087                {
2088                        this();
2089                        this.queue_name = queue_name;
2090                        this.max_items = max_items;
2091                        set_max_items_isSet(true);
2092                        this.timeout_msec = timeout_msec;
2093                        set_timeout_msec_isSet(true);
2094                        this.auto_abort_msec = auto_abort_msec;
2095                        set_auto_abort_msec_isSet(true);
2096                }
2097
2098                /**
2099                 * Performs a deep copy on <i>other</i>.
2100                 */
2101                public get_args(get_args other) {
2102                        __isset_bit_vector.clear();
2103                        __isset_bit_vector.or(other.__isset_bit_vector);
2104                        if (other.is_set_queue_name()) {
2105                                this.queue_name = other.queue_name;
2106                        }
2107                        this.max_items = other.max_items;
2108                        this.timeout_msec = other.timeout_msec;
2109                        this.auto_abort_msec = other.auto_abort_msec;
2110                }
2111
2112                @Override
2113                public get_args deepCopy() {
2114                        return new get_args(this);
2115                }
2116
2117                @Override
2118                public void clear() {
2119                        this.queue_name = null;
2120                        set_max_items_isSet(false);
2121                        this.max_items = 0;
2122                        this.timeout_msec = 0;
2123
2124                        this.auto_abort_msec = 0;
2125
2126                }
2127
2128                public String get_queue_name() {
2129                        return this.queue_name;
2130                }
2131
2132                public void set_queue_name(String queue_name) {
2133                        this.queue_name = queue_name;
2134                }
2135
2136                public void unset_queue_name() {
2137                        this.queue_name = null;
2138                }
2139
2140                /**
2141                 * Returns true if field queue_name is set (has been assigned a value)
2142                 * and false otherwise
2143                 */
2144                public boolean is_set_queue_name() {
2145                        return this.queue_name != null;
2146                }
2147
2148                public void set_queue_name_isSet(boolean value) {
2149                        if (!value) {
2150                                this.queue_name = null;
2151                        }
2152                }
2153
2154                public int get_max_items() {
2155                        return this.max_items;
2156                }
2157
2158                public void set_max_items(int max_items) {
2159                        this.max_items = max_items;
2160                        set_max_items_isSet(true);
2161                }
2162
2163                public void unset_max_items() {
2164                        __isset_bit_vector.clear(__MAX_ITEMS_ISSET_ID);
2165                }
2166
2167                /**
2168                 * Returns true if field max_items is set (has been assigned a value)
2169                 * and false otherwise
2170                 */
2171                public boolean is_set_max_items() {
2172                        return __isset_bit_vector.get(__MAX_ITEMS_ISSET_ID);
2173                }
2174
2175                public void set_max_items_isSet(boolean value) {
2176                        __isset_bit_vector.set(__MAX_ITEMS_ISSET_ID, value);
2177                }
2178
2179                public int get_timeout_msec() {
2180                        return this.timeout_msec;
2181                }
2182
2183                public void set_timeout_msec(int timeout_msec) {
2184                        this.timeout_msec = timeout_msec;
2185                        set_timeout_msec_isSet(true);
2186                }
2187
2188                public void unset_timeout_msec() {
2189                        __isset_bit_vector.clear(__TIMEOUT_MSEC_ISSET_ID);
2190                }
2191
2192                /**
2193                 * Returns true if field timeout_msec is set (has been assigned a value)
2194                 * and false otherwise
2195                 */
2196                public boolean is_set_timeout_msec() {
2197                        return __isset_bit_vector.get(__TIMEOUT_MSEC_ISSET_ID);
2198                }
2199
2200                public void set_timeout_msec_isSet(boolean value) {
2201                        __isset_bit_vector.set(__TIMEOUT_MSEC_ISSET_ID, value);
2202                }
2203
2204                public int get_auto_abort_msec() {
2205                        return this.auto_abort_msec;
2206                }
2207
2208                public void set_auto_abort_msec(int auto_abort_msec) {
2209                        this.auto_abort_msec = auto_abort_msec;
2210                        set_auto_abort_msec_isSet(true);
2211                }
2212
2213                public void unset_auto_abort_msec() {
2214                        __isset_bit_vector.clear(__AUTO_ABORT_MSEC_ISSET_ID);
2215                }
2216
2217                /**
2218                 * Returns true if field auto_abort_msec is set (has been assigned a
2219                 * value) and false otherwise
2220                 */
2221                public boolean is_set_auto_abort_msec() {
2222                        return __isset_bit_vector.get(__AUTO_ABORT_MSEC_ISSET_ID);
2223                }
2224
2225                public void set_auto_abort_msec_isSet(boolean value) {
2226                        __isset_bit_vector.set(__AUTO_ABORT_MSEC_ISSET_ID, value);
2227                }
2228
2229                @Override
2230                public void setFieldValue(_Fields field, Object value) {
2231                        switch (field) {
2232                        case QUEUE_NAME:
2233                                if (value == null) {
2234                                        unset_queue_name();
2235                                } else {
2236                                        set_queue_name((String) value);
2237                                }
2238                                break;
2239
2240                        case MAX_ITEMS:
2241                                if (value == null) {
2242                                        unset_max_items();
2243                                } else {
2244                                        set_max_items((Integer) value);
2245                                }
2246                                break;
2247
2248                        case TIMEOUT_MSEC:
2249                                if (value == null) {
2250                                        unset_timeout_msec();
2251                                } else {
2252                                        set_timeout_msec((Integer) value);
2253                                }
2254                                break;
2255
2256                        case AUTO_ABORT_MSEC:
2257                                if (value == null) {
2258                                        unset_auto_abort_msec();
2259                                } else {
2260                                        set_auto_abort_msec((Integer) value);
2261                                }
2262                                break;
2263
2264                        }
2265                }
2266
2267                @Override
2268                public Object getFieldValue(_Fields field) {
2269                        switch (field) {
2270                        case QUEUE_NAME:
2271                                return get_queue_name();
2272
2273                        case MAX_ITEMS:
2274                                return Integer.valueOf(get_max_items());
2275
2276                        case TIMEOUT_MSEC:
2277                                return Integer.valueOf(get_timeout_msec());
2278
2279                        case AUTO_ABORT_MSEC:
2280                                return Integer.valueOf(get_auto_abort_msec());
2281
2282                        }
2283                        throw new IllegalStateException();
2284                }
2285
2286                /**
2287                 * Returns true if field corresponding to fieldID is set (has been
2288                 * assigned a value) and false otherwise
2289                 */
2290                @Override
2291                public boolean isSet(_Fields field) {
2292                        if (field == null) {
2293                                throw new IllegalArgumentException();
2294                        }
2295
2296                        switch (field) {
2297                        case QUEUE_NAME:
2298                                return is_set_queue_name();
2299                        case MAX_ITEMS:
2300                                return is_set_max_items();
2301                        case TIMEOUT_MSEC:
2302                                return is_set_timeout_msec();
2303                        case AUTO_ABORT_MSEC:
2304                                return is_set_auto_abort_msec();
2305                        }
2306                        throw new IllegalStateException();
2307                }
2308
2309                @Override
2310                public boolean equals(Object that) {
2311                        if (that == null)
2312                                return false;
2313                        if (that instanceof get_args)
2314                                return this.equals((get_args) that);
2315                        return false;
2316                }
2317
2318                public boolean equals(get_args that) {
2319                        if (that == null)
2320                                return false;
2321
2322                        final boolean this_present_queue_name = true && this.is_set_queue_name();
2323                        final boolean that_present_queue_name = true && that.is_set_queue_name();
2324                        if (this_present_queue_name || that_present_queue_name) {
2325                                if (!(this_present_queue_name && that_present_queue_name))
2326                                        return false;
2327                                if (!this.queue_name.equals(that.queue_name))
2328                                        return false;
2329                        }
2330
2331                        final boolean this_present_max_items = true;
2332                        final boolean that_present_max_items = true;
2333                        if (this_present_max_items || that_present_max_items) {
2334                                if (!(this_present_max_items && that_present_max_items))
2335                                        return false;
2336                                if (this.max_items != that.max_items)
2337                                        return false;
2338                        }
2339
2340                        final boolean this_present_timeout_msec = true;
2341                        final boolean that_present_timeout_msec = true;
2342                        if (this_present_timeout_msec || that_present_timeout_msec) {
2343                                if (!(this_present_timeout_msec && that_present_timeout_msec))
2344                                        return false;
2345                                if (this.timeout_msec != that.timeout_msec)
2346                                        return false;
2347                        }
2348
2349                        final boolean this_present_auto_abort_msec = true;
2350                        final boolean that_present_auto_abort_msec = true;
2351                        if (this_present_auto_abort_msec || that_present_auto_abort_msec) {
2352                                if (!(this_present_auto_abort_msec && that_present_auto_abort_msec))
2353                                        return false;
2354                                if (this.auto_abort_msec != that.auto_abort_msec)
2355                                        return false;
2356                        }
2357
2358                        return true;
2359                }
2360
2361                @Override
2362                public int hashCode() {
2363                        final HashCodeBuilder builder = new HashCodeBuilder();
2364
2365                        final boolean present_queue_name = true && (is_set_queue_name());
2366                        builder.append(present_queue_name);
2367                        if (present_queue_name)
2368                                builder.append(queue_name);
2369
2370                        final boolean present_max_items = true;
2371                        builder.append(present_max_items);
2372                        if (present_max_items)
2373                                builder.append(max_items);
2374
2375                        final boolean present_timeout_msec = true;
2376                        builder.append(present_timeout_msec);
2377                        if (present_timeout_msec)
2378                                builder.append(timeout_msec);
2379
2380                        final boolean present_auto_abort_msec = true;
2381                        builder.append(present_auto_abort_msec);
2382                        if (present_auto_abort_msec)
2383                                builder.append(auto_abort_msec);
2384
2385                        return builder.toHashCode();
2386                }
2387
2388                @Override
2389                public int compareTo(get_args other) {
2390                        if (!getClass().equals(other.getClass())) {
2391                                return getClass().getName().compareTo(other.getClass().getName());
2392                        }
2393
2394                        int lastComparison = 0;
2395                        final get_args typedOther = other;
2396
2397                        lastComparison = Boolean.valueOf(is_set_queue_name()).compareTo(typedOther.is_set_queue_name());
2398                        if (lastComparison != 0) {
2399                                return lastComparison;
2400                        }
2401                        if (is_set_queue_name()) {
2402                                lastComparison = org.apache.thrift7.TBaseHelper.compareTo(this.queue_name, typedOther.queue_name);
2403                                if (lastComparison != 0) {
2404                                        return lastComparison;
2405                                }
2406                        }
2407                        lastComparison = Boolean.valueOf(is_set_max_items()).compareTo(typedOther.is_set_max_items());
2408                        if (lastComparison != 0) {
2409                                return lastComparison;
2410                        }
2411                        if (is_set_max_items()) {
2412                                lastComparison = org.apache.thrift7.TBaseHelper.compareTo(this.max_items, typedOther.max_items);
2413                                if (lastComparison != 0) {
2414                                        return lastComparison;
2415                                }
2416                        }
2417                        lastComparison = Boolean.valueOf(is_set_timeout_msec()).compareTo(typedOther.is_set_timeout_msec());
2418                        if (lastComparison != 0) {
2419                                return lastComparison;
2420                        }
2421                        if (is_set_timeout_msec()) {
2422                                lastComparison = org.apache.thrift7.TBaseHelper.compareTo(this.timeout_msec, typedOther.timeout_msec);
2423                                if (lastComparison != 0) {
2424                                        return lastComparison;
2425                                }
2426                        }
2427                        lastComparison = Boolean.valueOf(is_set_auto_abort_msec()).compareTo(typedOther.is_set_auto_abort_msec());
2428                        if (lastComparison != 0) {
2429                                return lastComparison;
2430                        }
2431                        if (is_set_auto_abort_msec()) {
2432                                lastComparison = org.apache.thrift7.TBaseHelper.compareTo(this.auto_abort_msec,
2433                                                typedOther.auto_abort_msec);
2434                                if (lastComparison != 0) {
2435                                        return lastComparison;
2436                                }
2437                        }
2438                        return 0;
2439                }
2440
2441                @Override
2442                public _Fields fieldForId(int fieldId) {
2443                        return _Fields.findByThriftId(fieldId);
2444                }
2445
2446                @Override
2447                public void read(org.apache.thrift7.protocol.TProtocol iprot) throws org.apache.thrift7.TException {
2448                        org.apache.thrift7.protocol.TField field;
2449                        iprot.readStructBegin();
2450                        while (true)
2451                        {
2452                                field = iprot.readFieldBegin();
2453                                if (field.type == org.apache.thrift7.protocol.TType.STOP) {
2454                                        break;
2455                                }
2456                                switch (field.id) {
2457                                case 1: // QUEUE_NAME
2458                                        if (field.type == org.apache.thrift7.protocol.TType.STRING) {
2459                                                this.queue_name = iprot.readString();
2460                                        } else {
2461                                                org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
2462                                        }
2463                                        break;
2464                                case 2: // MAX_ITEMS
2465                                        if (field.type == org.apache.thrift7.protocol.TType.I32) {
2466                                                this.max_items = iprot.readI32();
2467                                                set_max_items_isSet(true);
2468                                        } else {
2469                                                org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
2470                                        }
2471                                        break;
2472                                case 3: // TIMEOUT_MSEC
2473                                        if (field.type == org.apache.thrift7.protocol.TType.I32) {
2474                                                this.timeout_msec = iprot.readI32();
2475                                                set_timeout_msec_isSet(true);
2476                                        } else {
2477                                                org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
2478                                        }
2479                                        break;
2480                                case 4: // AUTO_ABORT_MSEC
2481                                        if (field.type == org.apache.thrift7.protocol.TType.I32) {
2482                                                this.auto_abort_msec = iprot.readI32();
2483                                                set_auto_abort_msec_isSet(true);
2484                                        } else {
2485                                                org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
2486                                        }
2487                                        break;
2488                                default:
2489                                        org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
2490                                }
2491                                iprot.readFieldEnd();
2492                        }
2493                        iprot.readStructEnd();
2494                        validate();
2495                }
2496
2497                @Override
2498                public void write(org.apache.thrift7.protocol.TProtocol oprot) throws org.apache.thrift7.TException {
2499                        validate();
2500
2501                        oprot.writeStructBegin(STRUCT_DESC);
2502                        if (this.queue_name != null) {
2503                                oprot.writeFieldBegin(QUEUE_NAME_FIELD_DESC);
2504                                oprot.writeString(this.queue_name);
2505                                oprot.writeFieldEnd();
2506                        }
2507                        oprot.writeFieldBegin(MAX_ITEMS_FIELD_DESC);
2508                        oprot.writeI32(this.max_items);
2509                        oprot.writeFieldEnd();
2510                        oprot.writeFieldBegin(TIMEOUT_MSEC_FIELD_DESC);
2511                        oprot.writeI32(this.timeout_msec);
2512                        oprot.writeFieldEnd();
2513                        oprot.writeFieldBegin(AUTO_ABORT_MSEC_FIELD_DESC);
2514                        oprot.writeI32(this.auto_abort_msec);
2515                        oprot.writeFieldEnd();
2516                        oprot.writeFieldStop();
2517                        oprot.writeStructEnd();
2518                }
2519
2520                @Override
2521                public String toString() {
2522                        final StringBuilder sb = new StringBuilder("get_args(");
2523                        boolean first = true;
2524
2525                        sb.append("queue_name:");
2526                        if (this.queue_name == null) {
2527                                sb.append("null");
2528                        } else {
2529                                sb.append(this.queue_name);
2530                        }
2531                        first = false;
2532                        if (!first)
2533                                sb.append(", ");
2534                        sb.append("max_items:");
2535                        sb.append(this.max_items);
2536                        first = false;
2537                        if (!first)
2538                                sb.append(", ");
2539                        sb.append("timeout_msec:");
2540                        sb.append(this.timeout_msec);
2541                        first = false;
2542                        if (!first)
2543                                sb.append(", ");
2544                        sb.append("auto_abort_msec:");
2545                        sb.append(this.auto_abort_msec);
2546                        first = false;
2547                        sb.append(")");
2548                        return sb.toString();
2549                }
2550
2551                public void validate() throws org.apache.thrift7.TException {
2552                        // check for required fields
2553                }
2554
2555                private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
2556                        try {
2557                                write(new org.apache.thrift7.protocol.TCompactProtocol(
2558                                                new org.apache.thrift7.transport.TIOStreamTransport(out)));
2559                        } catch (final org.apache.thrift7.TException te) {
2560                                throw new java.io.IOException(te);
2561                        }
2562                }
2563
2564                private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
2565                        try {
2566                                // it doesn't seem like you should have to do this, but java
2567                                // serialization is wacky, and doesn't call the default
2568                                // constructor.
2569                                __isset_bit_vector = new BitSet(1);
2570                                read(new org.apache.thrift7.protocol.TCompactProtocol(
2571                                                new org.apache.thrift7.transport.TIOStreamTransport(in)));
2572                        } catch (final org.apache.thrift7.TException te) {
2573                                throw new java.io.IOException(te);
2574                        }
2575                }
2576
2577        }
2578
2579        public static class get_result
2580                        implements
2581                                org.apache.thrift7.TBase<get_result, get_result._Fields>,
2582                                java.io.Serializable,
2583                                Cloneable
2584        {
2585                private static final org.apache.thrift7.protocol.TStruct STRUCT_DESC = new org.apache.thrift7.protocol.TStruct(
2586                                "get_result");
2587
2588                private static final org.apache.thrift7.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift7.protocol.TField(
2589                                "success", org.apache.thrift7.protocol.TType.LIST, (short) 0);
2590
2591                private List<Item> success; // required
2592
2593                /**
2594                 * The set of fields this struct contains, along with convenience
2595                 * methods for finding and manipulating them.
2596                 */
2597                public enum _Fields implements org.apache.thrift7.TFieldIdEnum {
2598                        SUCCESS((short) 0, "success");
2599
2600                        private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
2601
2602                        static {
2603                                for (final _Fields field : EnumSet.allOf(_Fields.class)) {
2604                                        byName.put(field.getFieldName(), field);
2605                                }
2606                        }
2607
2608                        /**
2609                         * Find the _Fields constant that matches fieldId, or null if its
2610                         * not found.
2611                         */
2612                        public static _Fields findByThriftId(int fieldId) {
2613                                switch (fieldId) {
2614                                case 0: // SUCCESS
2615                                        return SUCCESS;
2616                                default:
2617                                        return null;
2618                                }
2619                        }
2620
2621                        /**
2622                         * Find the _Fields constant that matches fieldId, throwing an
2623                         * exception if it is not found.
2624                         */
2625                        public static _Fields findByThriftIdOrThrow(int fieldId) {
2626                                final _Fields fields = findByThriftId(fieldId);
2627                                if (fields == null)
2628                                        throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
2629                                return fields;
2630                        }
2631
2632                        /**
2633                         * Find the _Fields constant that matches name, or null if its not
2634                         * found.
2635                         */
2636                        public static _Fields findByName(String name) {
2637                                return byName.get(name);
2638                        }
2639
2640                        private final short _thriftId;
2641                        private final String _fieldName;
2642
2643                        _Fields(short thriftId, String fieldName) {
2644                                _thriftId = thriftId;
2645                                _fieldName = fieldName;
2646                        }
2647
2648                        @Override
2649                        public short getThriftFieldId() {
2650                                return _thriftId;
2651                        }
2652
2653                        @Override
2654                        public String getFieldName() {
2655                                return _fieldName;
2656                        }
2657                }
2658
2659                // isset id assignments
2660
2661                public static final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> metaDataMap;
2662                static {
2663                        final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift7.meta_data.FieldMetaData>(
2664                                        _Fields.class);
2665                        tmpMap.put(_Fields.SUCCESS, new org.apache.thrift7.meta_data.FieldMetaData("success",
2666                                        org.apache.thrift7.TFieldRequirementType.DEFAULT,
2667                                        new org.apache.thrift7.meta_data.ListMetaData(org.apache.thrift7.protocol.TType.LIST,
2668                                                        new org.apache.thrift7.meta_data.StructMetaData(org.apache.thrift7.protocol.TType.STRUCT,
2669                                                                        Item.class))));
2670                        metaDataMap = Collections.unmodifiableMap(tmpMap);
2671                        org.apache.thrift7.meta_data.FieldMetaData.addStructMetaDataMap(get_result.class, metaDataMap);
2672                }
2673
2674                public get_result() {
2675                }
2676
2677                public get_result(
2678                                List<Item> success)
2679                {
2680                        this();
2681                        this.success = success;
2682                }
2683
2684                /**
2685                 * Performs a deep copy on <i>other</i>.
2686                 */
2687                public get_result(get_result other) {
2688                        if (other.is_set_success()) {
2689                                final List<Item> __this__success = new ArrayList<Item>();
2690                                for (final Item other_element : other.success) {
2691                                        __this__success.add(new Item(other_element));
2692                                }
2693                                this.success = __this__success;
2694                        }
2695                }
2696
2697                @Override
2698                public get_result deepCopy() {
2699                        return new get_result(this);
2700                }
2701
2702                @Override
2703                public void clear() {
2704                        this.success = null;
2705                }
2706
2707                public int get_success_size() {
2708                        return (this.success == null) ? 0 : this.success.size();
2709                }
2710
2711                public java.util.Iterator<Item> get_success_iterator() {
2712                        return (this.success == null) ? null : this.success.iterator();
2713                }
2714
2715                public void add_to_success(Item elem) {
2716                        if (this.success == null) {
2717                                this.success = new ArrayList<Item>();
2718                        }
2719                        this.success.add(elem);
2720                }
2721
2722                public List<Item> get_success() {
2723                        return this.success;
2724                }
2725
2726                public void set_success(List<Item> success) {
2727                        this.success = success;
2728                }
2729
2730                public void unset_success() {
2731                        this.success = null;
2732                }
2733
2734                /**
2735                 * Returns true if field success is set (has been assigned a value) and
2736                 * false otherwise
2737                 */
2738                public boolean is_set_success() {
2739                        return this.success != null;
2740                }
2741
2742                public void set_success_isSet(boolean value) {
2743                        if (!value) {
2744                                this.success = null;
2745                        }
2746                }
2747
2748                @Override
2749                public void setFieldValue(_Fields field, Object value) {
2750                        switch (field) {
2751                        case SUCCESS:
2752                                if (value == null) {
2753                                        unset_success();
2754                                } else {
2755                                        set_success((List<Item>) value);
2756                                }
2757                                break;
2758
2759                        }
2760                }
2761
2762                @Override
2763                public Object getFieldValue(_Fields field) {
2764                        switch (field) {
2765                        case SUCCESS:
2766                                return get_success();
2767
2768                        }
2769                        throw new IllegalStateException();
2770                }
2771
2772                /**
2773                 * Returns true if field corresponding to fieldID is set (has been
2774                 * assigned a value) and false otherwise
2775                 */
2776                @Override
2777                public boolean isSet(_Fields field) {
2778                        if (field == null) {
2779                                throw new IllegalArgumentException();
2780                        }
2781
2782                        switch (field) {
2783                        case SUCCESS:
2784                                return is_set_success();
2785                        }
2786                        throw new IllegalStateException();
2787                }
2788
2789                @Override
2790                public boolean equals(Object that) {
2791                        if (that == null)
2792                                return false;
2793                        if (that instanceof get_result)
2794                                return this.equals((get_result) that);
2795                        return false;
2796                }
2797
2798                public boolean equals(get_result that) {
2799                        if (that == null)
2800                                return false;
2801
2802                        final boolean this_present_success = true && this.is_set_success();
2803                        final boolean that_present_success = true && that.is_set_success();
2804                        if (this_present_success || that_present_success) {
2805                                if (!(this_present_success && that_present_success))
2806                                        return false;
2807                                if (!this.success.equals(that.success))
2808                                        return false;
2809                        }
2810
2811                        return true;
2812                }
2813
2814                @Override
2815                public int hashCode() {
2816                        final HashCodeBuilder builder = new HashCodeBuilder();
2817
2818                        final boolean present_success = true && (is_set_success());
2819                        builder.append(present_success);
2820                        if (present_success)
2821                                builder.append(success);
2822
2823                        return builder.toHashCode();
2824                }
2825
2826                @Override
2827                public int compareTo(get_result other) {
2828                        if (!getClass().equals(other.getClass())) {
2829                                return getClass().getName().compareTo(other.getClass().getName());
2830                        }
2831
2832                        int lastComparison = 0;
2833                        final get_result typedOther = other;
2834
2835                        lastComparison = Boolean.valueOf(is_set_success()).compareTo(typedOther.is_set_success());
2836                        if (lastComparison != 0) {
2837                                return lastComparison;
2838                        }
2839                        if (is_set_success()) {
2840                                lastComparison = org.apache.thrift7.TBaseHelper.compareTo(this.success, typedOther.success);
2841                                if (lastComparison != 0) {
2842                                        return lastComparison;
2843                                }
2844                        }
2845                        return 0;
2846                }
2847
2848                @Override
2849                public _Fields fieldForId(int fieldId) {
2850                        return _Fields.findByThriftId(fieldId);
2851                }
2852
2853                @Override
2854                public void read(org.apache.thrift7.protocol.TProtocol iprot) throws org.apache.thrift7.TException {
2855                        org.apache.thrift7.protocol.TField field;
2856                        iprot.readStructBegin();
2857                        while (true)
2858                        {
2859                                field = iprot.readFieldBegin();
2860                                if (field.type == org.apache.thrift7.protocol.TType.STOP) {
2861                                        break;
2862                                }
2863                                switch (field.id) {
2864                                case 0: // SUCCESS
2865                                        if (field.type == org.apache.thrift7.protocol.TType.LIST) {
2866                                                {
2867                                                        final org.apache.thrift7.protocol.TList _list4 = iprot.readListBegin();
2868                                                        this.success = new ArrayList<Item>(_list4.size);
2869                                                        for (int _i5 = 0; _i5 < _list4.size; ++_i5)
2870                                                        {
2871                                                                Item _elem6; // required
2872                                                                _elem6 = new Item();
2873                                                                _elem6.read(iprot);
2874                                                                this.success.add(_elem6);
2875                                                        }
2876                                                        iprot.readListEnd();
2877                                                }
2878                                        } else {
2879                                                org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
2880                                        }
2881                                        break;
2882                                default:
2883                                        org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
2884                                }
2885                                iprot.readFieldEnd();
2886                        }
2887                        iprot.readStructEnd();
2888                        validate();
2889                }
2890
2891                @Override
2892                public void write(org.apache.thrift7.protocol.TProtocol oprot) throws org.apache.thrift7.TException {
2893                        oprot.writeStructBegin(STRUCT_DESC);
2894
2895                        if (this.is_set_success()) {
2896                                oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
2897                                {
2898                                        oprot.writeListBegin(new org.apache.thrift7.protocol.TList(org.apache.thrift7.protocol.TType.STRUCT,
2899                                                        this.success.size()));
2900                                        for (final Item _iter7 : this.success)
2901                                        {
2902                                                _iter7.write(oprot);
2903                                        }
2904                                        oprot.writeListEnd();
2905                                }
2906                                oprot.writeFieldEnd();
2907                        }
2908                        oprot.writeFieldStop();
2909                        oprot.writeStructEnd();
2910                }
2911
2912                @Override
2913                public String toString() {
2914                        final StringBuilder sb = new StringBuilder("get_result(");
2915                        boolean first = true;
2916
2917                        sb.append("success:");
2918                        if (this.success == null) {
2919                                sb.append("null");
2920                        } else {
2921                                sb.append(this.success);
2922                        }
2923                        first = false;
2924                        sb.append(")");
2925                        return sb.toString();
2926                }
2927
2928                public void validate() throws org.apache.thrift7.TException {
2929                        // check for required fields
2930                }
2931
2932                private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
2933                        try {
2934                                write(new org.apache.thrift7.protocol.TCompactProtocol(
2935                                                new org.apache.thrift7.transport.TIOStreamTransport(out)));
2936                        } catch (final org.apache.thrift7.TException te) {
2937                                throw new java.io.IOException(te);
2938                        }
2939                }
2940
2941                private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
2942                        try {
2943                                read(new org.apache.thrift7.protocol.TCompactProtocol(
2944                                                new org.apache.thrift7.transport.TIOStreamTransport(in)));
2945                        } catch (final org.apache.thrift7.TException te) {
2946                                throw new java.io.IOException(te);
2947                        }
2948                }
2949
2950        }
2951
2952        public static class confirm_args
2953                        implements
2954                                org.apache.thrift7.TBase<confirm_args, confirm_args._Fields>,
2955                                java.io.Serializable,
2956                                Cloneable
2957        {
2958                private static final org.apache.thrift7.protocol.TStruct STRUCT_DESC = new org.apache.thrift7.protocol.TStruct(
2959                                "confirm_args");
2960
2961                private static final org.apache.thrift7.protocol.TField QUEUE_NAME_FIELD_DESC = new org.apache.thrift7.protocol.TField(
2962                                "queue_name", org.apache.thrift7.protocol.TType.STRING, (short) 1);
2963                private static final org.apache.thrift7.protocol.TField IDS_FIELD_DESC = new org.apache.thrift7.protocol.TField(
2964                                "ids", org.apache.thrift7.protocol.TType.SET, (short) 2);
2965
2966                private String queue_name; // required
2967                private Set<Long> ids; // required
2968
2969                /**
2970                 * The set of fields this struct contains, along with convenience
2971                 * methods for finding and manipulating them.
2972                 */
2973                public enum _Fields implements org.apache.thrift7.TFieldIdEnum {
2974                        QUEUE_NAME((short) 1, "queue_name"),
2975                        IDS((short) 2, "ids");
2976
2977                        private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
2978
2979                        static {
2980                                for (final _Fields field : EnumSet.allOf(_Fields.class)) {
2981                                        byName.put(field.getFieldName(), field);
2982                                }
2983                        }
2984
2985                        /**
2986                         * Find the _Fields constant that matches fieldId, or null if its
2987                         * not found.
2988                         */
2989                        public static _Fields findByThriftId(int fieldId) {
2990                                switch (fieldId) {
2991                                case 1: // QUEUE_NAME
2992                                        return QUEUE_NAME;
2993                                case 2: // IDS
2994                                        return IDS;
2995                                default:
2996                                        return null;
2997                                }
2998                        }
2999
3000                        /**
3001                         * Find the _Fields constant that matches fieldId, throwing an
3002                         * exception if it is not found.
3003                         */
3004                        public static _Fields findByThriftIdOrThrow(int fieldId) {
3005                                final _Fields fields = findByThriftId(fieldId);
3006                                if (fields == null)
3007                                        throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
3008                                return fields;
3009                        }
3010
3011                        /**
3012                         * Find the _Fields constant that matches name, or null if its not
3013                         * found.
3014                         */
3015                        public static _Fields findByName(String name) {
3016                                return byName.get(name);
3017                        }
3018
3019                        private final short _thriftId;
3020                        private final String _fieldName;
3021
3022                        _Fields(short thriftId, String fieldName) {
3023                                _thriftId = thriftId;
3024                                _fieldName = fieldName;
3025                        }
3026
3027                        @Override
3028                        public short getThriftFieldId() {
3029                                return _thriftId;
3030                        }
3031
3032                        @Override
3033                        public String getFieldName() {
3034                                return _fieldName;
3035                        }
3036                }
3037
3038                // isset id assignments
3039
3040                public static final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> metaDataMap;
3041                static {
3042                        final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift7.meta_data.FieldMetaData>(
3043                                        _Fields.class);
3044                        tmpMap.put(_Fields.QUEUE_NAME, new org.apache.thrift7.meta_data.FieldMetaData("queue_name",
3045                                        org.apache.thrift7.TFieldRequirementType.DEFAULT,
3046                                        new org.apache.thrift7.meta_data.FieldValueMetaData(org.apache.thrift7.protocol.TType.STRING)));
3047                        tmpMap.put(_Fields.IDS, new org.apache.thrift7.meta_data.FieldMetaData("ids",
3048                                        org.apache.thrift7.TFieldRequirementType.DEFAULT,
3049                                        new org.apache.thrift7.meta_data.SetMetaData(org.apache.thrift7.protocol.TType.SET,
3050                                                        new org.apache.thrift7.meta_data.FieldValueMetaData(org.apache.thrift7.protocol.TType.I64))));
3051                        metaDataMap = Collections.unmodifiableMap(tmpMap);
3052                        org.apache.thrift7.meta_data.FieldMetaData.addStructMetaDataMap(confirm_args.class, metaDataMap);
3053                }
3054
3055                public confirm_args() {
3056                }
3057
3058                public confirm_args(
3059                                String queue_name,
3060                                Set<Long> ids)
3061                {
3062                        this();
3063                        this.queue_name = queue_name;
3064                        this.ids = ids;
3065                }
3066
3067                /**
3068                 * Performs a deep copy on <i>other</i>.
3069                 */
3070                public confirm_args(confirm_args other) {
3071                        if (other.is_set_queue_name()) {
3072                                this.queue_name = other.queue_name;
3073                        }
3074                        if (other.is_set_ids()) {
3075                                final Set<Long> __this__ids = new HashSet<Long>();
3076                                for (final Long other_element : other.ids) {
3077                                        __this__ids.add(other_element);
3078                                }
3079                                this.ids = __this__ids;
3080                        }
3081                }
3082
3083                @Override
3084                public confirm_args deepCopy() {
3085                        return new confirm_args(this);
3086                }
3087
3088                @Override
3089                public void clear() {
3090                        this.queue_name = null;
3091                        this.ids = null;
3092                }
3093
3094                public String get_queue_name() {
3095                        return this.queue_name;
3096                }
3097
3098                public void set_queue_name(String queue_name) {
3099                        this.queue_name = queue_name;
3100                }
3101
3102                public void unset_queue_name() {
3103                        this.queue_name = null;
3104                }
3105
3106                /**
3107                 * Returns true if field queue_name is set (has been assigned a value)
3108                 * and false otherwise
3109                 */
3110                public boolean is_set_queue_name() {
3111                        return this.queue_name != null;
3112                }
3113
3114                public void set_queue_name_isSet(boolean value) {
3115                        if (!value) {
3116                                this.queue_name = null;
3117                        }
3118                }
3119
3120                public int get_ids_size() {
3121                        return (this.ids == null) ? 0 : this.ids.size();
3122                }
3123
3124                public java.util.Iterator<Long> get_ids_iterator() {
3125                        return (this.ids == null) ? null : this.ids.iterator();
3126                }
3127
3128                public void add_to_ids(long elem) {
3129                        if (this.ids == null) {
3130                                this.ids = new HashSet<Long>();
3131                        }
3132                        this.ids.add(elem);
3133                }
3134
3135                public Set<Long> get_ids() {
3136                        return this.ids;
3137                }
3138
3139                public void set_ids(Set<Long> ids) {
3140                        this.ids = ids;
3141                }
3142
3143                public void unset_ids() {
3144                        this.ids = null;
3145                }
3146
3147                /**
3148                 * Returns true if field ids is set (has been assigned a value) and
3149                 * false otherwise
3150                 */
3151                public boolean is_set_ids() {
3152                        return this.ids != null;
3153                }
3154
3155                public void set_ids_isSet(boolean value) {
3156                        if (!value) {
3157                                this.ids = null;
3158                        }
3159                }
3160
3161                @Override
3162                public void setFieldValue(_Fields field, Object value) {
3163                        switch (field) {
3164                        case QUEUE_NAME:
3165                                if (value == null) {
3166                                        unset_queue_name();
3167                                } else {
3168                                        set_queue_name((String) value);
3169                                }
3170                                break;
3171
3172                        case IDS:
3173                                if (value == null) {
3174                                        unset_ids();
3175                                } else {
3176                                        set_ids((Set<Long>) value);
3177                                }
3178                                break;
3179
3180                        }
3181                }
3182
3183                @Override
3184                public Object getFieldValue(_Fields field) {
3185                        switch (field) {
3186                        case QUEUE_NAME:
3187                                return get_queue_name();
3188
3189                        case IDS:
3190                                return get_ids();
3191
3192                        }
3193                        throw new IllegalStateException();
3194                }
3195
3196                /**
3197                 * Returns true if field corresponding to fieldID is set (has been
3198                 * assigned a value) and false otherwise
3199                 */
3200                @Override
3201                public boolean isSet(_Fields field) {
3202                        if (field == null) {
3203                                throw new IllegalArgumentException();
3204                        }
3205
3206                        switch (field) {
3207                        case QUEUE_NAME:
3208                                return is_set_queue_name();
3209                        case IDS:
3210                                return is_set_ids();
3211                        }
3212                        throw new IllegalStateException();
3213                }
3214
3215                @Override
3216                public boolean equals(Object that) {
3217                        if (that == null)
3218                                return false;
3219                        if (that instanceof confirm_args)
3220                                return this.equals((confirm_args) that);
3221                        return false;
3222                }
3223
3224                public boolean equals(confirm_args that) {
3225                        if (that == null)
3226                                return false;
3227
3228                        final boolean this_present_queue_name = true && this.is_set_queue_name();
3229                        final boolean that_present_queue_name = true && that.is_set_queue_name();
3230                        if (this_present_queue_name || that_present_queue_name) {
3231                                if (!(this_present_queue_name && that_present_queue_name))
3232                                        return false;
3233                                if (!this.queue_name.equals(that.queue_name))
3234                                        return false;
3235                        }
3236
3237                        final boolean this_present_ids = true && this.is_set_ids();
3238                        final boolean that_present_ids = true && that.is_set_ids();
3239                        if (this_present_ids || that_present_ids) {
3240                                if (!(this_present_ids && that_present_ids))
3241                                        return false;
3242                                if (!this.ids.equals(that.ids))
3243                                        return false;
3244                        }
3245
3246                        return true;
3247                }
3248
3249                @Override
3250                public int hashCode() {
3251                        final HashCodeBuilder builder = new HashCodeBuilder();
3252
3253                        final boolean present_queue_name = true && (is_set_queue_name());
3254                        builder.append(present_queue_name);
3255                        if (present_queue_name)
3256                                builder.append(queue_name);
3257
3258                        final boolean present_ids = true && (is_set_ids());
3259                        builder.append(present_ids);
3260                        if (present_ids)
3261                                builder.append(ids);
3262
3263                        return builder.toHashCode();
3264                }
3265
3266                @Override
3267                public int compareTo(confirm_args other) {
3268                        if (!getClass().equals(other.getClass())) {
3269                                return getClass().getName().compareTo(other.getClass().getName());
3270                        }
3271
3272                        int lastComparison = 0;
3273                        final confirm_args typedOther = other;
3274
3275                        lastComparison = Boolean.valueOf(is_set_queue_name()).compareTo(typedOther.is_set_queue_name());
3276                        if (lastComparison != 0) {
3277                                return lastComparison;
3278                        }
3279                        if (is_set_queue_name()) {
3280                                lastComparison = org.apache.thrift7.TBaseHelper.compareTo(this.queue_name, typedOther.queue_name);
3281                                if (lastComparison != 0) {
3282                                        return lastComparison;
3283                                }
3284                        }
3285                        lastComparison = Boolean.valueOf(is_set_ids()).compareTo(typedOther.is_set_ids());
3286                        if (lastComparison != 0) {
3287                                return lastComparison;
3288                        }
3289                        if (is_set_ids()) {
3290                                lastComparison = org.apache.thrift7.TBaseHelper.compareTo(this.ids, typedOther.ids);
3291                                if (lastComparison != 0) {
3292                                        return lastComparison;
3293                                }
3294                        }
3295                        return 0;
3296                }
3297
3298                @Override
3299                public _Fields fieldForId(int fieldId) {
3300                        return _Fields.findByThriftId(fieldId);
3301                }
3302
3303                @Override
3304                public void read(org.apache.thrift7.protocol.TProtocol iprot) throws org.apache.thrift7.TException {
3305                        org.apache.thrift7.protocol.TField field;
3306                        iprot.readStructBegin();
3307                        while (true)
3308                        {
3309                                field = iprot.readFieldBegin();
3310                                if (field.type == org.apache.thrift7.protocol.TType.STOP) {
3311                                        break;
3312                                }
3313                                switch (field.id) {
3314                                case 1: // QUEUE_NAME
3315                                        if (field.type == org.apache.thrift7.protocol.TType.STRING) {
3316                                                this.queue_name = iprot.readString();
3317                                        } else {
3318                                                org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
3319                                        }
3320                                        break;
3321                                case 2: // IDS
3322                                        if (field.type == org.apache.thrift7.protocol.TType.SET) {
3323                                                {
3324                                                        final org.apache.thrift7.protocol.TSet _set8 = iprot.readSetBegin();
3325                                                        this.ids = new HashSet<Long>(2 * _set8.size);
3326                                                        for (int _i9 = 0; _i9 < _set8.size; ++_i9)
3327                                                        {
3328                                                                long _elem10; // required
3329                                                                _elem10 = iprot.readI64();
3330                                                                this.ids.add(_elem10);
3331                                                        }
3332                                                        iprot.readSetEnd();
3333                                                }
3334                                        } else {
3335                                                org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
3336                                        }
3337                                        break;
3338                                default:
3339                                        org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
3340                                }
3341                                iprot.readFieldEnd();
3342                        }
3343                        iprot.readStructEnd();
3344                        validate();
3345                }
3346
3347                @Override
3348                public void write(org.apache.thrift7.protocol.TProtocol oprot) throws org.apache.thrift7.TException {
3349                        validate();
3350
3351                        oprot.writeStructBegin(STRUCT_DESC);
3352                        if (this.queue_name != null) {
3353                                oprot.writeFieldBegin(QUEUE_NAME_FIELD_DESC);
3354                                oprot.writeString(this.queue_name);
3355                                oprot.writeFieldEnd();
3356                        }
3357                        if (this.ids != null) {
3358                                oprot.writeFieldBegin(IDS_FIELD_DESC);
3359                                {
3360                                        oprot.writeSetBegin(new org.apache.thrift7.protocol.TSet(org.apache.thrift7.protocol.TType.I64,
3361                                                        this.ids.size()));
3362                                        for (final long _iter11 : this.ids)
3363                                        {
3364                                                oprot.writeI64(_iter11);
3365                                        }
3366                                        oprot.writeSetEnd();
3367                                }
3368                                oprot.writeFieldEnd();
3369                        }
3370                        oprot.writeFieldStop();
3371                        oprot.writeStructEnd();
3372                }
3373
3374                @Override
3375                public String toString() {
3376                        final StringBuilder sb = new StringBuilder("confirm_args(");
3377                        boolean first = true;
3378
3379                        sb.append("queue_name:");
3380                        if (this.queue_name == null) {
3381                                sb.append("null");
3382                        } else {
3383                                sb.append(this.queue_name);
3384                        }
3385                        first = false;
3386                        if (!first)
3387                                sb.append(", ");
3388                        sb.append("ids:");
3389                        if (this.ids == null) {
3390                                sb.append("null");
3391                        } else {
3392                                sb.append(this.ids);
3393                        }
3394                        first = false;
3395                        sb.append(")");
3396                        return sb.toString();
3397                }
3398
3399                public void validate() throws org.apache.thrift7.TException {
3400                        // check for required fields
3401                }
3402
3403                private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
3404                        try {
3405                                write(new org.apache.thrift7.protocol.TCompactProtocol(
3406                                                new org.apache.thrift7.transport.TIOStreamTransport(out)));
3407                        } catch (final org.apache.thrift7.TException te) {
3408                                throw new java.io.IOException(te);
3409                        }
3410                }
3411
3412                private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
3413                        try {
3414                                read(new org.apache.thrift7.protocol.TCompactProtocol(
3415                                                new org.apache.thrift7.transport.TIOStreamTransport(in)));
3416                        } catch (final org.apache.thrift7.TException te) {
3417                                throw new java.io.IOException(te);
3418                        }
3419                }
3420
3421        }
3422
3423        public static class confirm_result
3424                        implements
3425                                org.apache.thrift7.TBase<confirm_result, confirm_result._Fields>,
3426                                java.io.Serializable,
3427                                Cloneable
3428        {
3429                private static final org.apache.thrift7.protocol.TStruct STRUCT_DESC = new org.apache.thrift7.protocol.TStruct(
3430                                "confirm_result");
3431
3432                private static final org.apache.thrift7.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift7.protocol.TField(
3433                                "success", org.apache.thrift7.protocol.TType.I32, (short) 0);
3434
3435                private int success; // required
3436
3437                /**
3438                 * The set of fields this struct contains, along with convenience
3439                 * methods for finding and manipulating them.
3440                 */
3441                public enum _Fields implements org.apache.thrift7.TFieldIdEnum {
3442                        SUCCESS((short) 0, "success");
3443
3444                        private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
3445
3446                        static {
3447                                for (final _Fields field : EnumSet.allOf(_Fields.class)) {
3448                                        byName.put(field.getFieldName(), field);
3449                                }
3450                        }
3451
3452                        /**
3453                         * Find the _Fields constant that matches fieldId, or null if its
3454                         * not found.
3455                         */
3456                        public static _Fields findByThriftId(int fieldId) {
3457                                switch (fieldId) {
3458                                case 0: // SUCCESS
3459                                        return SUCCESS;
3460                                default:
3461                                        return null;
3462                                }
3463                        }
3464
3465                        /**
3466                         * Find the _Fields constant that matches fieldId, throwing an
3467                         * exception if it is not found.
3468                         */
3469                        public static _Fields findByThriftIdOrThrow(int fieldId) {
3470                                final _Fields fields = findByThriftId(fieldId);
3471                                if (fields == null)
3472                                        throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
3473                                return fields;
3474                        }
3475
3476                        /**
3477                         * Find the _Fields constant that matches name, or null if its not
3478                         * found.
3479                         */
3480                        public static _Fields findByName(String name) {
3481                                return byName.get(name);
3482                        }
3483
3484                        private final short _thriftId;
3485                        private final String _fieldName;
3486
3487                        _Fields(short thriftId, String fieldName) {
3488                                _thriftId = thriftId;
3489                                _fieldName = fieldName;
3490                        }
3491
3492                        @Override
3493                        public short getThriftFieldId() {
3494                                return _thriftId;
3495                        }
3496
3497                        @Override
3498                        public String getFieldName() {
3499                                return _fieldName;
3500                        }
3501                }
3502
3503                // isset id assignments
3504                private static final int __SUCCESS_ISSET_ID = 0;
3505                private BitSet __isset_bit_vector = new BitSet(1);
3506
3507                public static final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> metaDataMap;
3508                static {
3509                        final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift7.meta_data.FieldMetaData>(
3510                                        _Fields.class);
3511                        tmpMap.put(_Fields.SUCCESS, new org.apache.thrift7.meta_data.FieldMetaData("success",
3512                                        org.apache.thrift7.TFieldRequirementType.DEFAULT,
3513                                        new org.apache.thrift7.meta_data.FieldValueMetaData(org.apache.thrift7.protocol.TType.I32)));
3514                        metaDataMap = Collections.unmodifiableMap(tmpMap);
3515                        org.apache.thrift7.meta_data.FieldMetaData.addStructMetaDataMap(confirm_result.class, metaDataMap);
3516                }
3517
3518                public confirm_result() {
3519                }
3520
3521                public confirm_result(
3522                                int success)
3523                {
3524                        this();
3525                        this.success = success;
3526                        set_success_isSet(true);
3527                }
3528
3529                /**
3530                 * Performs a deep copy on <i>other</i>.
3531                 */
3532                public confirm_result(confirm_result other) {
3533                        __isset_bit_vector.clear();
3534                        __isset_bit_vector.or(other.__isset_bit_vector);
3535                        this.success = other.success;
3536                }
3537
3538                @Override
3539                public confirm_result deepCopy() {
3540                        return new confirm_result(this);
3541                }
3542
3543                @Override
3544                public void clear() {
3545                        set_success_isSet(false);
3546                        this.success = 0;
3547                }
3548
3549                public int get_success() {
3550                        return this.success;
3551                }
3552
3553                public void set_success(int success) {
3554                        this.success = success;
3555                        set_success_isSet(true);
3556                }
3557
3558                public void unset_success() {
3559                        __isset_bit_vector.clear(__SUCCESS_ISSET_ID);
3560                }
3561
3562                /**
3563                 * Returns true if field success is set (has been assigned a value) and
3564                 * false otherwise
3565                 */
3566                public boolean is_set_success() {
3567                        return __isset_bit_vector.get(__SUCCESS_ISSET_ID);
3568                }
3569
3570                public void set_success_isSet(boolean value) {
3571                        __isset_bit_vector.set(__SUCCESS_ISSET_ID, value);
3572                }
3573
3574                @Override
3575                public void setFieldValue(_Fields field, Object value) {
3576                        switch (field) {
3577                        case SUCCESS:
3578                                if (value == null) {
3579                                        unset_success();
3580                                } else {
3581                                        set_success((Integer) value);
3582                                }
3583                                break;
3584
3585                        }
3586                }
3587
3588                @Override
3589                public Object getFieldValue(_Fields field) {
3590                        switch (field) {
3591                        case SUCCESS:
3592                                return Integer.valueOf(get_success());
3593
3594                        }
3595                        throw new IllegalStateException();
3596                }
3597
3598                /**
3599                 * Returns true if field corresponding to fieldID is set (has been
3600                 * assigned a value) and false otherwise
3601                 */
3602                @Override
3603                public boolean isSet(_Fields field) {
3604                        if (field == null) {
3605                                throw new IllegalArgumentException();
3606                        }
3607
3608                        switch (field) {
3609                        case SUCCESS:
3610                                return is_set_success();
3611                        }
3612                        throw new IllegalStateException();
3613                }
3614
3615                @Override
3616                public boolean equals(Object that) {
3617                        if (that == null)
3618                                return false;
3619                        if (that instanceof confirm_result)
3620                                return this.equals((confirm_result) that);
3621                        return false;
3622                }
3623
3624                public boolean equals(confirm_result that) {
3625                        if (that == null)
3626                                return false;
3627
3628                        final boolean this_present_success = true;
3629                        final boolean that_present_success = true;
3630                        if (this_present_success || that_present_success) {
3631                                if (!(this_present_success && that_present_success))
3632                                        return false;
3633                                if (this.success != that.success)
3634                                        return false;
3635                        }
3636
3637                        return true;
3638                }
3639
3640                @Override
3641                public int hashCode() {
3642                        final HashCodeBuilder builder = new HashCodeBuilder();
3643
3644                        final boolean present_success = true;
3645                        builder.append(present_success);
3646                        if (present_success)
3647                                builder.append(success);
3648
3649                        return builder.toHashCode();
3650                }
3651
3652                @Override
3653                public int compareTo(confirm_result other) {
3654                        if (!getClass().equals(other.getClass())) {
3655                                return getClass().getName().compareTo(other.getClass().getName());
3656                        }
3657
3658                        int lastComparison = 0;
3659                        final confirm_result typedOther = other;
3660
3661                        lastComparison = Boolean.valueOf(is_set_success()).compareTo(typedOther.is_set_success());
3662                        if (lastComparison != 0) {
3663                                return lastComparison;
3664                        }
3665                        if (is_set_success()) {
3666                                lastComparison = org.apache.thrift7.TBaseHelper.compareTo(this.success, typedOther.success);
3667                                if (lastComparison != 0) {
3668                                        return lastComparison;
3669                                }
3670                        }
3671                        return 0;
3672                }
3673
3674                @Override
3675                public _Fields fieldForId(int fieldId) {
3676                        return _Fields.findByThriftId(fieldId);
3677                }
3678
3679                @Override
3680                public void read(org.apache.thrift7.protocol.TProtocol iprot) throws org.apache.thrift7.TException {
3681                        org.apache.thrift7.protocol.TField field;
3682                        iprot.readStructBegin();
3683                        while (true)
3684                        {
3685                                field = iprot.readFieldBegin();
3686                                if (field.type == org.apache.thrift7.protocol.TType.STOP) {
3687                                        break;
3688                                }
3689                                switch (field.id) {
3690                                case 0: // SUCCESS
3691                                        if (field.type == org.apache.thrift7.protocol.TType.I32) {
3692                                                this.success = iprot.readI32();
3693                                                set_success_isSet(true);
3694                                        } else {
3695                                                org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
3696                                        }
3697                                        break;
3698                                default:
3699                                        org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
3700                                }
3701                                iprot.readFieldEnd();
3702                        }
3703                        iprot.readStructEnd();
3704                        validate();
3705                }
3706
3707                @Override
3708                public void write(org.apache.thrift7.protocol.TProtocol oprot) throws org.apache.thrift7.TException {
3709                        oprot.writeStructBegin(STRUCT_DESC);
3710
3711                        if (this.is_set_success()) {
3712                                oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
3713                                oprot.writeI32(this.success);
3714                                oprot.writeFieldEnd();
3715                        }
3716                        oprot.writeFieldStop();
3717                        oprot.writeStructEnd();
3718                }
3719
3720                @Override
3721                public String toString() {
3722                        final StringBuilder sb = new StringBuilder("confirm_result(");
3723                        boolean first = true;
3724
3725                        sb.append("success:");
3726                        sb.append(this.success);
3727                        first = false;
3728                        sb.append(")");
3729                        return sb.toString();
3730                }
3731
3732                public void validate() throws org.apache.thrift7.TException {
3733                        // check for required fields
3734                }
3735
3736                private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
3737                        try {
3738                                write(new org.apache.thrift7.protocol.TCompactProtocol(
3739                                                new org.apache.thrift7.transport.TIOStreamTransport(out)));
3740                        } catch (final org.apache.thrift7.TException te) {
3741                                throw new java.io.IOException(te);
3742                        }
3743                }
3744
3745                private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
3746                        try {
3747                                read(new org.apache.thrift7.protocol.TCompactProtocol(
3748                                                new org.apache.thrift7.transport.TIOStreamTransport(in)));
3749                        } catch (final org.apache.thrift7.TException te) {
3750                                throw new java.io.IOException(te);
3751                        }
3752                }
3753
3754        }
3755
3756        public static class abort_args
3757                        implements
3758                                org.apache.thrift7.TBase<abort_args, abort_args._Fields>,
3759                                java.io.Serializable,
3760                                Cloneable
3761        {
3762                private static final org.apache.thrift7.protocol.TStruct STRUCT_DESC = new org.apache.thrift7.protocol.TStruct(
3763                                "abort_args");
3764
3765                private static final org.apache.thrift7.protocol.TField QUEUE_NAME_FIELD_DESC = new org.apache.thrift7.protocol.TField(
3766                                "queue_name", org.apache.thrift7.protocol.TType.STRING, (short) 1);
3767                private static final org.apache.thrift7.protocol.TField IDS_FIELD_DESC = new org.apache.thrift7.protocol.TField(
3768                                "ids", org.apache.thrift7.protocol.TType.SET, (short) 2);
3769
3770                private String queue_name; // required
3771                private Set<Long> ids; // required
3772
3773                /**
3774                 * The set of fields this struct contains, along with convenience
3775                 * methods for finding and manipulating them.
3776                 */
3777                public enum _Fields implements org.apache.thrift7.TFieldIdEnum {
3778                        QUEUE_NAME((short) 1, "queue_name"),
3779                        IDS((short) 2, "ids");
3780
3781                        private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
3782
3783                        static {
3784                                for (final _Fields field : EnumSet.allOf(_Fields.class)) {
3785                                        byName.put(field.getFieldName(), field);
3786                                }
3787                        }
3788
3789                        /**
3790                         * Find the _Fields constant that matches fieldId, or null if its
3791                         * not found.
3792                         */
3793                        public static _Fields findByThriftId(int fieldId) {
3794                                switch (fieldId) {
3795                                case 1: // QUEUE_NAME
3796                                        return QUEUE_NAME;
3797                                case 2: // IDS
3798                                        return IDS;
3799                                default:
3800                                        return null;
3801                                }
3802                        }
3803
3804                        /**
3805                         * Find the _Fields constant that matches fieldId, throwing an
3806                         * exception if it is not found.
3807                         */
3808                        public static _Fields findByThriftIdOrThrow(int fieldId) {
3809                                final _Fields fields = findByThriftId(fieldId);
3810                                if (fields == null)
3811                                        throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
3812                                return fields;
3813                        }
3814
3815                        /**
3816                         * Find the _Fields constant that matches name, or null if its not
3817                         * found.
3818                         */
3819                        public static _Fields findByName(String name) {
3820                                return byName.get(name);
3821                        }
3822
3823                        private final short _thriftId;
3824                        private final String _fieldName;
3825
3826                        _Fields(short thriftId, String fieldName) {
3827                                _thriftId = thriftId;
3828                                _fieldName = fieldName;
3829                        }
3830
3831                        @Override
3832                        public short getThriftFieldId() {
3833                                return _thriftId;
3834                        }
3835
3836                        @Override
3837                        public String getFieldName() {
3838                                return _fieldName;
3839                        }
3840                }
3841
3842                // isset id assignments
3843
3844                public static final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> metaDataMap;
3845                static {
3846                        final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift7.meta_data.FieldMetaData>(
3847                                        _Fields.class);
3848                        tmpMap.put(_Fields.QUEUE_NAME, new org.apache.thrift7.meta_data.FieldMetaData("queue_name",
3849                                        org.apache.thrift7.TFieldRequirementType.DEFAULT,
3850                                        new org.apache.thrift7.meta_data.FieldValueMetaData(org.apache.thrift7.protocol.TType.STRING)));
3851                        tmpMap.put(_Fields.IDS, new org.apache.thrift7.meta_data.FieldMetaData("ids",
3852                                        org.apache.thrift7.TFieldRequirementType.DEFAULT,
3853                                        new org.apache.thrift7.meta_data.SetMetaData(org.apache.thrift7.protocol.TType.SET,
3854                                                        new org.apache.thrift7.meta_data.FieldValueMetaData(org.apache.thrift7.protocol.TType.I64))));
3855                        metaDataMap = Collections.unmodifiableMap(tmpMap);
3856                        org.apache.thrift7.meta_data.FieldMetaData.addStructMetaDataMap(abort_args.class, metaDataMap);
3857                }
3858
3859                public abort_args() {
3860                }
3861
3862                public abort_args(
3863                                String queue_name,
3864                                Set<Long> ids)
3865                {
3866                        this();
3867                        this.queue_name = queue_name;
3868                        this.ids = ids;
3869                }
3870
3871                /**
3872                 * Performs a deep copy on <i>other</i>.
3873                 */
3874                public abort_args(abort_args other) {
3875                        if (other.is_set_queue_name()) {
3876                                this.queue_name = other.queue_name;
3877                        }
3878                        if (other.is_set_ids()) {
3879                                final Set<Long> __this__ids = new HashSet<Long>();
3880                                for (final Long other_element : other.ids) {
3881                                        __this__ids.add(other_element);
3882                                }
3883                                this.ids = __this__ids;
3884                        }
3885                }
3886
3887                @Override
3888                public abort_args deepCopy() {
3889                        return new abort_args(this);
3890                }
3891
3892                @Override
3893                public void clear() {
3894                        this.queue_name = null;
3895                        this.ids = null;
3896                }
3897
3898                public String get_queue_name() {
3899                        return this.queue_name;
3900                }
3901
3902                public void set_queue_name(String queue_name) {
3903                        this.queue_name = queue_name;
3904                }
3905
3906                public void unset_queue_name() {
3907                        this.queue_name = null;
3908                }
3909
3910                /**
3911                 * Returns true if field queue_name is set (has been assigned a value)
3912                 * and false otherwise
3913                 */
3914                public boolean is_set_queue_name() {
3915                        return this.queue_name != null;
3916                }
3917
3918                public void set_queue_name_isSet(boolean value) {
3919                        if (!value) {
3920                                this.queue_name = null;
3921                        }
3922                }
3923
3924                public int get_ids_size() {
3925                        return (this.ids == null) ? 0 : this.ids.size();
3926                }
3927
3928                public java.util.Iterator<Long> get_ids_iterator() {
3929                        return (this.ids == null) ? null : this.ids.iterator();
3930                }
3931
3932                public void add_to_ids(long elem) {
3933                        if (this.ids == null) {
3934                                this.ids = new HashSet<Long>();
3935                        }
3936                        this.ids.add(elem);
3937                }
3938
3939                public Set<Long> get_ids() {
3940                        return this.ids;
3941                }
3942
3943                public void set_ids(Set<Long> ids) {
3944                        this.ids = ids;
3945                }
3946
3947                public void unset_ids() {
3948                        this.ids = null;
3949                }
3950
3951                /**
3952                 * Returns true if field ids is set (has been assigned a value) and
3953                 * false otherwise
3954                 */
3955                public boolean is_set_ids() {
3956                        return this.ids != null;
3957                }
3958
3959                public void set_ids_isSet(boolean value) {
3960                        if (!value) {
3961                                this.ids = null;
3962                        }
3963                }
3964
3965                @Override
3966                public void setFieldValue(_Fields field, Object value) {
3967                        switch (field) {
3968                        case QUEUE_NAME:
3969                                if (value == null) {
3970                                        unset_queue_name();
3971                                } else {
3972                                        set_queue_name((String) value);
3973                                }
3974                                break;
3975
3976                        case IDS:
3977                                if (value == null) {
3978                                        unset_ids();
3979                                } else {
3980                                        set_ids((Set<Long>) value);
3981                                }
3982                                break;
3983
3984                        }
3985                }
3986
3987                @Override
3988                public Object getFieldValue(_Fields field) {
3989                        switch (field) {
3990                        case QUEUE_NAME:
3991                                return get_queue_name();
3992
3993                        case IDS:
3994                                return get_ids();
3995
3996                        }
3997                        throw new IllegalStateException();
3998                }
3999
4000                /**
4001                 * Returns true if field corresponding to fieldID is set (has been
4002                 * assigned a value) and false otherwise
4003                 */
4004                @Override
4005                public boolean isSet(_Fields field) {
4006                        if (field == null) {
4007                                throw new IllegalArgumentException();
4008                        }
4009
4010                        switch (field) {
4011                        case QUEUE_NAME:
4012                                return is_set_queue_name();
4013                        case IDS:
4014                                return is_set_ids();
4015                        }
4016                        throw new IllegalStateException();
4017                }
4018
4019                @Override
4020                public boolean equals(Object that) {
4021                        if (that == null)
4022                                return false;
4023                        if (that instanceof abort_args)
4024                                return this.equals((abort_args) that);
4025                        return false;
4026                }
4027
4028                public boolean equals(abort_args that) {
4029                        if (that == null)
4030                                return false;
4031
4032                        final boolean this_present_queue_name = true && this.is_set_queue_name();
4033                        final boolean that_present_queue_name = true && that.is_set_queue_name();
4034                        if (this_present_queue_name || that_present_queue_name) {
4035                                if (!(this_present_queue_name && that_present_queue_name))
4036                                        return false;
4037                                if (!this.queue_name.equals(that.queue_name))
4038                                        return false;
4039                        }
4040
4041                        final boolean this_present_ids = true && this.is_set_ids();
4042                        final boolean that_present_ids = true && that.is_set_ids();
4043                        if (this_present_ids || that_present_ids) {
4044                                if (!(this_present_ids && that_present_ids))
4045                                        return false;
4046                                if (!this.ids.equals(that.ids))
4047                                        return false;
4048                        }
4049
4050                        return true;
4051                }
4052
4053                @Override
4054                public int hashCode() {
4055                        final HashCodeBuilder builder = new HashCodeBuilder();
4056
4057                        final boolean present_queue_name = true && (is_set_queue_name());
4058                        builder.append(present_queue_name);
4059                        if (present_queue_name)
4060                                builder.append(queue_name);
4061
4062                        final boolean present_ids = true && (is_set_ids());
4063                        builder.append(present_ids);
4064                        if (present_ids)
4065                                builder.append(ids);
4066
4067                        return builder.toHashCode();
4068                }
4069
4070                @Override
4071                public int compareTo(abort_args other) {
4072                        if (!getClass().equals(other.getClass())) {
4073                                return getClass().getName().compareTo(other.getClass().getName());
4074                        }
4075
4076                        int lastComparison = 0;
4077                        final abort_args typedOther = other;
4078
4079                        lastComparison = Boolean.valueOf(is_set_queue_name()).compareTo(typedOther.is_set_queue_name());
4080                        if (lastComparison != 0) {
4081                                return lastComparison;
4082                        }
4083                        if (is_set_queue_name()) {
4084                                lastComparison = org.apache.thrift7.TBaseHelper.compareTo(this.queue_name, typedOther.queue_name);
4085                                if (lastComparison != 0) {
4086                                        return lastComparison;
4087                                }
4088                        }
4089                        lastComparison = Boolean.valueOf(is_set_ids()).compareTo(typedOther.is_set_ids());
4090                        if (lastComparison != 0) {
4091                                return lastComparison;
4092                        }
4093                        if (is_set_ids()) {
4094                                lastComparison = org.apache.thrift7.TBaseHelper.compareTo(this.ids, typedOther.ids);
4095                                if (lastComparison != 0) {
4096                                        return lastComparison;
4097                                }
4098                        }
4099                        return 0;
4100                }
4101
4102                @Override
4103                public _Fields fieldForId(int fieldId) {
4104                        return _Fields.findByThriftId(fieldId);
4105                }
4106
4107                @Override
4108                public void read(org.apache.thrift7.protocol.TProtocol iprot) throws org.apache.thrift7.TException {
4109                        org.apache.thrift7.protocol.TField field;
4110                        iprot.readStructBegin();
4111                        while (true)
4112                        {
4113                                field = iprot.readFieldBegin();
4114                                if (field.type == org.apache.thrift7.protocol.TType.STOP) {
4115                                        break;
4116                                }
4117                                switch (field.id) {
4118                                case 1: // QUEUE_NAME
4119                                        if (field.type == org.apache.thrift7.protocol.TType.STRING) {
4120                                                this.queue_name = iprot.readString();
4121                                        } else {
4122                                                org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
4123                                        }
4124                                        break;
4125                                case 2: // IDS
4126                                        if (field.type == org.apache.thrift7.protocol.TType.SET) {
4127                                                {
4128                                                        final org.apache.thrift7.protocol.TSet _set12 = iprot.readSetBegin();
4129                                                        this.ids = new HashSet<Long>(2 * _set12.size);
4130                                                        for (int _i13 = 0; _i13 < _set12.size; ++_i13)
4131                                                        {
4132                                                                long _elem14; // required
4133                                                                _elem14 = iprot.readI64();
4134                                                                this.ids.add(_elem14);
4135                                                        }
4136                                                        iprot.readSetEnd();
4137                                                }
4138                                        } else {
4139                                                org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
4140                                        }
4141                                        break;
4142                                default:
4143                                        org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
4144                                }
4145                                iprot.readFieldEnd();
4146                        }
4147                        iprot.readStructEnd();
4148                        validate();
4149                }
4150
4151                @Override
4152                public void write(org.apache.thrift7.protocol.TProtocol oprot) throws org.apache.thrift7.TException {
4153                        validate();
4154
4155                        oprot.writeStructBegin(STRUCT_DESC);
4156                        if (this.queue_name != null) {
4157                                oprot.writeFieldBegin(QUEUE_NAME_FIELD_DESC);
4158                                oprot.writeString(this.queue_name);
4159                                oprot.writeFieldEnd();
4160                        }
4161                        if (this.ids != null) {
4162                                oprot.writeFieldBegin(IDS_FIELD_DESC);
4163                                {
4164                                        oprot.writeSetBegin(new org.apache.thrift7.protocol.TSet(org.apache.thrift7.protocol.TType.I64,
4165                                                        this.ids.size()));
4166                                        for (final long _iter15 : this.ids)
4167                                        {
4168                                                oprot.writeI64(_iter15);
4169                                        }
4170                                        oprot.writeSetEnd();
4171                                }
4172                                oprot.writeFieldEnd();
4173                        }
4174                        oprot.writeFieldStop();
4175                        oprot.writeStructEnd();
4176                }
4177
4178                @Override
4179                public String toString() {
4180                        final StringBuilder sb = new StringBuilder("abort_args(");
4181                        boolean first = true;
4182
4183                        sb.append("queue_name:");
4184                        if (this.queue_name == null) {
4185                                sb.append("null");
4186                        } else {
4187                                sb.append(this.queue_name);
4188                        }
4189                        first = false;
4190                        if (!first)
4191                                sb.append(", ");
4192                        sb.append("ids:");
4193                        if (this.ids == null) {
4194                                sb.append("null");
4195                        } else {
4196                                sb.append(this.ids);
4197                        }
4198                        first = false;
4199                        sb.append(")");
4200                        return sb.toString();
4201                }
4202
4203                public void validate() throws org.apache.thrift7.TException {
4204                        // check for required fields
4205                }
4206
4207                private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
4208                        try {
4209                                write(new org.apache.thrift7.protocol.TCompactProtocol(
4210                                                new org.apache.thrift7.transport.TIOStreamTransport(out)));
4211                        } catch (final org.apache.thrift7.TException te) {
4212                                throw new java.io.IOException(te);
4213                        }
4214                }
4215
4216                private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
4217                        try {
4218                                read(new org.apache.thrift7.protocol.TCompactProtocol(
4219                                                new org.apache.thrift7.transport.TIOStreamTransport(in)));
4220                        } catch (final org.apache.thrift7.TException te) {
4221                                throw new java.io.IOException(te);
4222                        }
4223                }
4224
4225        }
4226
4227        public static class abort_result
4228                        implements
4229                                org.apache.thrift7.TBase<abort_result, abort_result._Fields>,
4230                                java.io.Serializable,
4231                                Cloneable
4232        {
4233                private static final org.apache.thrift7.protocol.TStruct STRUCT_DESC = new org.apache.thrift7.protocol.TStruct(
4234                                "abort_result");
4235
4236                private static final org.apache.thrift7.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift7.protocol.TField(
4237                                "success", org.apache.thrift7.protocol.TType.I32, (short) 0);
4238
4239                private int success; // required
4240
4241                /**
4242                 * The set of fields this struct contains, along with convenience
4243                 * methods for finding and manipulating them.
4244                 */
4245                public enum _Fields implements org.apache.thrift7.TFieldIdEnum {
4246                        SUCCESS((short) 0, "success");
4247
4248                        private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
4249
4250                        static {
4251                                for (final _Fields field : EnumSet.allOf(_Fields.class)) {
4252                                        byName.put(field.getFieldName(), field);
4253                                }
4254                        }
4255
4256                        /**
4257                         * Find the _Fields constant that matches fieldId, or null if its
4258                         * not found.
4259                         */
4260                        public static _Fields findByThriftId(int fieldId) {
4261                                switch (fieldId) {
4262                                case 0: // SUCCESS
4263                                        return SUCCESS;
4264                                default:
4265                                        return null;
4266                                }
4267                        }
4268
4269                        /**
4270                         * Find the _Fields constant that matches fieldId, throwing an
4271                         * exception if it is not found.
4272                         */
4273                        public static _Fields findByThriftIdOrThrow(int fieldId) {
4274                                final _Fields fields = findByThriftId(fieldId);
4275                                if (fields == null)
4276                                        throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
4277                                return fields;
4278                        }
4279
4280                        /**
4281                         * Find the _Fields constant that matches name, or null if its not
4282                         * found.
4283                         */
4284                        public static _Fields findByName(String name) {
4285                                return byName.get(name);
4286                        }
4287
4288                        private final short _thriftId;
4289                        private final String _fieldName;
4290
4291                        _Fields(short thriftId, String fieldName) {
4292                                _thriftId = thriftId;
4293                                _fieldName = fieldName;
4294                        }
4295
4296                        @Override
4297                        public short getThriftFieldId() {
4298                                return _thriftId;
4299                        }
4300
4301                        @Override
4302                        public String getFieldName() {
4303                                return _fieldName;
4304                        }
4305                }
4306
4307                // isset id assignments
4308                private static final int __SUCCESS_ISSET_ID = 0;
4309                private BitSet __isset_bit_vector = new BitSet(1);
4310
4311                public static final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> metaDataMap;
4312                static {
4313                        final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift7.meta_data.FieldMetaData>(
4314                                        _Fields.class);
4315                        tmpMap.put(_Fields.SUCCESS, new org.apache.thrift7.meta_data.FieldMetaData("success",
4316                                        org.apache.thrift7.TFieldRequirementType.DEFAULT,
4317                                        new org.apache.thrift7.meta_data.FieldValueMetaData(org.apache.thrift7.protocol.TType.I32)));
4318                        metaDataMap = Collections.unmodifiableMap(tmpMap);
4319                        org.apache.thrift7.meta_data.FieldMetaData.addStructMetaDataMap(abort_result.class, metaDataMap);
4320                }
4321
4322                public abort_result() {
4323                }
4324
4325                public abort_result(
4326                                int success)
4327                {
4328                        this();
4329                        this.success = success;
4330                        set_success_isSet(true);
4331                }
4332
4333                /**
4334                 * Performs a deep copy on <i>other</i>.
4335                 */
4336                public abort_result(abort_result other) {
4337                        __isset_bit_vector.clear();
4338                        __isset_bit_vector.or(other.__isset_bit_vector);
4339                        this.success = other.success;
4340                }
4341
4342                @Override
4343                public abort_result deepCopy() {
4344                        return new abort_result(this);
4345                }
4346
4347                @Override
4348                public void clear() {
4349                        set_success_isSet(false);
4350                        this.success = 0;
4351                }
4352
4353                public int get_success() {
4354                        return this.success;
4355                }
4356
4357                public void set_success(int success) {
4358                        this.success = success;
4359                        set_success_isSet(true);
4360                }
4361
4362                public void unset_success() {
4363                        __isset_bit_vector.clear(__SUCCESS_ISSET_ID);
4364                }
4365
4366                /**
4367                 * Returns true if field success is set (has been assigned a value) and
4368                 * false otherwise
4369                 */
4370                public boolean is_set_success() {
4371                        return __isset_bit_vector.get(__SUCCESS_ISSET_ID);
4372                }
4373
4374                public void set_success_isSet(boolean value) {
4375                        __isset_bit_vector.set(__SUCCESS_ISSET_ID, value);
4376                }
4377
4378                @Override
4379                public void setFieldValue(_Fields field, Object value) {
4380                        switch (field) {
4381                        case SUCCESS:
4382                                if (value == null) {
4383                                        unset_success();
4384                                } else {
4385                                        set_success((Integer) value);
4386                                }
4387                                break;
4388
4389                        }
4390                }
4391
4392                @Override
4393                public Object getFieldValue(_Fields field) {
4394                        switch (field) {
4395                        case SUCCESS:
4396                                return Integer.valueOf(get_success());
4397
4398                        }
4399                        throw new IllegalStateException();
4400                }
4401
4402                /**
4403                 * Returns true if field corresponding to fieldID is set (has been
4404                 * assigned a value) and false otherwise
4405                 */
4406                @Override
4407                public boolean isSet(_Fields field) {
4408                        if (field == null) {
4409                                throw new IllegalArgumentException();
4410                        }
4411
4412                        switch (field) {
4413                        case SUCCESS:
4414                                return is_set_success();
4415                        }
4416                        throw new IllegalStateException();
4417                }
4418
4419                @Override
4420                public boolean equals(Object that) {
4421                        if (that == null)
4422                                return false;
4423                        if (that instanceof abort_result)
4424                                return this.equals((abort_result) that);
4425                        return false;
4426                }
4427
4428                public boolean equals(abort_result that) {
4429                        if (that == null)
4430                                return false;
4431
4432                        final boolean this_present_success = true;
4433                        final boolean that_present_success = true;
4434                        if (this_present_success || that_present_success) {
4435                                if (!(this_present_success && that_present_success))
4436                                        return false;
4437                                if (this.success != that.success)
4438                                        return false;
4439                        }
4440
4441                        return true;
4442                }
4443
4444                @Override
4445                public int hashCode() {
4446                        final HashCodeBuilder builder = new HashCodeBuilder();
4447
4448                        final boolean present_success = true;
4449                        builder.append(present_success);
4450                        if (present_success)
4451                                builder.append(success);
4452
4453                        return builder.toHashCode();
4454                }
4455
4456                @Override
4457                public int compareTo(abort_result other) {
4458                        if (!getClass().equals(other.getClass())) {
4459                                return getClass().getName().compareTo(other.getClass().getName());
4460                        }
4461
4462                        int lastComparison = 0;
4463                        final abort_result typedOther = other;
4464
4465                        lastComparison = Boolean.valueOf(is_set_success()).compareTo(typedOther.is_set_success());
4466                        if (lastComparison != 0) {
4467                                return lastComparison;
4468                        }
4469                        if (is_set_success()) {
4470                                lastComparison = org.apache.thrift7.TBaseHelper.compareTo(this.success, typedOther.success);
4471                                if (lastComparison != 0) {
4472                                        return lastComparison;
4473                                }
4474                        }
4475                        return 0;
4476                }
4477
4478                @Override
4479                public _Fields fieldForId(int fieldId) {
4480                        return _Fields.findByThriftId(fieldId);
4481                }
4482
4483                @Override
4484                public void read(org.apache.thrift7.protocol.TProtocol iprot) throws org.apache.thrift7.TException {
4485                        org.apache.thrift7.protocol.TField field;
4486                        iprot.readStructBegin();
4487                        while (true)
4488                        {
4489                                field = iprot.readFieldBegin();
4490                                if (field.type == org.apache.thrift7.protocol.TType.STOP) {
4491                                        break;
4492                                }
4493                                switch (field.id) {
4494                                case 0: // SUCCESS
4495                                        if (field.type == org.apache.thrift7.protocol.TType.I32) {
4496                                                this.success = iprot.readI32();
4497                                                set_success_isSet(true);
4498                                        } else {
4499                                                org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
4500                                        }
4501                                        break;
4502                                default:
4503                                        org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
4504                                }
4505                                iprot.readFieldEnd();
4506                        }
4507                        iprot.readStructEnd();
4508                        validate();
4509                }
4510
4511                @Override
4512                public void write(org.apache.thrift7.protocol.TProtocol oprot) throws org.apache.thrift7.TException {
4513                        oprot.writeStructBegin(STRUCT_DESC);
4514
4515                        if (this.is_set_success()) {
4516                                oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
4517                                oprot.writeI32(this.success);
4518                                oprot.writeFieldEnd();
4519                        }
4520                        oprot.writeFieldStop();
4521                        oprot.writeStructEnd();
4522                }
4523
4524                @Override
4525                public String toString() {
4526                        final StringBuilder sb = new StringBuilder("abort_result(");
4527                        boolean first = true;
4528
4529                        sb.append("success:");
4530                        sb.append(this.success);
4531                        first = false;
4532                        sb.append(")");
4533                        return sb.toString();
4534                }
4535
4536                public void validate() throws org.apache.thrift7.TException {
4537                        // check for required fields
4538                }
4539
4540                private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
4541                        try {
4542                                write(new org.apache.thrift7.protocol.TCompactProtocol(
4543                                                new org.apache.thrift7.transport.TIOStreamTransport(out)));
4544                        } catch (final org.apache.thrift7.TException te) {
4545                                throw new java.io.IOException(te);
4546                        }
4547                }
4548
4549                private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
4550                        try {
4551                                read(new org.apache.thrift7.protocol.TCompactProtocol(
4552                                                new org.apache.thrift7.transport.TIOStreamTransport(in)));
4553                        } catch (final org.apache.thrift7.TException te) {
4554                                throw new java.io.IOException(te);
4555                        }
4556                }
4557
4558        }
4559
4560        public static class peek_args
4561                        implements
4562                                org.apache.thrift7.TBase<peek_args, peek_args._Fields>,
4563                                java.io.Serializable,
4564                                Cloneable
4565        {
4566                private static final org.apache.thrift7.protocol.TStruct STRUCT_DESC = new org.apache.thrift7.protocol.TStruct(
4567                                "peek_args");
4568
4569                private static final org.apache.thrift7.protocol.TField QUEUE_NAME_FIELD_DESC = new org.apache.thrift7.protocol.TField(
4570                                "queue_name", org.apache.thrift7.protocol.TType.STRING, (short) 1);
4571
4572                private String queue_name; // required
4573
4574                /**
4575                 * The set of fields this struct contains, along with convenience
4576                 * methods for finding and manipulating them.
4577                 */
4578                public enum _Fields implements org.apache.thrift7.TFieldIdEnum {
4579                        QUEUE_NAME((short) 1, "queue_name");
4580
4581                        private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
4582
4583                        static {
4584                                for (final _Fields field : EnumSet.allOf(_Fields.class)) {
4585                                        byName.put(field.getFieldName(), field);
4586                                }
4587                        }
4588
4589                        /**
4590                         * Find the _Fields constant that matches fieldId, or null if its
4591                         * not found.
4592                         */
4593                        public static _Fields findByThriftId(int fieldId) {
4594                                switch (fieldId) {
4595                                case 1: // QUEUE_NAME
4596                                        return QUEUE_NAME;
4597                                default:
4598                                        return null;
4599                                }
4600                        }
4601
4602                        /**
4603                         * Find the _Fields constant that matches fieldId, throwing an
4604                         * exception if it is not found.
4605                         */
4606                        public static _Fields findByThriftIdOrThrow(int fieldId) {
4607                                final _Fields fields = findByThriftId(fieldId);
4608                                if (fields == null)
4609                                        throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
4610                                return fields;
4611                        }
4612
4613                        /**
4614                         * Find the _Fields constant that matches name, or null if its not
4615                         * found.
4616                         */
4617                        public static _Fields findByName(String name) {
4618                                return byName.get(name);
4619                        }
4620
4621                        private final short _thriftId;
4622                        private final String _fieldName;
4623
4624                        _Fields(short thriftId, String fieldName) {
4625                                _thriftId = thriftId;
4626                                _fieldName = fieldName;
4627                        }
4628
4629                        @Override
4630                        public short getThriftFieldId() {
4631                                return _thriftId;
4632                        }
4633
4634                        @Override
4635                        public String getFieldName() {
4636                                return _fieldName;
4637                        }
4638                }
4639
4640                // isset id assignments
4641
4642                public static final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> metaDataMap;
4643                static {
4644                        final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift7.meta_data.FieldMetaData>(
4645                                        _Fields.class);
4646                        tmpMap.put(_Fields.QUEUE_NAME, new org.apache.thrift7.meta_data.FieldMetaData("queue_name",
4647                                        org.apache.thrift7.TFieldRequirementType.DEFAULT,
4648                                        new org.apache.thrift7.meta_data.FieldValueMetaData(org.apache.thrift7.protocol.TType.STRING)));
4649                        metaDataMap = Collections.unmodifiableMap(tmpMap);
4650                        org.apache.thrift7.meta_data.FieldMetaData.addStructMetaDataMap(peek_args.class, metaDataMap);
4651                }
4652
4653                public peek_args() {
4654                }
4655
4656                public peek_args(
4657                                String queue_name)
4658                {
4659                        this();
4660                        this.queue_name = queue_name;
4661                }
4662
4663                /**
4664                 * Performs a deep copy on <i>other</i>.
4665                 */
4666                public peek_args(peek_args other) {
4667                        if (other.is_set_queue_name()) {
4668                                this.queue_name = other.queue_name;
4669                        }
4670                }
4671
4672                @Override
4673                public peek_args deepCopy() {
4674                        return new peek_args(this);
4675                }
4676
4677                @Override
4678                public void clear() {
4679                        this.queue_name = null;
4680                }
4681
4682                public String get_queue_name() {
4683                        return this.queue_name;
4684                }
4685
4686                public void set_queue_name(String queue_name) {
4687                        this.queue_name = queue_name;
4688                }
4689
4690                public void unset_queue_name() {
4691                        this.queue_name = null;
4692                }
4693
4694                /**
4695                 * Returns true if field queue_name is set (has been assigned a value)
4696                 * and false otherwise
4697                 */
4698                public boolean is_set_queue_name() {
4699                        return this.queue_name != null;
4700                }
4701
4702                public void set_queue_name_isSet(boolean value) {
4703                        if (!value) {
4704                                this.queue_name = null;
4705                        }
4706                }
4707
4708                @Override
4709                public void setFieldValue(_Fields field, Object value) {
4710                        switch (field) {
4711                        case QUEUE_NAME:
4712                                if (value == null) {
4713                                        unset_queue_name();
4714                                } else {
4715                                        set_queue_name((String) value);
4716                                }
4717                                break;
4718
4719                        }
4720                }
4721
4722                @Override
4723                public Object getFieldValue(_Fields field) {
4724                        switch (field) {
4725                        case QUEUE_NAME:
4726                                return get_queue_name();
4727
4728                        }
4729                        throw new IllegalStateException();
4730                }
4731
4732                /**
4733                 * Returns true if field corresponding to fieldID is set (has been
4734                 * assigned a value) and false otherwise
4735                 */
4736                @Override
4737                public boolean isSet(_Fields field) {
4738                        if (field == null) {
4739                                throw new IllegalArgumentException();
4740                        }
4741
4742                        switch (field) {
4743                        case QUEUE_NAME:
4744                                return is_set_queue_name();
4745                        }
4746                        throw new IllegalStateException();
4747                }
4748
4749                @Override
4750                public boolean equals(Object that) {
4751                        if (that == null)
4752                                return false;
4753                        if (that instanceof peek_args)
4754                                return this.equals((peek_args) that);
4755                        return false;
4756                }
4757
4758                public boolean equals(peek_args that) {
4759                        if (that == null)
4760                                return false;
4761
4762                        final boolean this_present_queue_name = true && this.is_set_queue_name();
4763                        final boolean that_present_queue_name = true && that.is_set_queue_name();
4764                        if (this_present_queue_name || that_present_queue_name) {
4765                                if (!(this_present_queue_name && that_present_queue_name))
4766                                        return false;
4767                                if (!this.queue_name.equals(that.queue_name))
4768                                        return false;
4769                        }
4770
4771                        return true;
4772                }
4773
4774                @Override
4775                public int hashCode() {
4776                        final HashCodeBuilder builder = new HashCodeBuilder();
4777
4778                        final boolean present_queue_name = true && (is_set_queue_name());
4779                        builder.append(present_queue_name);
4780                        if (present_queue_name)
4781                                builder.append(queue_name);
4782
4783                        return builder.toHashCode();
4784                }
4785
4786                @Override
4787                public int compareTo(peek_args other) {
4788                        if (!getClass().equals(other.getClass())) {
4789                                return getClass().getName().compareTo(other.getClass().getName());
4790                        }
4791
4792                        int lastComparison = 0;
4793                        final peek_args typedOther = other;
4794
4795                        lastComparison = Boolean.valueOf(is_set_queue_name()).compareTo(typedOther.is_set_queue_name());
4796                        if (lastComparison != 0) {
4797                                return lastComparison;
4798                        }
4799                        if (is_set_queue_name()) {
4800                                lastComparison = org.apache.thrift7.TBaseHelper.compareTo(this.queue_name, typedOther.queue_name);
4801                                if (lastComparison != 0) {
4802                                        return lastComparison;
4803                                }
4804                        }
4805                        return 0;
4806                }
4807
4808                @Override
4809                public _Fields fieldForId(int fieldId) {
4810                        return _Fields.findByThriftId(fieldId);
4811                }
4812
4813                @Override
4814                public void read(org.apache.thrift7.protocol.TProtocol iprot) throws org.apache.thrift7.TException {
4815                        org.apache.thrift7.protocol.TField field;
4816                        iprot.readStructBegin();
4817                        while (true)
4818                        {
4819                                field = iprot.readFieldBegin();
4820                                if (field.type == org.apache.thrift7.protocol.TType.STOP) {
4821                                        break;
4822                                }
4823                                switch (field.id) {
4824                                case 1: // QUEUE_NAME
4825                                        if (field.type == org.apache.thrift7.protocol.TType.STRING) {
4826                                                this.queue_name = iprot.readString();
4827                                        } else {
4828                                                org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
4829                                        }
4830                                        break;
4831                                default:
4832                                        org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
4833                                }
4834                                iprot.readFieldEnd();
4835                        }
4836                        iprot.readStructEnd();
4837                        validate();
4838                }
4839
4840                @Override
4841                public void write(org.apache.thrift7.protocol.TProtocol oprot) throws org.apache.thrift7.TException {
4842                        validate();
4843
4844                        oprot.writeStructBegin(STRUCT_DESC);
4845                        if (this.queue_name != null) {
4846                                oprot.writeFieldBegin(QUEUE_NAME_FIELD_DESC);
4847                                oprot.writeString(this.queue_name);
4848                                oprot.writeFieldEnd();
4849                        }
4850                        oprot.writeFieldStop();
4851                        oprot.writeStructEnd();
4852                }
4853
4854                @Override
4855                public String toString() {
4856                        final StringBuilder sb = new StringBuilder("peek_args(");
4857                        boolean first = true;
4858
4859                        sb.append("queue_name:");
4860                        if (this.queue_name == null) {
4861                                sb.append("null");
4862                        } else {
4863                                sb.append(this.queue_name);
4864                        }
4865                        first = false;
4866                        sb.append(")");
4867                        return sb.toString();
4868                }
4869
4870                public void validate() throws org.apache.thrift7.TException {
4871                        // check for required fields
4872                }
4873
4874                private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
4875                        try {
4876                                write(new org.apache.thrift7.protocol.TCompactProtocol(
4877                                                new org.apache.thrift7.transport.TIOStreamTransport(out)));
4878                        } catch (final org.apache.thrift7.TException te) {
4879                                throw new java.io.IOException(te);
4880                        }
4881                }
4882
4883                private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
4884                        try {
4885                                read(new org.apache.thrift7.protocol.TCompactProtocol(
4886                                                new org.apache.thrift7.transport.TIOStreamTransport(in)));
4887                        } catch (final org.apache.thrift7.TException te) {
4888                                throw new java.io.IOException(te);
4889                        }
4890                }
4891
4892        }
4893
4894        public static class peek_result
4895                        implements
4896                                org.apache.thrift7.TBase<peek_result, peek_result._Fields>,
4897                                java.io.Serializable,
4898                                Cloneable
4899        {
4900                private static final org.apache.thrift7.protocol.TStruct STRUCT_DESC = new org.apache.thrift7.protocol.TStruct(
4901                                "peek_result");
4902
4903                private static final org.apache.thrift7.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift7.protocol.TField(
4904                                "success", org.apache.thrift7.protocol.TType.STRUCT, (short) 0);
4905
4906                private QueueInfo success; // required
4907
4908                /**
4909                 * The set of fields this struct contains, along with convenience
4910                 * methods for finding and manipulating them.
4911                 */
4912                public enum _Fields implements org.apache.thrift7.TFieldIdEnum {
4913                        SUCCESS((short) 0, "success");
4914
4915                        private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
4916
4917                        static {
4918                                for (final _Fields field : EnumSet.allOf(_Fields.class)) {
4919                                        byName.put(field.getFieldName(), field);
4920                                }
4921                        }
4922
4923                        /**
4924                         * Find the _Fields constant that matches fieldId, or null if its
4925                         * not found.
4926                         */
4927                        public static _Fields findByThriftId(int fieldId) {
4928                                switch (fieldId) {
4929                                case 0: // SUCCESS
4930                                        return SUCCESS;
4931                                default:
4932                                        return null;
4933                                }
4934                        }
4935
4936                        /**
4937                         * Find the _Fields constant that matches fieldId, throwing an
4938                         * exception if it is not found.
4939                         */
4940                        public static _Fields findByThriftIdOrThrow(int fieldId) {
4941                                final _Fields fields = findByThriftId(fieldId);
4942                                if (fields == null)
4943                                        throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
4944                                return fields;
4945                        }
4946
4947                        /**
4948                         * Find the _Fields constant that matches name, or null if its not
4949                         * found.
4950                         */
4951                        public static _Fields findByName(String name) {
4952                                return byName.get(name);
4953                        }
4954
4955                        private final short _thriftId;
4956                        private final String _fieldName;
4957
4958                        _Fields(short thriftId, String fieldName) {
4959                                _thriftId = thriftId;
4960                                _fieldName = fieldName;
4961                        }
4962
4963                        @Override
4964                        public short getThriftFieldId() {
4965                                return _thriftId;
4966                        }
4967
4968                        @Override
4969                        public String getFieldName() {
4970                                return _fieldName;
4971                        }
4972                }
4973
4974                // isset id assignments
4975
4976                public static final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> metaDataMap;
4977                static {
4978                        final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift7.meta_data.FieldMetaData>(
4979                                        _Fields.class);
4980                        tmpMap.put(_Fields.SUCCESS, new org.apache.thrift7.meta_data.FieldMetaData("success",
4981                                        org.apache.thrift7.TFieldRequirementType.DEFAULT,
4982                                        new org.apache.thrift7.meta_data.StructMetaData(org.apache.thrift7.protocol.TType.STRUCT,
4983                                                        QueueInfo.class)));
4984                        metaDataMap = Collections.unmodifiableMap(tmpMap);
4985                        org.apache.thrift7.meta_data.FieldMetaData.addStructMetaDataMap(peek_result.class, metaDataMap);
4986                }
4987
4988                public peek_result() {
4989                }
4990
4991                public peek_result(
4992                                QueueInfo success)
4993                {
4994                        this();
4995                        this.success = success;
4996                }
4997
4998                /**
4999                 * Performs a deep copy on <i>other</i>.
5000                 */
5001                public peek_result(peek_result other) {
5002                        if (other.is_set_success()) {
5003                                this.success = new QueueInfo(other.success);
5004                        }
5005                }
5006
5007                @Override
5008                public peek_result deepCopy() {
5009                        return new peek_result(this);
5010                }
5011
5012                @Override
5013                public void clear() {
5014                        this.success = null;
5015                }
5016
5017                public QueueInfo get_success() {
5018                        return this.success;
5019                }
5020
5021                public void set_success(QueueInfo success) {
5022                        this.success = success;
5023                }
5024
5025                public void unset_success() {
5026                        this.success = null;
5027                }
5028
5029                /**
5030                 * Returns true if field success is set (has been assigned a value) and
5031                 * false otherwise
5032                 */
5033                public boolean is_set_success() {
5034                        return this.success != null;
5035                }
5036
5037                public void set_success_isSet(boolean value) {
5038                        if (!value) {
5039                                this.success = null;
5040                        }
5041                }
5042
5043                @Override
5044                public void setFieldValue(_Fields field, Object value) {
5045                        switch (field) {
5046                        case SUCCESS:
5047                                if (value == null) {
5048                                        unset_success();
5049                                } else {
5050                                        set_success((QueueInfo) value);
5051                                }
5052                                break;
5053
5054                        }
5055                }
5056
5057                @Override
5058                public Object getFieldValue(_Fields field) {
5059                        switch (field) {
5060                        case SUCCESS:
5061                                return get_success();
5062
5063                        }
5064                        throw new IllegalStateException();
5065                }
5066
5067                /**
5068                 * Returns true if field corresponding to fieldID is set (has been
5069                 * assigned a value) and false otherwise
5070                 */
5071                @Override
5072                public boolean isSet(_Fields field) {
5073                        if (field == null) {
5074                                throw new IllegalArgumentException();
5075                        }
5076
5077                        switch (field) {
5078                        case SUCCESS:
5079                                return is_set_success();
5080                        }
5081                        throw new IllegalStateException();
5082                }
5083
5084                @Override
5085                public boolean equals(Object that) {
5086                        if (that == null)
5087                                return false;
5088                        if (that instanceof peek_result)
5089                                return this.equals((peek_result) that);
5090                        return false;
5091                }
5092
5093                public boolean equals(peek_result that) {
5094                        if (that == null)
5095                                return false;
5096
5097                        final boolean this_present_success = true && this.is_set_success();
5098                        final boolean that_present_success = true && that.is_set_success();
5099                        if (this_present_success || that_present_success) {
5100                                if (!(this_present_success && that_present_success))
5101                                        return false;
5102                                if (!this.success.equals(that.success))
5103                                        return false;
5104                        }
5105
5106                        return true;
5107                }
5108
5109                @Override
5110                public int hashCode() {
5111                        final HashCodeBuilder builder = new HashCodeBuilder();
5112
5113                        final boolean present_success = true && (is_set_success());
5114                        builder.append(present_success);
5115                        if (present_success)
5116                                builder.append(success);
5117
5118                        return builder.toHashCode();
5119                }
5120
5121                @Override
5122                public int compareTo(peek_result other) {
5123                        if (!getClass().equals(other.getClass())) {
5124                                return getClass().getName().compareTo(other.getClass().getName());
5125                        }
5126
5127                        int lastComparison = 0;
5128                        final peek_result typedOther = other;
5129
5130                        lastComparison = Boolean.valueOf(is_set_success()).compareTo(typedOther.is_set_success());
5131                        if (lastComparison != 0) {
5132                                return lastComparison;
5133                        }
5134                        if (is_set_success()) {
5135                                lastComparison = org.apache.thrift7.TBaseHelper.compareTo(this.success, typedOther.success);
5136                                if (lastComparison != 0) {
5137                                        return lastComparison;
5138                                }
5139                        }
5140                        return 0;
5141                }
5142
5143                @Override
5144                public _Fields fieldForId(int fieldId) {
5145                        return _Fields.findByThriftId(fieldId);
5146                }
5147
5148                @Override
5149                public void read(org.apache.thrift7.protocol.TProtocol iprot) throws org.apache.thrift7.TException {
5150                        org.apache.thrift7.protocol.TField field;
5151                        iprot.readStructBegin();
5152                        while (true)
5153                        {
5154                                field = iprot.readFieldBegin();
5155                                if (field.type == org.apache.thrift7.protocol.TType.STOP) {
5156                                        break;
5157                                }
5158                                switch (field.id) {
5159                                case 0: // SUCCESS
5160                                        if (field.type == org.apache.thrift7.protocol.TType.STRUCT) {
5161                                                this.success = new QueueInfo();
5162                                                this.success.read(iprot);
5163                                        } else {
5164                                                org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
5165                                        }
5166                                        break;
5167                                default:
5168                                        org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
5169                                }
5170                                iprot.readFieldEnd();
5171                        }
5172                        iprot.readStructEnd();
5173                        validate();
5174                }
5175
5176                @Override
5177                public void write(org.apache.thrift7.protocol.TProtocol oprot) throws org.apache.thrift7.TException {
5178                        oprot.writeStructBegin(STRUCT_DESC);
5179
5180                        if (this.is_set_success()) {
5181                                oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
5182                                this.success.write(oprot);
5183                                oprot.writeFieldEnd();
5184                        }
5185                        oprot.writeFieldStop();
5186                        oprot.writeStructEnd();
5187                }
5188
5189                @Override
5190                public String toString() {
5191                        final StringBuilder sb = new StringBuilder("peek_result(");
5192                        boolean first = true;
5193
5194                        sb.append("success:");
5195                        if (this.success == null) {
5196                                sb.append("null");
5197                        } else {
5198                                sb.append(this.success);
5199                        }
5200                        first = false;
5201                        sb.append(")");
5202                        return sb.toString();
5203                }
5204
5205                public void validate() throws org.apache.thrift7.TException {
5206                        // check for required fields
5207                }
5208
5209                private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
5210                        try {
5211                                write(new org.apache.thrift7.protocol.TCompactProtocol(
5212                                                new org.apache.thrift7.transport.TIOStreamTransport(out)));
5213                        } catch (final org.apache.thrift7.TException te) {
5214                                throw new java.io.IOException(te);
5215                        }
5216                }
5217
5218                private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
5219                        try {
5220                                read(new org.apache.thrift7.protocol.TCompactProtocol(
5221                                                new org.apache.thrift7.transport.TIOStreamTransport(in)));
5222                        } catch (final org.apache.thrift7.TException te) {
5223                                throw new java.io.IOException(te);
5224                        }
5225                }
5226
5227        }
5228
5229        public static class flush_queue_args
5230                        implements
5231                                org.apache.thrift7.TBase<flush_queue_args, flush_queue_args._Fields>,
5232                                java.io.Serializable,
5233                                Cloneable
5234        {
5235                private static final org.apache.thrift7.protocol.TStruct STRUCT_DESC = new org.apache.thrift7.protocol.TStruct(
5236                                "flush_queue_args");
5237
5238                private static final org.apache.thrift7.protocol.TField QUEUE_NAME_FIELD_DESC = new org.apache.thrift7.protocol.TField(
5239                                "queue_name", org.apache.thrift7.protocol.TType.STRING, (short) 1);
5240
5241                private String queue_name; // required
5242
5243                /**
5244                 * The set of fields this struct contains, along with convenience
5245                 * methods for finding and manipulating them.
5246                 */
5247                public enum _Fields implements org.apache.thrift7.TFieldIdEnum {
5248                        QUEUE_NAME((short) 1, "queue_name");
5249
5250                        private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
5251
5252                        static {
5253                                for (final _Fields field : EnumSet.allOf(_Fields.class)) {
5254                                        byName.put(field.getFieldName(), field);
5255                                }
5256                        }
5257
5258                        /**
5259                         * Find the _Fields constant that matches fieldId, or null if its
5260                         * not found.
5261                         */
5262                        public static _Fields findByThriftId(int fieldId) {
5263                                switch (fieldId) {
5264                                case 1: // QUEUE_NAME
5265                                        return QUEUE_NAME;
5266                                default:
5267                                        return null;
5268                                }
5269                        }
5270
5271                        /**
5272                         * Find the _Fields constant that matches fieldId, throwing an
5273                         * exception if it is not found.
5274                         */
5275                        public static _Fields findByThriftIdOrThrow(int fieldId) {
5276                                final _Fields fields = findByThriftId(fieldId);
5277                                if (fields == null)
5278                                        throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
5279                                return fields;
5280                        }
5281
5282                        /**
5283                         * Find the _Fields constant that matches name, or null if its not
5284                         * found.
5285                         */
5286                        public static _Fields findByName(String name) {
5287                                return byName.get(name);
5288                        }
5289
5290                        private final short _thriftId;
5291                        private final String _fieldName;
5292
5293                        _Fields(short thriftId, String fieldName) {
5294                                _thriftId = thriftId;
5295                                _fieldName = fieldName;
5296                        }
5297
5298                        @Override
5299                        public short getThriftFieldId() {
5300                                return _thriftId;
5301                        }
5302
5303                        @Override
5304                        public String getFieldName() {
5305                                return _fieldName;
5306                        }
5307                }
5308
5309                // isset id assignments
5310
5311                public static final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> metaDataMap;
5312                static {
5313                        final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift7.meta_data.FieldMetaData>(
5314                                        _Fields.class);
5315                        tmpMap.put(_Fields.QUEUE_NAME, new org.apache.thrift7.meta_data.FieldMetaData("queue_name",
5316                                        org.apache.thrift7.TFieldRequirementType.DEFAULT,
5317                                        new org.apache.thrift7.meta_data.FieldValueMetaData(org.apache.thrift7.protocol.TType.STRING)));
5318                        metaDataMap = Collections.unmodifiableMap(tmpMap);
5319                        org.apache.thrift7.meta_data.FieldMetaData.addStructMetaDataMap(flush_queue_args.class, metaDataMap);
5320                }
5321
5322                public flush_queue_args() {
5323                }
5324
5325                public flush_queue_args(
5326                                String queue_name)
5327                {
5328                        this();
5329                        this.queue_name = queue_name;
5330                }
5331
5332                /**
5333                 * Performs a deep copy on <i>other</i>.
5334                 */
5335                public flush_queue_args(flush_queue_args other) {
5336                        if (other.is_set_queue_name()) {
5337                                this.queue_name = other.queue_name;
5338                        }
5339                }
5340
5341                @Override
5342                public flush_queue_args deepCopy() {
5343                        return new flush_queue_args(this);
5344                }
5345
5346                @Override
5347                public void clear() {
5348                        this.queue_name = null;
5349                }
5350
5351                public String get_queue_name() {
5352                        return this.queue_name;
5353                }
5354
5355                public void set_queue_name(String queue_name) {
5356                        this.queue_name = queue_name;
5357                }
5358
5359                public void unset_queue_name() {
5360                        this.queue_name = null;
5361                }
5362
5363                /**
5364                 * Returns true if field queue_name is set (has been assigned a value)
5365                 * and false otherwise
5366                 */
5367                public boolean is_set_queue_name() {
5368                        return this.queue_name != null;
5369                }
5370
5371                public void set_queue_name_isSet(boolean value) {
5372                        if (!value) {
5373                                this.queue_name = null;
5374                        }
5375                }
5376
5377                @Override
5378                public void setFieldValue(_Fields field, Object value) {
5379                        switch (field) {
5380                        case QUEUE_NAME:
5381                                if (value == null) {
5382                                        unset_queue_name();
5383                                } else {
5384                                        set_queue_name((String) value);
5385                                }
5386                                break;
5387
5388                        }
5389                }
5390
5391                @Override
5392                public Object getFieldValue(_Fields field) {
5393                        switch (field) {
5394                        case QUEUE_NAME:
5395                                return get_queue_name();
5396
5397                        }
5398                        throw new IllegalStateException();
5399                }
5400
5401                /**
5402                 * Returns true if field corresponding to fieldID is set (has been
5403                 * assigned a value) and false otherwise
5404                 */
5405                @Override
5406                public boolean isSet(_Fields field) {
5407                        if (field == null) {
5408                                throw new IllegalArgumentException();
5409                        }
5410
5411                        switch (field) {
5412                        case QUEUE_NAME:
5413                                return is_set_queue_name();
5414                        }
5415                        throw new IllegalStateException();
5416                }
5417
5418                @Override
5419                public boolean equals(Object that) {
5420                        if (that == null)
5421                                return false;
5422                        if (that instanceof flush_queue_args)
5423                                return this.equals((flush_queue_args) that);
5424                        return false;
5425                }
5426
5427                public boolean equals(flush_queue_args that) {
5428                        if (that == null)
5429                                return false;
5430
5431                        final boolean this_present_queue_name = true && this.is_set_queue_name();
5432                        final boolean that_present_queue_name = true && that.is_set_queue_name();
5433                        if (this_present_queue_name || that_present_queue_name) {
5434                                if (!(this_present_queue_name && that_present_queue_name))
5435                                        return false;
5436                                if (!this.queue_name.equals(that.queue_name))
5437                                        return false;
5438                        }
5439
5440                        return true;
5441                }
5442
5443                @Override
5444                public int hashCode() {
5445                        final HashCodeBuilder builder = new HashCodeBuilder();
5446
5447                        final boolean present_queue_name = true && (is_set_queue_name());
5448                        builder.append(present_queue_name);
5449                        if (present_queue_name)
5450                                builder.append(queue_name);
5451
5452                        return builder.toHashCode();
5453                }
5454
5455                @Override
5456                public int compareTo(flush_queue_args other) {
5457                        if (!getClass().equals(other.getClass())) {
5458                                return getClass().getName().compareTo(other.getClass().getName());
5459                        }
5460
5461                        int lastComparison = 0;
5462                        final flush_queue_args typedOther = other;
5463
5464                        lastComparison = Boolean.valueOf(is_set_queue_name()).compareTo(typedOther.is_set_queue_name());
5465                        if (lastComparison != 0) {
5466                                return lastComparison;
5467                        }
5468                        if (is_set_queue_name()) {
5469                                lastComparison = org.apache.thrift7.TBaseHelper.compareTo(this.queue_name, typedOther.queue_name);
5470                                if (lastComparison != 0) {
5471                                        return lastComparison;
5472                                }
5473                        }
5474                        return 0;
5475                }
5476
5477                @Override
5478                public _Fields fieldForId(int fieldId) {
5479                        return _Fields.findByThriftId(fieldId);
5480                }
5481
5482                @Override
5483                public void read(org.apache.thrift7.protocol.TProtocol iprot) throws org.apache.thrift7.TException {
5484                        org.apache.thrift7.protocol.TField field;
5485                        iprot.readStructBegin();
5486                        while (true)
5487                        {
5488                                field = iprot.readFieldBegin();
5489                                if (field.type == org.apache.thrift7.protocol.TType.STOP) {
5490                                        break;
5491                                }
5492                                switch (field.id) {
5493                                case 1: // QUEUE_NAME
5494                                        if (field.type == org.apache.thrift7.protocol.TType.STRING) {
5495                                                this.queue_name = iprot.readString();
5496                                        } else {
5497                                                org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
5498                                        }
5499                                        break;
5500                                default:
5501                                        org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
5502                                }
5503                                iprot.readFieldEnd();
5504                        }
5505                        iprot.readStructEnd();
5506                        validate();
5507                }
5508
5509                @Override
5510                public void write(org.apache.thrift7.protocol.TProtocol oprot) throws org.apache.thrift7.TException {
5511                        validate();
5512
5513                        oprot.writeStructBegin(STRUCT_DESC);
5514                        if (this.queue_name != null) {
5515                                oprot.writeFieldBegin(QUEUE_NAME_FIELD_DESC);
5516                                oprot.writeString(this.queue_name);
5517                                oprot.writeFieldEnd();
5518                        }
5519                        oprot.writeFieldStop();
5520                        oprot.writeStructEnd();
5521                }
5522
5523                @Override
5524                public String toString() {
5525                        final StringBuilder sb = new StringBuilder("flush_queue_args(");
5526                        boolean first = true;
5527
5528                        sb.append("queue_name:");
5529                        if (this.queue_name == null) {
5530                                sb.append("null");
5531                        } else {
5532                                sb.append(this.queue_name);
5533                        }
5534                        first = false;
5535                        sb.append(")");
5536                        return sb.toString();
5537                }
5538
5539                public void validate() throws org.apache.thrift7.TException {
5540                        // check for required fields
5541                }
5542
5543                private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
5544                        try {
5545                                write(new org.apache.thrift7.protocol.TCompactProtocol(
5546                                                new org.apache.thrift7.transport.TIOStreamTransport(out)));
5547                        } catch (final org.apache.thrift7.TException te) {
5548                                throw new java.io.IOException(te);
5549                        }
5550                }
5551
5552                private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
5553                        try {
5554                                read(new org.apache.thrift7.protocol.TCompactProtocol(
5555                                                new org.apache.thrift7.transport.TIOStreamTransport(in)));
5556                        } catch (final org.apache.thrift7.TException te) {
5557                                throw new java.io.IOException(te);
5558                        }
5559                }
5560
5561        }
5562
5563        public static class flush_queue_result
5564                        implements
5565                                org.apache.thrift7.TBase<flush_queue_result, flush_queue_result._Fields>,
5566                                java.io.Serializable,
5567                                Cloneable
5568        {
5569                private static final org.apache.thrift7.protocol.TStruct STRUCT_DESC = new org.apache.thrift7.protocol.TStruct(
5570                                "flush_queue_result");
5571
5572                /**
5573                 * The set of fields this struct contains, along with convenience
5574                 * methods for finding and manipulating them.
5575                 */
5576                public enum _Fields implements org.apache.thrift7.TFieldIdEnum {
5577                        ;
5578
5579                        private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
5580
5581                        static {
5582                                for (final _Fields field : EnumSet.allOf(_Fields.class)) {
5583                                        byName.put(field.getFieldName(), field);
5584                                }
5585                        }
5586
5587                        /**
5588                         * Find the _Fields constant that matches fieldId, or null if its
5589                         * not found.
5590                         */
5591                        public static _Fields findByThriftId(int fieldId) {
5592                                switch (fieldId) {
5593                                default:
5594                                        return null;
5595                                }
5596                        }
5597
5598                        /**
5599                         * Find the _Fields constant that matches fieldId, throwing an
5600                         * exception if it is not found.
5601                         */
5602                        public static _Fields findByThriftIdOrThrow(int fieldId) {
5603                                final _Fields fields = findByThriftId(fieldId);
5604                                if (fields == null)
5605                                        throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
5606                                return fields;
5607                        }
5608
5609                        /**
5610                         * Find the _Fields constant that matches name, or null if its not
5611                         * found.
5612                         */
5613                        public static _Fields findByName(String name) {
5614                                return byName.get(name);
5615                        }
5616
5617                        private final short _thriftId;
5618                        private final String _fieldName;
5619
5620                        _Fields(short thriftId, String fieldName) {
5621                                _thriftId = thriftId;
5622                                _fieldName = fieldName;
5623                        }
5624
5625                        @Override
5626                        public short getThriftFieldId() {
5627                                return _thriftId;
5628                        }
5629
5630                        @Override
5631                        public String getFieldName() {
5632                                return _fieldName;
5633                        }
5634                }
5635
5636                public static final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> metaDataMap;
5637                static {
5638                        final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift7.meta_data.FieldMetaData>(
5639                                        _Fields.class);
5640                        metaDataMap = Collections.unmodifiableMap(tmpMap);
5641                        org.apache.thrift7.meta_data.FieldMetaData.addStructMetaDataMap(flush_queue_result.class, metaDataMap);
5642                }
5643
5644                public flush_queue_result() {
5645                }
5646
5647                /**
5648                 * Performs a deep copy on <i>other</i>.
5649                 */
5650                public flush_queue_result(flush_queue_result other) {
5651                }
5652
5653                @Override
5654                public flush_queue_result deepCopy() {
5655                        return new flush_queue_result(this);
5656                }
5657
5658                @Override
5659                public void clear() {
5660                }
5661
5662                @Override
5663                public void setFieldValue(_Fields field, Object value) {
5664                        switch (field) {
5665                        }
5666                }
5667
5668                @Override
5669                public Object getFieldValue(_Fields field) {
5670                        switch (field) {
5671                        }
5672                        throw new IllegalStateException();
5673                }
5674
5675                /**
5676                 * Returns true if field corresponding to fieldID is set (has been
5677                 * assigned a value) and false otherwise
5678                 */
5679                @Override
5680                public boolean isSet(_Fields field) {
5681                        if (field == null) {
5682                                throw new IllegalArgumentException();
5683                        }
5684
5685                        switch (field) {
5686                        }
5687                        throw new IllegalStateException();
5688                }
5689
5690                @Override
5691                public boolean equals(Object that) {
5692                        if (that == null)
5693                                return false;
5694                        if (that instanceof flush_queue_result)
5695                                return this.equals((flush_queue_result) that);
5696                        return false;
5697                }
5698
5699                public boolean equals(flush_queue_result that) {
5700                        if (that == null)
5701                                return false;
5702
5703                        return true;
5704                }
5705
5706                @Override
5707                public int hashCode() {
5708                        final HashCodeBuilder builder = new HashCodeBuilder();
5709
5710                        return builder.toHashCode();
5711                }
5712
5713                @Override
5714                public int compareTo(flush_queue_result other) {
5715                        if (!getClass().equals(other.getClass())) {
5716                                return getClass().getName().compareTo(other.getClass().getName());
5717                        }
5718
5719                        final int lastComparison = 0;
5720                        final flush_queue_result typedOther = other;
5721
5722                        return 0;
5723                }
5724
5725                @Override
5726                public _Fields fieldForId(int fieldId) {
5727                        return _Fields.findByThriftId(fieldId);
5728                }
5729
5730                @Override
5731                public void read(org.apache.thrift7.protocol.TProtocol iprot) throws org.apache.thrift7.TException {
5732                        org.apache.thrift7.protocol.TField field;
5733                        iprot.readStructBegin();
5734                        while (true)
5735                        {
5736                                field = iprot.readFieldBegin();
5737                                if (field.type == org.apache.thrift7.protocol.TType.STOP) {
5738                                        break;
5739                                }
5740                                switch (field.id) {
5741                                default:
5742                                        org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
5743                                }
5744                                iprot.readFieldEnd();
5745                        }
5746                        iprot.readStructEnd();
5747                        validate();
5748                }
5749
5750                @Override
5751                public void write(org.apache.thrift7.protocol.TProtocol oprot) throws org.apache.thrift7.TException {
5752                        oprot.writeStructBegin(STRUCT_DESC);
5753
5754                        oprot.writeFieldStop();
5755                        oprot.writeStructEnd();
5756                }
5757
5758                @Override
5759                public String toString() {
5760                        final StringBuilder sb = new StringBuilder("flush_queue_result(");
5761                        final boolean first = true;
5762
5763                        sb.append(")");
5764                        return sb.toString();
5765                }
5766
5767                public void validate() throws org.apache.thrift7.TException {
5768                        // check for required fields
5769                }
5770
5771                private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
5772                        try {
5773                                write(new org.apache.thrift7.protocol.TCompactProtocol(
5774                                                new org.apache.thrift7.transport.TIOStreamTransport(out)));
5775                        } catch (final org.apache.thrift7.TException te) {
5776                                throw new java.io.IOException(te);
5777                        }
5778                }
5779
5780                private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
5781                        try {
5782                                read(new org.apache.thrift7.protocol.TCompactProtocol(
5783                                                new org.apache.thrift7.transport.TIOStreamTransport(in)));
5784                        } catch (final org.apache.thrift7.TException te) {
5785                                throw new java.io.IOException(te);
5786                        }
5787                }
5788
5789        }
5790
5791        public static class flush_all_queues_args
5792                        implements
5793                                org.apache.thrift7.TBase<flush_all_queues_args, flush_all_queues_args._Fields>,
5794                                java.io.Serializable,
5795                                Cloneable
5796        {
5797                private static final org.apache.thrift7.protocol.TStruct STRUCT_DESC = new org.apache.thrift7.protocol.TStruct(
5798                                "flush_all_queues_args");
5799
5800                /**
5801                 * The set of fields this struct contains, along with convenience
5802                 * methods for finding and manipulating them.
5803                 */
5804                public enum _Fields implements org.apache.thrift7.TFieldIdEnum {
5805                        ;
5806
5807                        private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
5808
5809                        static {
5810                                for (final _Fields field : EnumSet.allOf(_Fields.class)) {
5811                                        byName.put(field.getFieldName(), field);
5812                                }
5813                        }
5814
5815                        /**
5816                         * Find the _Fields constant that matches fieldId, or null if its
5817                         * not found.
5818                         */
5819                        public static _Fields findByThriftId(int fieldId) {
5820                                switch (fieldId) {
5821                                default:
5822                                        return null;
5823                                }
5824                        }
5825
5826                        /**
5827                         * Find the _Fields constant that matches fieldId, throwing an
5828                         * exception if it is not found.
5829                         */
5830                        public static _Fields findByThriftIdOrThrow(int fieldId) {
5831                                final _Fields fields = findByThriftId(fieldId);
5832                                if (fields == null)
5833                                        throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
5834                                return fields;
5835                        }
5836
5837                        /**
5838                         * Find the _Fields constant that matches name, or null if its not
5839                         * found.
5840                         */
5841                        public static _Fields findByName(String name) {
5842                                return byName.get(name);
5843                        }
5844
5845                        private final short _thriftId;
5846                        private final String _fieldName;
5847
5848                        _Fields(short thriftId, String fieldName) {
5849                                _thriftId = thriftId;
5850                                _fieldName = fieldName;
5851                        }
5852
5853                        @Override
5854                        public short getThriftFieldId() {
5855                                return _thriftId;
5856                        }
5857
5858                        @Override
5859                        public String getFieldName() {
5860                                return _fieldName;
5861                        }
5862                }
5863
5864                public static final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> metaDataMap;
5865                static {
5866                        final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift7.meta_data.FieldMetaData>(
5867                                        _Fields.class);
5868                        metaDataMap = Collections.unmodifiableMap(tmpMap);
5869                        org.apache.thrift7.meta_data.FieldMetaData.addStructMetaDataMap(flush_all_queues_args.class, metaDataMap);
5870                }
5871
5872                public flush_all_queues_args() {
5873                }
5874
5875                /**
5876                 * Performs a deep copy on <i>other</i>.
5877                 */
5878                public flush_all_queues_args(flush_all_queues_args other) {
5879                }
5880
5881                @Override
5882                public flush_all_queues_args deepCopy() {
5883                        return new flush_all_queues_args(this);
5884                }
5885
5886                @Override
5887                public void clear() {
5888                }
5889
5890                @Override
5891                public void setFieldValue(_Fields field, Object value) {
5892                        switch (field) {
5893                        }
5894                }
5895
5896                @Override
5897                public Object getFieldValue(_Fields field) {
5898                        switch (field) {
5899                        }
5900                        throw new IllegalStateException();
5901                }
5902
5903                /**
5904                 * Returns true if field corresponding to fieldID is set (has been
5905                 * assigned a value) and false otherwise
5906                 */
5907                @Override
5908                public boolean isSet(_Fields field) {
5909                        if (field == null) {
5910                                throw new IllegalArgumentException();
5911                        }
5912
5913                        switch (field) {
5914                        }
5915                        throw new IllegalStateException();
5916                }
5917
5918                @Override
5919                public boolean equals(Object that) {
5920                        if (that == null)
5921                                return false;
5922                        if (that instanceof flush_all_queues_args)
5923                                return this.equals((flush_all_queues_args) that);
5924                        return false;
5925                }
5926
5927                public boolean equals(flush_all_queues_args that) {
5928                        if (that == null)
5929                                return false;
5930
5931                        return true;
5932                }
5933
5934                @Override
5935                public int hashCode() {
5936                        final HashCodeBuilder builder = new HashCodeBuilder();
5937
5938                        return builder.toHashCode();
5939                }
5940
5941                @Override
5942                public int compareTo(flush_all_queues_args other) {
5943                        if (!getClass().equals(other.getClass())) {
5944                                return getClass().getName().compareTo(other.getClass().getName());
5945                        }
5946
5947                        final int lastComparison = 0;
5948                        final flush_all_queues_args typedOther = other;
5949
5950                        return 0;
5951                }
5952
5953                @Override
5954                public _Fields fieldForId(int fieldId) {
5955                        return _Fields.findByThriftId(fieldId);
5956                }
5957
5958                @Override
5959                public void read(org.apache.thrift7.protocol.TProtocol iprot) throws org.apache.thrift7.TException {
5960                        org.apache.thrift7.protocol.TField field;
5961                        iprot.readStructBegin();
5962                        while (true)
5963                        {
5964                                field = iprot.readFieldBegin();
5965                                if (field.type == org.apache.thrift7.protocol.TType.STOP) {
5966                                        break;
5967                                }
5968                                switch (field.id) {
5969                                default:
5970                                        org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
5971                                }
5972                                iprot.readFieldEnd();
5973                        }
5974                        iprot.readStructEnd();
5975                        validate();
5976                }
5977
5978                @Override
5979                public void write(org.apache.thrift7.protocol.TProtocol oprot) throws org.apache.thrift7.TException {
5980                        validate();
5981
5982                        oprot.writeStructBegin(STRUCT_DESC);
5983                        oprot.writeFieldStop();
5984                        oprot.writeStructEnd();
5985                }
5986
5987                @Override
5988                public String toString() {
5989                        final StringBuilder sb = new StringBuilder("flush_all_queues_args(");
5990                        final boolean first = true;
5991
5992                        sb.append(")");
5993                        return sb.toString();
5994                }
5995
5996                public void validate() throws org.apache.thrift7.TException {
5997                        // check for required fields
5998                }
5999
6000                private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
6001                        try {
6002                                write(new org.apache.thrift7.protocol.TCompactProtocol(
6003                                                new org.apache.thrift7.transport.TIOStreamTransport(out)));
6004                        } catch (final org.apache.thrift7.TException te) {
6005                                throw new java.io.IOException(te);
6006                        }
6007                }
6008
6009                private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
6010                        try {
6011                                read(new org.apache.thrift7.protocol.TCompactProtocol(
6012                                                new org.apache.thrift7.transport.TIOStreamTransport(in)));
6013                        } catch (final org.apache.thrift7.TException te) {
6014                                throw new java.io.IOException(te);
6015                        }
6016                }
6017
6018        }
6019
6020        public static class flush_all_queues_result
6021                        implements
6022                                org.apache.thrift7.TBase<flush_all_queues_result, flush_all_queues_result._Fields>,
6023                                java.io.Serializable,
6024                                Cloneable
6025        {
6026                private static final org.apache.thrift7.protocol.TStruct STRUCT_DESC = new org.apache.thrift7.protocol.TStruct(
6027                                "flush_all_queues_result");
6028
6029                /**
6030                 * The set of fields this struct contains, along with convenience
6031                 * methods for finding and manipulating them.
6032                 */
6033                public enum _Fields implements org.apache.thrift7.TFieldIdEnum {
6034                        ;
6035
6036                        private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
6037
6038                        static {
6039                                for (final _Fields field : EnumSet.allOf(_Fields.class)) {
6040                                        byName.put(field.getFieldName(), field);
6041                                }
6042                        }
6043
6044                        /**
6045                         * Find the _Fields constant that matches fieldId, or null if its
6046                         * not found.
6047                         */
6048                        public static _Fields findByThriftId(int fieldId) {
6049                                switch (fieldId) {
6050                                default:
6051                                        return null;
6052                                }
6053                        }
6054
6055                        /**
6056                         * Find the _Fields constant that matches fieldId, throwing an
6057                         * exception if it is not found.
6058                         */
6059                        public static _Fields findByThriftIdOrThrow(int fieldId) {
6060                                final _Fields fields = findByThriftId(fieldId);
6061                                if (fields == null)
6062                                        throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
6063                                return fields;
6064                        }
6065
6066                        /**
6067                         * Find the _Fields constant that matches name, or null if its not
6068                         * found.
6069                         */
6070                        public static _Fields findByName(String name) {
6071                                return byName.get(name);
6072                        }
6073
6074                        private final short _thriftId;
6075                        private final String _fieldName;
6076
6077                        _Fields(short thriftId, String fieldName) {
6078                                _thriftId = thriftId;
6079                                _fieldName = fieldName;
6080                        }
6081
6082                        @Override
6083                        public short getThriftFieldId() {
6084                                return _thriftId;
6085                        }
6086
6087                        @Override
6088                        public String getFieldName() {
6089                                return _fieldName;
6090                        }
6091                }
6092
6093                public static final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> metaDataMap;
6094                static {
6095                        final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift7.meta_data.FieldMetaData>(
6096                                        _Fields.class);
6097                        metaDataMap = Collections.unmodifiableMap(tmpMap);
6098                        org.apache.thrift7.meta_data.FieldMetaData.addStructMetaDataMap(flush_all_queues_result.class, metaDataMap);
6099                }
6100
6101                public flush_all_queues_result() {
6102                }
6103
6104                /**
6105                 * Performs a deep copy on <i>other</i>.
6106                 */
6107                public flush_all_queues_result(flush_all_queues_result other) {
6108                }
6109
6110                @Override
6111                public flush_all_queues_result deepCopy() {
6112                        return new flush_all_queues_result(this);
6113                }
6114
6115                @Override
6116                public void clear() {
6117                }
6118
6119                @Override
6120                public void setFieldValue(_Fields field, Object value) {
6121                        switch (field) {
6122                        }
6123                }
6124
6125                @Override
6126                public Object getFieldValue(_Fields field) {
6127                        switch (field) {
6128                        }
6129                        throw new IllegalStateException();
6130                }
6131
6132                /**
6133                 * Returns true if field corresponding to fieldID is set (has been
6134                 * assigned a value) and false otherwise
6135                 */
6136                @Override
6137                public boolean isSet(_Fields field) {
6138                        if (field == null) {
6139                                throw new IllegalArgumentException();
6140                        }
6141
6142                        switch (field) {
6143                        }
6144                        throw new IllegalStateException();
6145                }
6146
6147                @Override
6148                public boolean equals(Object that) {
6149                        if (that == null)
6150                                return false;
6151                        if (that instanceof flush_all_queues_result)
6152                                return this.equals((flush_all_queues_result) that);
6153                        return false;
6154                }
6155
6156                public boolean equals(flush_all_queues_result that) {
6157                        if (that == null)
6158                                return false;
6159
6160                        return true;
6161                }
6162
6163                @Override
6164                public int hashCode() {
6165                        final HashCodeBuilder builder = new HashCodeBuilder();
6166
6167                        return builder.toHashCode();
6168                }
6169
6170                @Override
6171                public int compareTo(flush_all_queues_result other) {
6172                        if (!getClass().equals(other.getClass())) {
6173                                return getClass().getName().compareTo(other.getClass().getName());
6174                        }
6175
6176                        final int lastComparison = 0;
6177                        final flush_all_queues_result typedOther = other;
6178
6179                        return 0;
6180                }
6181
6182                @Override
6183                public _Fields fieldForId(int fieldId) {
6184                        return _Fields.findByThriftId(fieldId);
6185                }
6186
6187                @Override
6188                public void read(org.apache.thrift7.protocol.TProtocol iprot) throws org.apache.thrift7.TException {
6189                        org.apache.thrift7.protocol.TField field;
6190                        iprot.readStructBegin();
6191                        while (true)
6192                        {
6193                                field = iprot.readFieldBegin();
6194                                if (field.type == org.apache.thrift7.protocol.TType.STOP) {
6195                                        break;
6196                                }
6197                                switch (field.id) {
6198                                default:
6199                                        org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
6200                                }
6201                                iprot.readFieldEnd();
6202                        }
6203                        iprot.readStructEnd();
6204                        validate();
6205                }
6206
6207                @Override
6208                public void write(org.apache.thrift7.protocol.TProtocol oprot) throws org.apache.thrift7.TException {
6209                        oprot.writeStructBegin(STRUCT_DESC);
6210
6211                        oprot.writeFieldStop();
6212                        oprot.writeStructEnd();
6213                }
6214
6215                @Override
6216                public String toString() {
6217                        final StringBuilder sb = new StringBuilder("flush_all_queues_result(");
6218                        final boolean first = true;
6219
6220                        sb.append(")");
6221                        return sb.toString();
6222                }
6223
6224                public void validate() throws org.apache.thrift7.TException {
6225                        // check for required fields
6226                }
6227
6228                private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
6229                        try {
6230                                write(new org.apache.thrift7.protocol.TCompactProtocol(
6231                                                new org.apache.thrift7.transport.TIOStreamTransport(out)));
6232                        } catch (final org.apache.thrift7.TException te) {
6233                                throw new java.io.IOException(te);
6234                        }
6235                }
6236
6237                private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
6238                        try {
6239                                read(new org.apache.thrift7.protocol.TCompactProtocol(
6240                                                new org.apache.thrift7.transport.TIOStreamTransport(in)));
6241                        } catch (final org.apache.thrift7.TException te) {
6242                                throw new java.io.IOException(te);
6243                        }
6244                }
6245
6246        }
6247
6248        public static class delete_queue_args
6249                        implements
6250                                org.apache.thrift7.TBase<delete_queue_args, delete_queue_args._Fields>,
6251                                java.io.Serializable,
6252                                Cloneable
6253        {
6254                private static final org.apache.thrift7.protocol.TStruct STRUCT_DESC = new org.apache.thrift7.protocol.TStruct(
6255                                "delete_queue_args");
6256
6257                private static final org.apache.thrift7.protocol.TField QUEUE_NAME_FIELD_DESC = new org.apache.thrift7.protocol.TField(
6258                                "queue_name", org.apache.thrift7.protocol.TType.STRING, (short) 1);
6259
6260                private String queue_name; // required
6261
6262                /**
6263                 * The set of fields this struct contains, along with convenience
6264                 * methods for finding and manipulating them.
6265                 */
6266                public enum _Fields implements org.apache.thrift7.TFieldIdEnum {
6267                        QUEUE_NAME((short) 1, "queue_name");
6268
6269                        private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
6270
6271                        static {
6272                                for (final _Fields field : EnumSet.allOf(_Fields.class)) {
6273                                        byName.put(field.getFieldName(), field);
6274                                }
6275                        }
6276
6277                        /**
6278                         * Find the _Fields constant that matches fieldId, or null if its
6279                         * not found.
6280                         */
6281                        public static _Fields findByThriftId(int fieldId) {
6282                                switch (fieldId) {
6283                                case 1: // QUEUE_NAME
6284                                        return QUEUE_NAME;
6285                                default:
6286                                        return null;
6287                                }
6288                        }
6289
6290                        /**
6291                         * Find the _Fields constant that matches fieldId, throwing an
6292                         * exception if it is not found.
6293                         */
6294                        public static _Fields findByThriftIdOrThrow(int fieldId) {
6295                                final _Fields fields = findByThriftId(fieldId);
6296                                if (fields == null)
6297                                        throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
6298                                return fields;
6299                        }
6300
6301                        /**
6302                         * Find the _Fields constant that matches name, or null if its not
6303                         * found.
6304                         */
6305                        public static _Fields findByName(String name) {
6306                                return byName.get(name);
6307                        }
6308
6309                        private final short _thriftId;
6310                        private final String _fieldName;
6311
6312                        _Fields(short thriftId, String fieldName) {
6313                                _thriftId = thriftId;
6314                                _fieldName = fieldName;
6315                        }
6316
6317                        @Override
6318                        public short getThriftFieldId() {
6319                                return _thriftId;
6320                        }
6321
6322                        @Override
6323                        public String getFieldName() {
6324                                return _fieldName;
6325                        }
6326                }
6327
6328                // isset id assignments
6329
6330                public static final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> metaDataMap;
6331                static {
6332                        final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift7.meta_data.FieldMetaData>(
6333                                        _Fields.class);
6334                        tmpMap.put(_Fields.QUEUE_NAME, new org.apache.thrift7.meta_data.FieldMetaData("queue_name",
6335                                        org.apache.thrift7.TFieldRequirementType.DEFAULT,
6336                                        new org.apache.thrift7.meta_data.FieldValueMetaData(org.apache.thrift7.protocol.TType.STRING)));
6337                        metaDataMap = Collections.unmodifiableMap(tmpMap);
6338                        org.apache.thrift7.meta_data.FieldMetaData.addStructMetaDataMap(delete_queue_args.class, metaDataMap);
6339                }
6340
6341                public delete_queue_args() {
6342                }
6343
6344                public delete_queue_args(
6345                                String queue_name)
6346                {
6347                        this();
6348                        this.queue_name = queue_name;
6349                }
6350
6351                /**
6352                 * Performs a deep copy on <i>other</i>.
6353                 */
6354                public delete_queue_args(delete_queue_args other) {
6355                        if (other.is_set_queue_name()) {
6356                                this.queue_name = other.queue_name;
6357                        }
6358                }
6359
6360                @Override
6361                public delete_queue_args deepCopy() {
6362                        return new delete_queue_args(this);
6363                }
6364
6365                @Override
6366                public void clear() {
6367                        this.queue_name = null;
6368                }
6369
6370                public String get_queue_name() {
6371                        return this.queue_name;
6372                }
6373
6374                public void set_queue_name(String queue_name) {
6375                        this.queue_name = queue_name;
6376                }
6377
6378                public void unset_queue_name() {
6379                        this.queue_name = null;
6380                }
6381
6382                /**
6383                 * Returns true if field queue_name is set (has been assigned a value)
6384                 * and false otherwise
6385                 */
6386                public boolean is_set_queue_name() {
6387                        return this.queue_name != null;
6388                }
6389
6390                public void set_queue_name_isSet(boolean value) {
6391                        if (!value) {
6392                                this.queue_name = null;
6393                        }
6394                }
6395
6396                @Override
6397                public void setFieldValue(_Fields field, Object value) {
6398                        switch (field) {
6399                        case QUEUE_NAME:
6400                                if (value == null) {
6401                                        unset_queue_name();
6402                                } else {
6403                                        set_queue_name((String) value);
6404                                }
6405                                break;
6406
6407                        }
6408                }
6409
6410                @Override
6411                public Object getFieldValue(_Fields field) {
6412                        switch (field) {
6413                        case QUEUE_NAME:
6414                                return get_queue_name();
6415
6416                        }
6417                        throw new IllegalStateException();
6418                }
6419
6420                /**
6421                 * Returns true if field corresponding to fieldID is set (has been
6422                 * assigned a value) and false otherwise
6423                 */
6424                @Override
6425                public boolean isSet(_Fields field) {
6426                        if (field == null) {
6427                                throw new IllegalArgumentException();
6428                        }
6429
6430                        switch (field) {
6431                        case QUEUE_NAME:
6432                                return is_set_queue_name();
6433                        }
6434                        throw new IllegalStateException();
6435                }
6436
6437                @Override
6438                public boolean equals(Object that) {
6439                        if (that == null)
6440                                return false;
6441                        if (that instanceof delete_queue_args)
6442                                return this.equals((delete_queue_args) that);
6443                        return false;
6444                }
6445
6446                public boolean equals(delete_queue_args that) {
6447                        if (that == null)
6448                                return false;
6449
6450                        final boolean this_present_queue_name = true && this.is_set_queue_name();
6451                        final boolean that_present_queue_name = true && that.is_set_queue_name();
6452                        if (this_present_queue_name || that_present_queue_name) {
6453                                if (!(this_present_queue_name && that_present_queue_name))
6454                                        return false;
6455                                if (!this.queue_name.equals(that.queue_name))
6456                                        return false;
6457                        }
6458
6459                        return true;
6460                }
6461
6462                @Override
6463                public int hashCode() {
6464                        final HashCodeBuilder builder = new HashCodeBuilder();
6465
6466                        final boolean present_queue_name = true && (is_set_queue_name());
6467                        builder.append(present_queue_name);
6468                        if (present_queue_name)
6469                                builder.append(queue_name);
6470
6471                        return builder.toHashCode();
6472                }
6473
6474                @Override
6475                public int compareTo(delete_queue_args other) {
6476                        if (!getClass().equals(other.getClass())) {
6477                                return getClass().getName().compareTo(other.getClass().getName());
6478                        }
6479
6480                        int lastComparison = 0;
6481                        final delete_queue_args typedOther = other;
6482
6483                        lastComparison = Boolean.valueOf(is_set_queue_name()).compareTo(typedOther.is_set_queue_name());
6484                        if (lastComparison != 0) {
6485                                return lastComparison;
6486                        }
6487                        if (is_set_queue_name()) {
6488                                lastComparison = org.apache.thrift7.TBaseHelper.compareTo(this.queue_name, typedOther.queue_name);
6489                                if (lastComparison != 0) {
6490                                        return lastComparison;
6491                                }
6492                        }
6493                        return 0;
6494                }
6495
6496                @Override
6497                public _Fields fieldForId(int fieldId) {
6498                        return _Fields.findByThriftId(fieldId);
6499                }
6500
6501                @Override
6502                public void read(org.apache.thrift7.protocol.TProtocol iprot) throws org.apache.thrift7.TException {
6503                        org.apache.thrift7.protocol.TField field;
6504                        iprot.readStructBegin();
6505                        while (true)
6506                        {
6507                                field = iprot.readFieldBegin();
6508                                if (field.type == org.apache.thrift7.protocol.TType.STOP) {
6509                                        break;
6510                                }
6511                                switch (field.id) {
6512                                case 1: // QUEUE_NAME
6513                                        if (field.type == org.apache.thrift7.protocol.TType.STRING) {
6514                                                this.queue_name = iprot.readString();
6515                                        } else {
6516                                                org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
6517                                        }
6518                                        break;
6519                                default:
6520                                        org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
6521                                }
6522                                iprot.readFieldEnd();
6523                        }
6524                        iprot.readStructEnd();
6525                        validate();
6526                }
6527
6528                @Override
6529                public void write(org.apache.thrift7.protocol.TProtocol oprot) throws org.apache.thrift7.TException {
6530                        validate();
6531
6532                        oprot.writeStructBegin(STRUCT_DESC);
6533                        if (this.queue_name != null) {
6534                                oprot.writeFieldBegin(QUEUE_NAME_FIELD_DESC);
6535                                oprot.writeString(this.queue_name);
6536                                oprot.writeFieldEnd();
6537                        }
6538                        oprot.writeFieldStop();
6539                        oprot.writeStructEnd();
6540                }
6541
6542                @Override
6543                public String toString() {
6544                        final StringBuilder sb = new StringBuilder("delete_queue_args(");
6545                        boolean first = true;
6546
6547                        sb.append("queue_name:");
6548                        if (this.queue_name == null) {
6549                                sb.append("null");
6550                        } else {
6551                                sb.append(this.queue_name);
6552                        }
6553                        first = false;
6554                        sb.append(")");
6555                        return sb.toString();
6556                }
6557
6558                public void validate() throws org.apache.thrift7.TException {
6559                        // check for required fields
6560                }
6561
6562                private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
6563                        try {
6564                                write(new org.apache.thrift7.protocol.TCompactProtocol(
6565                                                new org.apache.thrift7.transport.TIOStreamTransport(out)));
6566                        } catch (final org.apache.thrift7.TException te) {
6567                                throw new java.io.IOException(te);
6568                        }
6569                }
6570
6571                private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
6572                        try {
6573                                read(new org.apache.thrift7.protocol.TCompactProtocol(
6574                                                new org.apache.thrift7.transport.TIOStreamTransport(in)));
6575                        } catch (final org.apache.thrift7.TException te) {
6576                                throw new java.io.IOException(te);
6577                        }
6578                }
6579
6580        }
6581
6582        public static class delete_queue_result
6583                        implements
6584                                org.apache.thrift7.TBase<delete_queue_result, delete_queue_result._Fields>,
6585                                java.io.Serializable,
6586                                Cloneable
6587        {
6588                private static final org.apache.thrift7.protocol.TStruct STRUCT_DESC = new org.apache.thrift7.protocol.TStruct(
6589                                "delete_queue_result");
6590
6591                /**
6592                 * The set of fields this struct contains, along with convenience
6593                 * methods for finding and manipulating them.
6594                 */
6595                public enum _Fields implements org.apache.thrift7.TFieldIdEnum {
6596                        ;
6597
6598                        private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
6599
6600                        static {
6601                                for (final _Fields field : EnumSet.allOf(_Fields.class)) {
6602                                        byName.put(field.getFieldName(), field);
6603                                }
6604                        }
6605
6606                        /**
6607                         * Find the _Fields constant that matches fieldId, or null if its
6608                         * not found.
6609                         */
6610                        public static _Fields findByThriftId(int fieldId) {
6611                                switch (fieldId) {
6612                                default:
6613                                        return null;
6614                                }
6615                        }
6616
6617                        /**
6618                         * Find the _Fields constant that matches fieldId, throwing an
6619                         * exception if it is not found.
6620                         */
6621                        public static _Fields findByThriftIdOrThrow(int fieldId) {
6622                                final _Fields fields = findByThriftId(fieldId);
6623                                if (fields == null)
6624                                        throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
6625                                return fields;
6626                        }
6627
6628                        /**
6629                         * Find the _Fields constant that matches name, or null if its not
6630                         * found.
6631                         */
6632                        public static _Fields findByName(String name) {
6633                                return byName.get(name);
6634                        }
6635
6636                        private final short _thriftId;
6637                        private final String _fieldName;
6638
6639                        _Fields(short thriftId, String fieldName) {
6640                                _thriftId = thriftId;
6641                                _fieldName = fieldName;
6642                        }
6643
6644                        @Override
6645                        public short getThriftFieldId() {
6646                                return _thriftId;
6647                        }
6648
6649                        @Override
6650                        public String getFieldName() {
6651                                return _fieldName;
6652                        }
6653                }
6654
6655                public static final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> metaDataMap;
6656                static {
6657                        final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift7.meta_data.FieldMetaData>(
6658                                        _Fields.class);
6659                        metaDataMap = Collections.unmodifiableMap(tmpMap);
6660                        org.apache.thrift7.meta_data.FieldMetaData.addStructMetaDataMap(delete_queue_result.class, metaDataMap);
6661                }
6662
6663                public delete_queue_result() {
6664                }
6665
6666                /**
6667                 * Performs a deep copy on <i>other</i>.
6668                 */
6669                public delete_queue_result(delete_queue_result other) {
6670                }
6671
6672                @Override
6673                public delete_queue_result deepCopy() {
6674                        return new delete_queue_result(this);
6675                }
6676
6677                @Override
6678                public void clear() {
6679                }
6680
6681                @Override
6682                public void setFieldValue(_Fields field, Object value) {
6683                        switch (field) {
6684                        }
6685                }
6686
6687                @Override
6688                public Object getFieldValue(_Fields field) {
6689                        switch (field) {
6690                        }
6691                        throw new IllegalStateException();
6692                }
6693
6694                /**
6695                 * Returns true if field corresponding to fieldID is set (has been
6696                 * assigned a value) and false otherwise
6697                 */
6698                @Override
6699                public boolean isSet(_Fields field) {
6700                        if (field == null) {
6701                                throw new IllegalArgumentException();
6702                        }
6703
6704                        switch (field) {
6705                        }
6706                        throw new IllegalStateException();
6707                }
6708
6709                @Override
6710                public boolean equals(Object that) {
6711                        if (that == null)
6712                                return false;
6713                        if (that instanceof delete_queue_result)
6714                                return this.equals((delete_queue_result) that);
6715                        return false;
6716                }
6717
6718                public boolean equals(delete_queue_result that) {
6719                        if (that == null)
6720                                return false;
6721
6722                        return true;
6723                }
6724
6725                @Override
6726                public int hashCode() {
6727                        final HashCodeBuilder builder = new HashCodeBuilder();
6728
6729                        return builder.toHashCode();
6730                }
6731
6732                @Override
6733                public int compareTo(delete_queue_result other) {
6734                        if (!getClass().equals(other.getClass())) {
6735                                return getClass().getName().compareTo(other.getClass().getName());
6736                        }
6737
6738                        final int lastComparison = 0;
6739                        final delete_queue_result typedOther = other;
6740
6741                        return 0;
6742                }
6743
6744                @Override
6745                public _Fields fieldForId(int fieldId) {
6746                        return _Fields.findByThriftId(fieldId);
6747                }
6748
6749                @Override
6750                public void read(org.apache.thrift7.protocol.TProtocol iprot) throws org.apache.thrift7.TException {
6751                        org.apache.thrift7.protocol.TField field;
6752                        iprot.readStructBegin();
6753                        while (true)
6754                        {
6755                                field = iprot.readFieldBegin();
6756                                if (field.type == org.apache.thrift7.protocol.TType.STOP) {
6757                                        break;
6758                                }
6759                                switch (field.id) {
6760                                default:
6761                                        org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
6762                                }
6763                                iprot.readFieldEnd();
6764                        }
6765                        iprot.readStructEnd();
6766                        validate();
6767                }
6768
6769                @Override
6770                public void write(org.apache.thrift7.protocol.TProtocol oprot) throws org.apache.thrift7.TException {
6771                        oprot.writeStructBegin(STRUCT_DESC);
6772
6773                        oprot.writeFieldStop();
6774                        oprot.writeStructEnd();
6775                }
6776
6777                @Override
6778                public String toString() {
6779                        final StringBuilder sb = new StringBuilder("delete_queue_result(");
6780                        final boolean first = true;
6781
6782                        sb.append(")");
6783                        return sb.toString();
6784                }
6785
6786                public void validate() throws org.apache.thrift7.TException {
6787                        // check for required fields
6788                }
6789
6790                private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
6791                        try {
6792                                write(new org.apache.thrift7.protocol.TCompactProtocol(
6793                                                new org.apache.thrift7.transport.TIOStreamTransport(out)));
6794                        } catch (final org.apache.thrift7.TException te) {
6795                                throw new java.io.IOException(te);
6796                        }
6797                }
6798
6799                private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
6800                        try {
6801                                read(new org.apache.thrift7.protocol.TCompactProtocol(
6802                                                new org.apache.thrift7.transport.TIOStreamTransport(in)));
6803                        } catch (final org.apache.thrift7.TException te) {
6804                                throw new java.io.IOException(te);
6805                        }
6806                }
6807
6808        }
6809
6810        public static class get_version_args
6811                        implements
6812                                org.apache.thrift7.TBase<get_version_args, get_version_args._Fields>,
6813                                java.io.Serializable,
6814                                Cloneable
6815        {
6816                private static final org.apache.thrift7.protocol.TStruct STRUCT_DESC = new org.apache.thrift7.protocol.TStruct(
6817                                "get_version_args");
6818
6819                /**
6820                 * The set of fields this struct contains, along with convenience
6821                 * methods for finding and manipulating them.
6822                 */
6823                public enum _Fields implements org.apache.thrift7.TFieldIdEnum {
6824                        ;
6825
6826                        private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
6827
6828                        static {
6829                                for (final _Fields field : EnumSet.allOf(_Fields.class)) {
6830                                        byName.put(field.getFieldName(), field);
6831                                }
6832                        }
6833
6834                        /**
6835                         * Find the _Fields constant that matches fieldId, or null if its
6836                         * not found.
6837                         */
6838                        public static _Fields findByThriftId(int fieldId) {
6839                                switch (fieldId) {
6840                                default:
6841                                        return null;
6842                                }
6843                        }
6844
6845                        /**
6846                         * Find the _Fields constant that matches fieldId, throwing an
6847                         * exception if it is not found.
6848                         */
6849                        public static _Fields findByThriftIdOrThrow(int fieldId) {
6850                                final _Fields fields = findByThriftId(fieldId);
6851                                if (fields == null)
6852                                        throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
6853                                return fields;
6854                        }
6855
6856                        /**
6857                         * Find the _Fields constant that matches name, or null if its not
6858                         * found.
6859                         */
6860                        public static _Fields findByName(String name) {
6861                                return byName.get(name);
6862                        }
6863
6864                        private final short _thriftId;
6865                        private final String _fieldName;
6866
6867                        _Fields(short thriftId, String fieldName) {
6868                                _thriftId = thriftId;
6869                                _fieldName = fieldName;
6870                        }
6871
6872                        @Override
6873                        public short getThriftFieldId() {
6874                                return _thriftId;
6875                        }
6876
6877                        @Override
6878                        public String getFieldName() {
6879                                return _fieldName;
6880                        }
6881                }
6882
6883                public static final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> metaDataMap;
6884                static {
6885                        final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift7.meta_data.FieldMetaData>(
6886                                        _Fields.class);
6887                        metaDataMap = Collections.unmodifiableMap(tmpMap);
6888                        org.apache.thrift7.meta_data.FieldMetaData.addStructMetaDataMap(get_version_args.class, metaDataMap);
6889                }
6890
6891                public get_version_args() {
6892                }
6893
6894                /**
6895                 * Performs a deep copy on <i>other</i>.
6896                 */
6897                public get_version_args(get_version_args other) {
6898                }
6899
6900                @Override
6901                public get_version_args deepCopy() {
6902                        return new get_version_args(this);
6903                }
6904
6905                @Override
6906                public void clear() {
6907                }
6908
6909                @Override
6910                public void setFieldValue(_Fields field, Object value) {
6911                        switch (field) {
6912                        }
6913                }
6914
6915                @Override
6916                public Object getFieldValue(_Fields field) {
6917                        switch (field) {
6918                        }
6919                        throw new IllegalStateException();
6920                }
6921
6922                /**
6923                 * Returns true if field corresponding to fieldID is set (has been
6924                 * assigned a value) and false otherwise
6925                 */
6926                @Override
6927                public boolean isSet(_Fields field) {
6928                        if (field == null) {
6929                                throw new IllegalArgumentException();
6930                        }
6931
6932                        switch (field) {
6933                        }
6934                        throw new IllegalStateException();
6935                }
6936
6937                @Override
6938                public boolean equals(Object that) {
6939                        if (that == null)
6940                                return false;
6941                        if (that instanceof get_version_args)
6942                                return this.equals((get_version_args) that);
6943                        return false;
6944                }
6945
6946                public boolean equals(get_version_args that) {
6947                        if (that == null)
6948                                return false;
6949
6950                        return true;
6951                }
6952
6953                @Override
6954                public int hashCode() {
6955                        final HashCodeBuilder builder = new HashCodeBuilder();
6956
6957                        return builder.toHashCode();
6958                }
6959
6960                @Override
6961                public int compareTo(get_version_args other) {
6962                        if (!getClass().equals(other.getClass())) {
6963                                return getClass().getName().compareTo(other.getClass().getName());
6964                        }
6965
6966                        final int lastComparison = 0;
6967                        final get_version_args typedOther = other;
6968
6969                        return 0;
6970                }
6971
6972                @Override
6973                public _Fields fieldForId(int fieldId) {
6974                        return _Fields.findByThriftId(fieldId);
6975                }
6976
6977                @Override
6978                public void read(org.apache.thrift7.protocol.TProtocol iprot) throws org.apache.thrift7.TException {
6979                        org.apache.thrift7.protocol.TField field;
6980                        iprot.readStructBegin();
6981                        while (true)
6982                        {
6983                                field = iprot.readFieldBegin();
6984                                if (field.type == org.apache.thrift7.protocol.TType.STOP) {
6985                                        break;
6986                                }
6987                                switch (field.id) {
6988                                default:
6989                                        org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
6990                                }
6991                                iprot.readFieldEnd();
6992                        }
6993                        iprot.readStructEnd();
6994                        validate();
6995                }
6996
6997                @Override
6998                public void write(org.apache.thrift7.protocol.TProtocol oprot) throws org.apache.thrift7.TException {
6999                        validate();
7000
7001                        oprot.writeStructBegin(STRUCT_DESC);
7002                        oprot.writeFieldStop();
7003                        oprot.writeStructEnd();
7004                }
7005
7006                @Override
7007                public String toString() {
7008                        final StringBuilder sb = new StringBuilder("get_version_args(");
7009                        final boolean first = true;
7010
7011                        sb.append(")");
7012                        return sb.toString();
7013                }
7014
7015                public void validate() throws org.apache.thrift7.TException {
7016                        // check for required fields
7017                }
7018
7019                private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
7020                        try {
7021                                write(new org.apache.thrift7.protocol.TCompactProtocol(
7022                                                new org.apache.thrift7.transport.TIOStreamTransport(out)));
7023                        } catch (final org.apache.thrift7.TException te) {
7024                                throw new java.io.IOException(te);
7025                        }
7026                }
7027
7028                private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
7029                        try {
7030                                read(new org.apache.thrift7.protocol.TCompactProtocol(
7031                                                new org.apache.thrift7.transport.TIOStreamTransport(in)));
7032                        } catch (final org.apache.thrift7.TException te) {
7033                                throw new java.io.IOException(te);
7034                        }
7035                }
7036
7037        }
7038
7039        public static class get_version_result
7040                        implements
7041                                org.apache.thrift7.TBase<get_version_result, get_version_result._Fields>,
7042                                java.io.Serializable,
7043                                Cloneable
7044        {
7045                private static final org.apache.thrift7.protocol.TStruct STRUCT_DESC = new org.apache.thrift7.protocol.TStruct(
7046                                "get_version_result");
7047
7048                private static final org.apache.thrift7.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift7.protocol.TField(
7049                                "success", org.apache.thrift7.protocol.TType.STRING, (short) 0);
7050
7051                private String success; // required
7052
7053                /**
7054                 * The set of fields this struct contains, along with convenience
7055                 * methods for finding and manipulating them.
7056                 */
7057                public enum _Fields implements org.apache.thrift7.TFieldIdEnum {
7058                        SUCCESS((short) 0, "success");
7059
7060                        private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
7061
7062                        static {
7063                                for (final _Fields field : EnumSet.allOf(_Fields.class)) {
7064                                        byName.put(field.getFieldName(), field);
7065                                }
7066                        }
7067
7068                        /**
7069                         * Find the _Fields constant that matches fieldId, or null if its
7070                         * not found.
7071                         */
7072                        public static _Fields findByThriftId(int fieldId) {
7073                                switch (fieldId) {
7074                                case 0: // SUCCESS
7075                                        return SUCCESS;
7076                                default:
7077                                        return null;
7078                                }
7079                        }
7080
7081                        /**
7082                         * Find the _Fields constant that matches fieldId, throwing an
7083                         * exception if it is not found.
7084                         */
7085                        public static _Fields findByThriftIdOrThrow(int fieldId) {
7086                                final _Fields fields = findByThriftId(fieldId);
7087                                if (fields == null)
7088                                        throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
7089                                return fields;
7090                        }
7091
7092                        /**
7093                         * Find the _Fields constant that matches name, or null if its not
7094                         * found.
7095                         */
7096                        public static _Fields findByName(String name) {
7097                                return byName.get(name);
7098                        }
7099
7100                        private final short _thriftId;
7101                        private final String _fieldName;
7102
7103                        _Fields(short thriftId, String fieldName) {
7104                                _thriftId = thriftId;
7105                                _fieldName = fieldName;
7106                        }
7107
7108                        @Override
7109                        public short getThriftFieldId() {
7110                                return _thriftId;
7111                        }
7112
7113                        @Override
7114                        public String getFieldName() {
7115                                return _fieldName;
7116                        }
7117                }
7118
7119                // isset id assignments
7120
7121                public static final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> metaDataMap;
7122                static {
7123                        final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift7.meta_data.FieldMetaData>(
7124                                        _Fields.class);
7125                        tmpMap.put(_Fields.SUCCESS, new org.apache.thrift7.meta_data.FieldMetaData("success",
7126                                        org.apache.thrift7.TFieldRequirementType.DEFAULT,
7127                                        new org.apache.thrift7.meta_data.FieldValueMetaData(org.apache.thrift7.protocol.TType.STRING)));
7128                        metaDataMap = Collections.unmodifiableMap(tmpMap);
7129                        org.apache.thrift7.meta_data.FieldMetaData.addStructMetaDataMap(get_version_result.class, metaDataMap);
7130                }
7131
7132                public get_version_result() {
7133                }
7134
7135                public get_version_result(
7136                                String success)
7137                {
7138                        this();
7139                        this.success = success;
7140                }
7141
7142                /**
7143                 * Performs a deep copy on <i>other</i>.
7144                 */
7145                public get_version_result(get_version_result other) {
7146                        if (other.is_set_success()) {
7147                                this.success = other.success;
7148                        }
7149                }
7150
7151                @Override
7152                public get_version_result deepCopy() {
7153                        return new get_version_result(this);
7154                }
7155
7156                @Override
7157                public void clear() {
7158                        this.success = null;
7159                }
7160
7161                public String get_success() {
7162                        return this.success;
7163                }
7164
7165                public void set_success(String success) {
7166                        this.success = success;
7167                }
7168
7169                public void unset_success() {
7170                        this.success = null;
7171                }
7172
7173                /**
7174                 * Returns true if field success is set (has been assigned a value) and
7175                 * false otherwise
7176                 */
7177                public boolean is_set_success() {
7178                        return this.success != null;
7179                }
7180
7181                public void set_success_isSet(boolean value) {
7182                        if (!value) {
7183                                this.success = null;
7184                        }
7185                }
7186
7187                @Override
7188                public void setFieldValue(_Fields field, Object value) {
7189                        switch (field) {
7190                        case SUCCESS:
7191                                if (value == null) {
7192                                        unset_success();
7193                                } else {
7194                                        set_success((String) value);
7195                                }
7196                                break;
7197
7198                        }
7199                }
7200
7201                @Override
7202                public Object getFieldValue(_Fields field) {
7203                        switch (field) {
7204                        case SUCCESS:
7205                                return get_success();
7206
7207                        }
7208                        throw new IllegalStateException();
7209                }
7210
7211                /**
7212                 * Returns true if field corresponding to fieldID is set (has been
7213                 * assigned a value) and false otherwise
7214                 */
7215                @Override
7216                public boolean isSet(_Fields field) {
7217                        if (field == null) {
7218                                throw new IllegalArgumentException();
7219                        }
7220
7221                        switch (field) {
7222                        case SUCCESS:
7223                                return is_set_success();
7224                        }
7225                        throw new IllegalStateException();
7226                }
7227
7228                @Override
7229                public boolean equals(Object that) {
7230                        if (that == null)
7231                                return false;
7232                        if (that instanceof get_version_result)
7233                                return this.equals((get_version_result) that);
7234                        return false;
7235                }
7236
7237                public boolean equals(get_version_result that) {
7238                        if (that == null)
7239                                return false;
7240
7241                        final boolean this_present_success = true && this.is_set_success();
7242                        final boolean that_present_success = true && that.is_set_success();
7243                        if (this_present_success || that_present_success) {
7244                                if (!(this_present_success && that_present_success))
7245                                        return false;
7246                                if (!this.success.equals(that.success))
7247                                        return false;
7248                        }
7249
7250                        return true;
7251                }
7252
7253                @Override
7254                public int hashCode() {
7255                        final HashCodeBuilder builder = new HashCodeBuilder();
7256
7257                        final boolean present_success = true && (is_set_success());
7258                        builder.append(present_success);
7259                        if (present_success)
7260                                builder.append(success);
7261
7262                        return builder.toHashCode();
7263                }
7264
7265                @Override
7266                public int compareTo(get_version_result other) {
7267                        if (!getClass().equals(other.getClass())) {
7268                                return getClass().getName().compareTo(other.getClass().getName());
7269                        }
7270
7271                        int lastComparison = 0;
7272                        final get_version_result typedOther = other;
7273
7274                        lastComparison = Boolean.valueOf(is_set_success()).compareTo(typedOther.is_set_success());
7275                        if (lastComparison != 0) {
7276                                return lastComparison;
7277                        }
7278                        if (is_set_success()) {
7279                                lastComparison = org.apache.thrift7.TBaseHelper.compareTo(this.success, typedOther.success);
7280                                if (lastComparison != 0) {
7281                                        return lastComparison;
7282                                }
7283                        }
7284                        return 0;
7285                }
7286
7287                @Override
7288                public _Fields fieldForId(int fieldId) {
7289                        return _Fields.findByThriftId(fieldId);
7290                }
7291
7292                @Override
7293                public void read(org.apache.thrift7.protocol.TProtocol iprot) throws org.apache.thrift7.TException {
7294                        org.apache.thrift7.protocol.TField field;
7295                        iprot.readStructBegin();
7296                        while (true)
7297                        {
7298                                field = iprot.readFieldBegin();
7299                                if (field.type == org.apache.thrift7.protocol.TType.STOP) {
7300                                        break;
7301                                }
7302                                switch (field.id) {
7303                                case 0: // SUCCESS
7304                                        if (field.type == org.apache.thrift7.protocol.TType.STRING) {
7305                                                this.success = iprot.readString();
7306                                        } else {
7307                                                org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
7308                                        }
7309                                        break;
7310                                default:
7311                                        org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
7312                                }
7313                                iprot.readFieldEnd();
7314                        }
7315                        iprot.readStructEnd();
7316                        validate();
7317                }
7318
7319                @Override
7320                public void write(org.apache.thrift7.protocol.TProtocol oprot) throws org.apache.thrift7.TException {
7321                        oprot.writeStructBegin(STRUCT_DESC);
7322
7323                        if (this.is_set_success()) {
7324                                oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
7325                                oprot.writeString(this.success);
7326                                oprot.writeFieldEnd();
7327                        }
7328                        oprot.writeFieldStop();
7329                        oprot.writeStructEnd();
7330                }
7331
7332                @Override
7333                public String toString() {
7334                        final StringBuilder sb = new StringBuilder("get_version_result(");
7335                        boolean first = true;
7336
7337                        sb.append("success:");
7338                        if (this.success == null) {
7339                                sb.append("null");
7340                        } else {
7341                                sb.append(this.success);
7342                        }
7343                        first = false;
7344                        sb.append(")");
7345                        return sb.toString();
7346                }
7347
7348                public void validate() throws org.apache.thrift7.TException {
7349                        // check for required fields
7350                }
7351
7352                private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
7353                        try {
7354                                write(new org.apache.thrift7.protocol.TCompactProtocol(
7355                                                new org.apache.thrift7.transport.TIOStreamTransport(out)));
7356                        } catch (final org.apache.thrift7.TException te) {
7357                                throw new java.io.IOException(te);
7358                        }
7359                }
7360
7361                private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
7362                        try {
7363                                read(new org.apache.thrift7.protocol.TCompactProtocol(
7364                                                new org.apache.thrift7.transport.TIOStreamTransport(in)));
7365                        } catch (final org.apache.thrift7.TException te) {
7366                                throw new java.io.IOException(te);
7367                        }
7368                }
7369
7370        }
7371
7372}