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}