http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/488b772f/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/AuroraSchedulerManager.java ---------------------------------------------------------------------- diff --git a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/AuroraSchedulerManager.java b/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/AuroraSchedulerManager.java deleted file mode 100644 index 710f681..0000000 --- a/modules/cloud/aurora-client/src/main/java/org/apache/airavata/cloud/aurora/client/sdk/AuroraSchedulerManager.java +++ /dev/null @@ -1,13414 +0,0 @@ -/** - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -/** - * Autogenerated by Thrift Compiler (0.9.3) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -package org.apache.airavata.cloud.aurora.client.sdk; - -import org.apache.thrift.scheme.IScheme; -import org.apache.thrift.scheme.SchemeFactory; -import org.apache.thrift.scheme.StandardScheme; - -import org.apache.thrift.scheme.TupleScheme; -import org.apache.thrift.protocol.TTupleProtocol; -import org.apache.thrift.protocol.TProtocolException; -import org.apache.thrift.EncodingUtils; -import org.apache.thrift.TException; -import org.apache.thrift.async.AsyncMethodCallback; -import org.apache.thrift.server.AbstractNonblockingServer.*; -import java.util.List; -import java.util.ArrayList; -import java.util.Map; -import java.util.HashMap; -import java.util.EnumMap; -import java.util.Set; -import java.util.HashSet; -import java.util.EnumSet; -import java.util.Collections; -import java.util.BitSet; -import java.nio.ByteBuffer; -import java.util.Arrays; -import javax.annotation.Generated; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-10-21") -public class AuroraSchedulerManager { - - public interface Iface extends ReadOnlyScheduler.Iface { - - /** - * Creates a new job. The request will be denied if a job with the provided name already exists - * in the cluster. - * - * @param description - */ - public Response createJob(JobConfiguration description) throws org.apache.thrift.TException; - - /** - * Enters a job into the cron schedule, without actually starting the job. - * If the job is already present in the schedule, this will update the schedule entry with the new - * configuration. - * - * @param description - */ - public Response scheduleCronJob(JobConfiguration description) throws org.apache.thrift.TException; - - /** - * Removes a job from the cron schedule. The request will be denied if the job was not previously - * scheduled with scheduleCronJob. - * - * @param job - */ - public Response descheduleCronJob(JobKey job) throws org.apache.thrift.TException; - - /** - * Starts a cron job immediately. The request will be denied if the specified job does not - * exist for the role account, or the job is not a cron job. - * - * @param job - */ - public Response startCronJob(JobKey job) throws org.apache.thrift.TException; - - /** - * Restarts a batch of shards. - * - * @param job - * @param shardIds - */ - public Response restartShards(JobKey job, Set<Integer> shardIds) throws org.apache.thrift.TException; - - /** - * Initiates a kill on tasks. - * - * @param job - * @param instances - */ - public Response killTasks(JobKey job, Set<Integer> instances) throws org.apache.thrift.TException; - - /** - * Adds new instances with the TaskConfig of the existing instance pointed by the key. - * - * @param key - * @param count - */ - public Response addInstances(InstanceKey key, int count) throws org.apache.thrift.TException; - - /** - * Replaces the template (configuration) for the existing cron job. - * The cron job template (configuration) must exist for the call to succeed. - * - * @param config - */ - public Response replaceCronTemplate(JobConfiguration config) throws org.apache.thrift.TException; - - /** - * Starts update of the existing service job. - * - * @param request A description of how to change the job. - * - * @param message A user-specified message to include with the induced job update state change. - */ - public Response startJobUpdate(JobUpdateRequest request, String message) throws org.apache.thrift.TException; - - /** - * Pauses the specified job update. Can be resumed by resumeUpdate call. - * - * @param key The update to pause. - * - * @param message A user-specified message to include with the induced job update state change. - */ - public Response pauseJobUpdate(JobUpdateKey key, String message) throws org.apache.thrift.TException; - - /** - * Resumes progress of a previously paused job update. - * - * @param key The update to resume. - * - * @param message A user-specified message to include with the induced job update state change. - */ - public Response resumeJobUpdate(JobUpdateKey key, String message) throws org.apache.thrift.TException; - - /** - * Permanently aborts the job update. Does not remove the update history. - * - * @param key The update to abort. - * - * @param message A user-specified message to include with the induced job update state change. - */ - public Response abortJobUpdate(JobUpdateKey key, String message) throws org.apache.thrift.TException; - - /** - * Rollbacks the specified active job update to the initial state. - * - * @param key The update to rollback. - * - * @param message A user-specified message to include with the induced job update state change. - */ - public Response rollbackJobUpdate(JobUpdateKey key, String message) throws org.apache.thrift.TException; - - /** - * Allows progress of the job update in case blockIfNoPulsesAfterMs is specified in - * JobUpdateSettings. Unblocks progress if the update was previously blocked. - * Responds with ResponseCode.INVALID_REQUEST in case an unknown update key is specified. - * - * @param key - */ - public Response pulseJobUpdate(JobUpdateKey key) throws org.apache.thrift.TException; - - } - - public interface AsyncIface extends ReadOnlyScheduler .AsyncIface { - - public void createJob(JobConfiguration description, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void scheduleCronJob(JobConfiguration description, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void descheduleCronJob(JobKey job, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void startCronJob(JobKey job, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void restartShards(JobKey job, Set<Integer> shardIds, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void killTasks(JobKey job, Set<Integer> instances, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void addInstances(InstanceKey key, int count, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void replaceCronTemplate(JobConfiguration config, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void startJobUpdate(JobUpdateRequest request, String message, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void pauseJobUpdate(JobUpdateKey key, String message, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void resumeJobUpdate(JobUpdateKey key, String message, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void abortJobUpdate(JobUpdateKey key, String message, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void rollbackJobUpdate(JobUpdateKey key, String message, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void pulseJobUpdate(JobUpdateKey key, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - } - - public static class Client extends ReadOnlyScheduler.Client implements Iface { - public static class Factory implements org.apache.thrift.TServiceClientFactory<Client> { - public Factory() {} - public Client getClient(org.apache.thrift.protocol.TProtocol prot) { - return new Client(prot); - } - public Client getClient(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) { - return new Client(iprot, oprot); - } - } - - public Client(org.apache.thrift.protocol.TProtocol prot) - { - super(prot, prot); - } - - public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) { - super(iprot, oprot); - } - - public Response createJob(JobConfiguration description) throws org.apache.thrift.TException - { - send_createJob(description); - return recv_createJob(); - } - - public void send_createJob(JobConfiguration description) throws org.apache.thrift.TException - { - createJob_args args = new createJob_args(); - args.setDescription(description); - sendBase("createJob", args); - } - - public Response recv_createJob() throws org.apache.thrift.TException - { - createJob_result result = new createJob_result(); - receiveBase(result, "createJob"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "createJob failed: unknown result"); - } - - public Response scheduleCronJob(JobConfiguration description) throws org.apache.thrift.TException - { - send_scheduleCronJob(description); - return recv_scheduleCronJob(); - } - - public void send_scheduleCronJob(JobConfiguration description) throws org.apache.thrift.TException - { - scheduleCronJob_args args = new scheduleCronJob_args(); - args.setDescription(description); - sendBase("scheduleCronJob", args); - } - - public Response recv_scheduleCronJob() throws org.apache.thrift.TException - { - scheduleCronJob_result result = new scheduleCronJob_result(); - receiveBase(result, "scheduleCronJob"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "scheduleCronJob failed: unknown result"); - } - - public Response descheduleCronJob(JobKey job) throws org.apache.thrift.TException - { - send_descheduleCronJob(job); - return recv_descheduleCronJob(); - } - - public void send_descheduleCronJob(JobKey job) throws org.apache.thrift.TException - { - descheduleCronJob_args args = new descheduleCronJob_args(); - args.setJob(job); - sendBase("descheduleCronJob", args); - } - - public Response recv_descheduleCronJob() throws org.apache.thrift.TException - { - descheduleCronJob_result result = new descheduleCronJob_result(); - receiveBase(result, "descheduleCronJob"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "descheduleCronJob failed: unknown result"); - } - - public Response startCronJob(JobKey job) throws org.apache.thrift.TException - { - send_startCronJob(job); - return recv_startCronJob(); - } - - public void send_startCronJob(JobKey job) throws org.apache.thrift.TException - { - startCronJob_args args = new startCronJob_args(); - args.setJob(job); - sendBase("startCronJob", args); - } - - public Response recv_startCronJob() throws org.apache.thrift.TException - { - startCronJob_result result = new startCronJob_result(); - receiveBase(result, "startCronJob"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "startCronJob failed: unknown result"); - } - - public Response restartShards(JobKey job, Set<Integer> shardIds) throws org.apache.thrift.TException - { - send_restartShards(job, shardIds); - return recv_restartShards(); - } - - public void send_restartShards(JobKey job, Set<Integer> shardIds) throws org.apache.thrift.TException - { - restartShards_args args = new restartShards_args(); - args.setJob(job); - args.setShardIds(shardIds); - sendBase("restartShards", args); - } - - public Response recv_restartShards() throws org.apache.thrift.TException - { - restartShards_result result = new restartShards_result(); - receiveBase(result, "restartShards"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "restartShards failed: unknown result"); - } - - public Response killTasks(JobKey job, Set<Integer> instances) throws org.apache.thrift.TException - { - send_killTasks(job, instances); - return recv_killTasks(); - } - - public void send_killTasks(JobKey job, Set<Integer> instances) throws org.apache.thrift.TException - { - killTasks_args args = new killTasks_args(); - args.setJob(job); - args.setInstances(instances); - sendBase("killTasks", args); - } - - public Response recv_killTasks() throws org.apache.thrift.TException - { - killTasks_result result = new killTasks_result(); - receiveBase(result, "killTasks"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "killTasks failed: unknown result"); - } - - public Response addInstances(InstanceKey key, int count) throws org.apache.thrift.TException - { - send_addInstances(key, count); - return recv_addInstances(); - } - - public void send_addInstances(InstanceKey key, int count) throws org.apache.thrift.TException - { - addInstances_args args = new addInstances_args(); - args.setKey(key); - args.setCount(count); - sendBase("addInstances", args); - } - - public Response recv_addInstances() throws org.apache.thrift.TException - { - addInstances_result result = new addInstances_result(); - receiveBase(result, "addInstances"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "addInstances failed: unknown result"); - } - - public Response replaceCronTemplate(JobConfiguration config) throws org.apache.thrift.TException - { - send_replaceCronTemplate(config); - return recv_replaceCronTemplate(); - } - - public void send_replaceCronTemplate(JobConfiguration config) throws org.apache.thrift.TException - { - replaceCronTemplate_args args = new replaceCronTemplate_args(); - args.setConfig(config); - sendBase("replaceCronTemplate", args); - } - - public Response recv_replaceCronTemplate() throws org.apache.thrift.TException - { - replaceCronTemplate_result result = new replaceCronTemplate_result(); - receiveBase(result, "replaceCronTemplate"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "replaceCronTemplate failed: unknown result"); - } - - public Response startJobUpdate(JobUpdateRequest request, String message) throws org.apache.thrift.TException - { - send_startJobUpdate(request, message); - return recv_startJobUpdate(); - } - - public void send_startJobUpdate(JobUpdateRequest request, String message) throws org.apache.thrift.TException - { - startJobUpdate_args args = new startJobUpdate_args(); - args.setRequest(request); - args.setMessage(message); - sendBase("startJobUpdate", args); - } - - public Response recv_startJobUpdate() throws org.apache.thrift.TException - { - startJobUpdate_result result = new startJobUpdate_result(); - receiveBase(result, "startJobUpdate"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "startJobUpdate failed: unknown result"); - } - - public Response pauseJobUpdate(JobUpdateKey key, String message) throws org.apache.thrift.TException - { - send_pauseJobUpdate(key, message); - return recv_pauseJobUpdate(); - } - - public void send_pauseJobUpdate(JobUpdateKey key, String message) throws org.apache.thrift.TException - { - pauseJobUpdate_args args = new pauseJobUpdate_args(); - args.setKey(key); - args.setMessage(message); - sendBase("pauseJobUpdate", args); - } - - public Response recv_pauseJobUpdate() throws org.apache.thrift.TException - { - pauseJobUpdate_result result = new pauseJobUpdate_result(); - receiveBase(result, "pauseJobUpdate"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "pauseJobUpdate failed: unknown result"); - } - - public Response resumeJobUpdate(JobUpdateKey key, String message) throws org.apache.thrift.TException - { - send_resumeJobUpdate(key, message); - return recv_resumeJobUpdate(); - } - - public void send_resumeJobUpdate(JobUpdateKey key, String message) throws org.apache.thrift.TException - { - resumeJobUpdate_args args = new resumeJobUpdate_args(); - args.setKey(key); - args.setMessage(message); - sendBase("resumeJobUpdate", args); - } - - public Response recv_resumeJobUpdate() throws org.apache.thrift.TException - { - resumeJobUpdate_result result = new resumeJobUpdate_result(); - receiveBase(result, "resumeJobUpdate"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "resumeJobUpdate failed: unknown result"); - } - - public Response abortJobUpdate(JobUpdateKey key, String message) throws org.apache.thrift.TException - { - send_abortJobUpdate(key, message); - return recv_abortJobUpdate(); - } - - public void send_abortJobUpdate(JobUpdateKey key, String message) throws org.apache.thrift.TException - { - abortJobUpdate_args args = new abortJobUpdate_args(); - args.setKey(key); - args.setMessage(message); - sendBase("abortJobUpdate", args); - } - - public Response recv_abortJobUpdate() throws org.apache.thrift.TException - { - abortJobUpdate_result result = new abortJobUpdate_result(); - receiveBase(result, "abortJobUpdate"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "abortJobUpdate failed: unknown result"); - } - - public Response rollbackJobUpdate(JobUpdateKey key, String message) throws org.apache.thrift.TException - { - send_rollbackJobUpdate(key, message); - return recv_rollbackJobUpdate(); - } - - public void send_rollbackJobUpdate(JobUpdateKey key, String message) throws org.apache.thrift.TException - { - rollbackJobUpdate_args args = new rollbackJobUpdate_args(); - args.setKey(key); - args.setMessage(message); - sendBase("rollbackJobUpdate", args); - } - - public Response recv_rollbackJobUpdate() throws org.apache.thrift.TException - { - rollbackJobUpdate_result result = new rollbackJobUpdate_result(); - receiveBase(result, "rollbackJobUpdate"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "rollbackJobUpdate failed: unknown result"); - } - - public Response pulseJobUpdate(JobUpdateKey key) throws org.apache.thrift.TException - { - send_pulseJobUpdate(key); - return recv_pulseJobUpdate(); - } - - public void send_pulseJobUpdate(JobUpdateKey key) throws org.apache.thrift.TException - { - pulseJobUpdate_args args = new pulseJobUpdate_args(); - args.setKey(key); - sendBase("pulseJobUpdate", args); - } - - public Response recv_pulseJobUpdate() throws org.apache.thrift.TException - { - pulseJobUpdate_result result = new pulseJobUpdate_result(); - receiveBase(result, "pulseJobUpdate"); - if (result.isSetSuccess()) { - return result.success; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "pulseJobUpdate failed: unknown result"); - } - - } - public static class AsyncClient extends ReadOnlyScheduler.AsyncClient implements AsyncIface { - public static class Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> { - private org.apache.thrift.async.TAsyncClientManager clientManager; - private org.apache.thrift.protocol.TProtocolFactory protocolFactory; - public Factory(org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.protocol.TProtocolFactory protocolFactory) { - this.clientManager = clientManager; - this.protocolFactory = protocolFactory; - } - public AsyncClient getAsyncClient(org.apache.thrift.transport.TNonblockingTransport transport) { - return new AsyncClient(protocolFactory, clientManager, transport); - } - } - - public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport) { - super(protocolFactory, clientManager, transport); - } - - public void createJob(JobConfiguration description, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - createJob_call method_call = new createJob_call(description, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class createJob_call extends org.apache.thrift.async.TAsyncMethodCall { - private JobConfiguration description; - public createJob_call(JobConfiguration description, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.description = description; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("createJob", org.apache.thrift.protocol.TMessageType.CALL, 0)); - createJob_args args = new createJob_args(); - args.setDescription(description); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_createJob(); - } - } - - public void scheduleCronJob(JobConfiguration description, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - scheduleCronJob_call method_call = new scheduleCronJob_call(description, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class scheduleCronJob_call extends org.apache.thrift.async.TAsyncMethodCall { - private JobConfiguration description; - public scheduleCronJob_call(JobConfiguration description, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.description = description; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("scheduleCronJob", org.apache.thrift.protocol.TMessageType.CALL, 0)); - scheduleCronJob_args args = new scheduleCronJob_args(); - args.setDescription(description); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_scheduleCronJob(); - } - } - - public void descheduleCronJob(JobKey job, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - descheduleCronJob_call method_call = new descheduleCronJob_call(job, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class descheduleCronJob_call extends org.apache.thrift.async.TAsyncMethodCall { - private JobKey job; - public descheduleCronJob_call(JobKey job, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.job = job; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("descheduleCronJob", org.apache.thrift.protocol.TMessageType.CALL, 0)); - descheduleCronJob_args args = new descheduleCronJob_args(); - args.setJob(job); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_descheduleCronJob(); - } - } - - public void startCronJob(JobKey job, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - startCronJob_call method_call = new startCronJob_call(job, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class startCronJob_call extends org.apache.thrift.async.TAsyncMethodCall { - private JobKey job; - public startCronJob_call(JobKey job, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.job = job; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("startCronJob", org.apache.thrift.protocol.TMessageType.CALL, 0)); - startCronJob_args args = new startCronJob_args(); - args.setJob(job); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_startCronJob(); - } - } - - public void restartShards(JobKey job, Set<Integer> shardIds, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - restartShards_call method_call = new restartShards_call(job, shardIds, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class restartShards_call extends org.apache.thrift.async.TAsyncMethodCall { - private JobKey job; - private Set<Integer> shardIds; - public restartShards_call(JobKey job, Set<Integer> shardIds, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.job = job; - this.shardIds = shardIds; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("restartShards", org.apache.thrift.protocol.TMessageType.CALL, 0)); - restartShards_args args = new restartShards_args(); - args.setJob(job); - args.setShardIds(shardIds); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_restartShards(); - } - } - - public void killTasks(JobKey job, Set<Integer> instances, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - killTasks_call method_call = new killTasks_call(job, instances, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class killTasks_call extends org.apache.thrift.async.TAsyncMethodCall { - private JobKey job; - private Set<Integer> instances; - public killTasks_call(JobKey job, Set<Integer> instances, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.job = job; - this.instances = instances; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("killTasks", org.apache.thrift.protocol.TMessageType.CALL, 0)); - killTasks_args args = new killTasks_args(); - args.setJob(job); - args.setInstances(instances); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_killTasks(); - } - } - - public void addInstances(InstanceKey key, int count, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - addInstances_call method_call = new addInstances_call(key, count, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class addInstances_call extends org.apache.thrift.async.TAsyncMethodCall { - private InstanceKey key; - private int count; - public addInstances_call(InstanceKey key, int count, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.key = key; - this.count = count; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("addInstances", org.apache.thrift.protocol.TMessageType.CALL, 0)); - addInstances_args args = new addInstances_args(); - args.setKey(key); - args.setCount(count); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_addInstances(); - } - } - - public void replaceCronTemplate(JobConfiguration config, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - replaceCronTemplate_call method_call = new replaceCronTemplate_call(config, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class replaceCronTemplate_call extends org.apache.thrift.async.TAsyncMethodCall { - private JobConfiguration config; - public replaceCronTemplate_call(JobConfiguration config, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.config = config; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("replaceCronTemplate", org.apache.thrift.protocol.TMessageType.CALL, 0)); - replaceCronTemplate_args args = new replaceCronTemplate_args(); - args.setConfig(config); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_replaceCronTemplate(); - } - } - - public void startJobUpdate(JobUpdateRequest request, String message, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - startJobUpdate_call method_call = new startJobUpdate_call(request, message, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class startJobUpdate_call extends org.apache.thrift.async.TAsyncMethodCall { - private JobUpdateRequest request; - private String message; - public startJobUpdate_call(JobUpdateRequest request, String message, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.request = request; - this.message = message; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("startJobUpdate", org.apache.thrift.protocol.TMessageType.CALL, 0)); - startJobUpdate_args args = new startJobUpdate_args(); - args.setRequest(request); - args.setMessage(message); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_startJobUpdate(); - } - } - - public void pauseJobUpdate(JobUpdateKey key, String message, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - pauseJobUpdate_call method_call = new pauseJobUpdate_call(key, message, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class pauseJobUpdate_call extends org.apache.thrift.async.TAsyncMethodCall { - private JobUpdateKey key; - private String message; - public pauseJobUpdate_call(JobUpdateKey key, String message, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.key = key; - this.message = message; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("pauseJobUpdate", org.apache.thrift.protocol.TMessageType.CALL, 0)); - pauseJobUpdate_args args = new pauseJobUpdate_args(); - args.setKey(key); - args.setMessage(message); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_pauseJobUpdate(); - } - } - - public void resumeJobUpdate(JobUpdateKey key, String message, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - resumeJobUpdate_call method_call = new resumeJobUpdate_call(key, message, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class resumeJobUpdate_call extends org.apache.thrift.async.TAsyncMethodCall { - private JobUpdateKey key; - private String message; - public resumeJobUpdate_call(JobUpdateKey key, String message, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.key = key; - this.message = message; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("resumeJobUpdate", org.apache.thrift.protocol.TMessageType.CALL, 0)); - resumeJobUpdate_args args = new resumeJobUpdate_args(); - args.setKey(key); - args.setMessage(message); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_resumeJobUpdate(); - } - } - - public void abortJobUpdate(JobUpdateKey key, String message, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - abortJobUpdate_call method_call = new abortJobUpdate_call(key, message, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class abortJobUpdate_call extends org.apache.thrift.async.TAsyncMethodCall { - private JobUpdateKey key; - private String message; - public abortJobUpdate_call(JobUpdateKey key, String message, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.key = key; - this.message = message; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("abortJobUpdate", org.apache.thrift.protocol.TMessageType.CALL, 0)); - abortJobUpdate_args args = new abortJobUpdate_args(); - args.setKey(key); - args.setMessage(message); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_abortJobUpdate(); - } - } - - public void rollbackJobUpdate(JobUpdateKey key, String message, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - rollbackJobUpdate_call method_call = new rollbackJobUpdate_call(key, message, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class rollbackJobUpdate_call extends org.apache.thrift.async.TAsyncMethodCall { - private JobUpdateKey key; - private String message; - public rollbackJobUpdate_call(JobUpdateKey key, String message, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.key = key; - this.message = message; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("rollbackJobUpdate", org.apache.thrift.protocol.TMessageType.CALL, 0)); - rollbackJobUpdate_args args = new rollbackJobUpdate_args(); - args.setKey(key); - args.setMessage(message); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_rollbackJobUpdate(); - } - } - - public void pulseJobUpdate(JobUpdateKey key, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - pulseJobUpdate_call method_call = new pulseJobUpdate_call(key, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class pulseJobUpdate_call extends org.apache.thrift.async.TAsyncMethodCall { - private JobUpdateKey key; - public pulseJobUpdate_call(JobUpdateKey key, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { - super(client, protocolFactory, transport, resultHandler, false); - this.key = key; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("pulseJobUpdate", org.apache.thrift.protocol.TMessageType.CALL, 0)); - pulseJobUpdate_args args = new pulseJobUpdate_args(); - args.setKey(key); - args.write(prot); - prot.writeMessageEnd(); - } - - public Response getResult() throws org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { - throw new IllegalStateException("Method call not finished!"); - } - org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); - org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); - return (new Client(prot)).recv_pulseJobUpdate(); - } - } - - } - - public static class Processor<I extends Iface> extends ReadOnlyScheduler.Processor<I> implements org.apache.thrift.TProcessor { - private static final Logger LOGGER = LoggerFactory.getLogger(Processor.class.getName()); - public Processor(I iface) { - super(iface, getProcessMap(new HashMap<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>())); - } - - protected Processor(I iface, Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) { - super(iface, getProcessMap(processMap)); - } - - private static <I extends Iface> Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> getProcessMap(Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) { - processMap.put("createJob", new createJob()); - processMap.put("scheduleCronJob", new scheduleCronJob()); - processMap.put("descheduleCronJob", new descheduleCronJob()); - processMap.put("startCronJob", new startCronJob()); - processMap.put("restartShards", new restartShards()); - processMap.put("killTasks", new killTasks()); - processMap.put("addInstances", new addInstances()); - processMap.put("replaceCronTemplate", new replaceCronTemplate()); - processMap.put("startJobUpdate", new startJobUpdate()); - processMap.put("pauseJobUpdate", new pauseJobUpdate()); - processMap.put("resumeJobUpdate", new resumeJobUpdate()); - processMap.put("abortJobUpdate", new abortJobUpdate()); - processMap.put("rollbackJobUpdate", new rollbackJobUpdate()); - processMap.put("pulseJobUpdate", new pulseJobUpdate()); - return processMap; - } - - public static class createJob<I extends Iface> extends org.apache.thrift.ProcessFunction<I, createJob_args> { - public createJob() { - super("createJob"); - } - - public createJob_args getEmptyArgsInstance() { - return new createJob_args(); - } - - protected boolean isOneway() { - return false; - } - - public createJob_result getResult(I iface, createJob_args args) throws org.apache.thrift.TException { - createJob_result result = new createJob_result(); - result.success = iface.createJob(args.description); - return result; - } - } - - public static class scheduleCronJob<I extends Iface> extends org.apache.thrift.ProcessFunction<I, scheduleCronJob_args> { - public scheduleCronJob() { - super("scheduleCronJob"); - } - - public scheduleCronJob_args getEmptyArgsInstance() { - return new scheduleCronJob_args(); - } - - protected boolean isOneway() { - return false; - } - - public scheduleCronJob_result getResult(I iface, scheduleCronJob_args args) throws org.apache.thrift.TException { - scheduleCronJob_result result = new scheduleCronJob_result(); - result.success = iface.scheduleCronJob(args.description); - return result; - } - } - - public static class descheduleCronJob<I extends Iface> extends org.apache.thrift.ProcessFunction<I, descheduleCronJob_args> { - public descheduleCronJob() { - super("descheduleCronJob"); - } - - public descheduleCronJob_args getEmptyArgsInstance() { - return new descheduleCronJob_args(); - } - - protected boolean isOneway() { - return false; - } - - public descheduleCronJob_result getResult(I iface, descheduleCronJob_args args) throws org.apache.thrift.TException { - descheduleCronJob_result result = new descheduleCronJob_result(); - result.success = iface.descheduleCronJob(args.job); - return result; - } - } - - public static class startCronJob<I extends Iface> extends org.apache.thrift.ProcessFunction<I, startCronJob_args> { - public startCronJob() { - super("startCronJob"); - } - - public startCronJob_args getEmptyArgsInstance() { - return new startCronJob_args(); - } - - protected boolean isOneway() { - return false; - } - - public startCronJob_result getResult(I iface, startCronJob_args args) throws org.apache.thrift.TException { - startCronJob_result result = new startCronJob_result(); - result.success = iface.startCronJob(args.job); - return result; - } - } - - public static class restartShards<I extends Iface> extends org.apache.thrift.ProcessFunction<I, restartShards_args> { - public restartShards() { - super("restartShards"); - } - - public restartShards_args getEmptyArgsInstance() { - return new restartShards_args(); - } - - protected boolean isOneway() { - return false; - } - - public restartShards_result getResult(I iface, restartShards_args args) throws org.apache.thrift.TException { - restartShards_result result = new restartShards_result(); - result.success = iface.restartShards(args.job, args.shardIds); - return result; - } - } - - public static class killTasks<I extends Iface> extends org.apache.thrift.ProcessFunction<I, killTasks_args> { - public killTasks() { - super("killTasks"); - } - - public killTasks_args getEmptyArgsInstance() { - return new killTasks_args(); - } - - protected boolean isOneway() { - return false; - } - - public killTasks_result getResult(I iface, killTasks_args args) throws org.apache.thrift.TException { - killTasks_result result = new killTasks_result(); - result.success = iface.killTasks(args.job, args.instances); - return result; - } - } - - public static class addInstances<I extends Iface> extends org.apache.thrift.ProcessFunction<I, addInstances_args> { - public addInstances() { - super("addInstances"); - } - - public addInstances_args getEmptyArgsInstance() { - return new addInstances_args(); - } - - protected boolean isOneway() { - return false; - } - - public addInstances_result getResult(I iface, addInstances_args args) throws org.apache.thrift.TException { - addInstances_result result = new addInstances_result(); - result.success = iface.addInstances(args.key, args.count); - return result; - } - } - - public static class replaceCronTemplate<I extends Iface> extends org.apache.thrift.ProcessFunction<I, replaceCronTemplate_args> { - public replaceCronTemplate() { - super("replaceCronTemplate"); - } - - public replaceCronTemplate_args getEmptyArgsInstance() { - return new replaceCronTemplate_args(); - } - - protected boolean isOneway() { - return false; - } - - public replaceCronTemplate_result getResult(I iface, replaceCronTemplate_args args) throws org.apache.thrift.TException { - replaceCronTemplate_result result = new replaceCronTemplate_result(); - result.success = iface.replaceCronTemplate(args.config); - return result; - } - } - - public static class startJobUpdate<I extends Iface> extends org.apache.thrift.ProcessFunction<I, startJobUpdate_args> { - public startJobUpdate() { - super("startJobUpdate"); - } - - public startJobUpdate_args getEmptyArgsInstance() { - return new startJobUpdate_args(); - } - - protected boolean isOneway() { - return false; - } - - public startJobUpdate_result getResult(I iface, startJobUpdate_args args) throws org.apache.thrift.TException { - startJobUpdate_result result = new startJobUpdate_result(); - result.success = iface.startJobUpdate(args.request, args.message); - return result; - } - } - - public static class pauseJobUpdate<I extends Iface> extends org.apache.thrift.ProcessFunction<I, pauseJobUpdate_args> { - public pauseJobUpdate() { - super("pauseJobUpdate"); - } - - public pauseJobUpdate_args getEmptyArgsInstance() { - return new pauseJobUpdate_args(); - } - - protected boolean isOneway() { - return false; - } - - public pauseJobUpdate_result getResult(I iface, pauseJobUpdate_args args) throws org.apache.thrift.TException { - pauseJobUpdate_result result = new pauseJobUpdate_result(); - result.success = iface.pauseJobUpdate(args.key, args.message); - return result; - } - } - - public static class resumeJobUpdate<I extends Iface> extends org.apache.thrift.ProcessFunction<I, resumeJobUpdate_args> { - public resumeJobUpdate() { - super("resumeJobUpdate"); - } - - public resumeJobUpdate_args getEmptyArgsInstance() { - return new resumeJobUpdate_args(); - } - - protected boolean isOneway() { - return false; - } - - public resumeJobUpdate_result getResult(I iface, resumeJobUpdate_args args) throws org.apache.thrift.TException { - resumeJobUpdate_result result = new resumeJobUpdate_result(); - result.success = iface.resumeJobUpdate(args.key, args.message); - return result; - } - } - - public static class abortJobUpdate<I extends Iface> extends org.apache.thrift.ProcessFunction<I, abortJobUpdate_args> { - public abortJobUpdate() { - super("abortJobUpdate"); - } - - public abortJobUpdate_args getEmptyArgsInstance() { - return new abortJobUpdate_args(); - } - - protected boolean isOneway() { - return false; - } - - public abortJobUpdate_result getResult(I iface, abortJobUpdate_args args) throws org.apache.thrift.TException { - abortJobUpdate_result result = new abortJobUpdate_result(); - result.success = iface.abortJobUpdate(args.key, args.message); - return result; - } - } - - public static class rollbackJobUpdate<I extends Iface> extends org.apache.thrift.ProcessFunction<I, rollbackJobUpdate_args> { - public rollbackJobUpdate() { - super("rollbackJobUpdate"); - } - - public rollbackJobUpdate_args getEmptyArgsInstance() { - return new rollbackJobUpdate_args(); - } - - protected boolean isOneway() { - return false; - } - - public rollbackJobUpdate_result getResult(I iface, rollbackJobUpdate_args args) throws org.apache.thrift.TException { - rollbackJobUpdate_result result = new rollbackJobUpdate_result(); - result.success = iface.rollbackJobUpdate(args.key, args.message); - return result; - } - } - - public static class pulseJobUpdate<I extends Iface> extends org.apache.thrift.ProcessFunction<I, pulseJobUpdate_args> { - public pulseJobUpdate() { - super("pulseJobUpdate"); - } - - public pulseJobUpdate_args getEmptyArgsInstance() { - return new pulseJobUpdate_args(); - } - - protected boolean isOneway() { - return false; - } - - public pulseJobUpdate_result getResult(I iface, pulseJobUpdate_args args) throws org.apache.thrift.TException { - pulseJobUpdate_result result = new pulseJobUpdate_result(); - result.success = iface.pulseJobUpdate(args.key); - return result; - } - } - - } - - public static class AsyncProcessor<I extends AsyncIface> extends ReadOnlyScheduler.AsyncProcessor<I> { - private static final Logger LOGGER = LoggerFactory.getLogger(AsyncProcessor.class.getName()); - public AsyncProcessor(I iface) { - super(iface, getProcessMap(new HashMap<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>>())); - } - - protected AsyncProcessor(I iface, Map<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>> processMap) { - super(iface, getProcessMap(processMap)); - } - - private static <I extends AsyncIface> Map<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase,?>> getProcessMap(Map<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>> processMap) { - processMap.put("createJob", new createJob()); - processMap.put("scheduleCronJob", new scheduleCronJob()); - processMap.put("descheduleCronJob", new descheduleCronJob()); - processMap.put("startCronJob", new startCronJob()); - processMap.put("restartShards", new restartShards()); - processMap.put("killTasks", new killTasks()); - processMap.put("addInstances", new addInstances()); - processMap.put("replaceCronTemplate", new replaceCronTemplate()); - processMap.put("startJobUpdate", new startJobUpdate()); - processMap.put("pauseJobUpdate", new pauseJobUpdate()); - processMap.put("resumeJobUpdate", new resumeJobUpdate()); - processMap.put("abortJobUpdate", new abortJobUpdate()); - processMap.put("rollbackJobUpdate", new rollbackJobUpdate()); - processMap.put("pulseJobUpdate", new pulseJobUpdate()); - return processMap; - } - - public static class createJob<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, createJob_args, Response> { - public createJob() { - super("createJob"); - } - - public createJob_args getEmptyArgsInstance() { - return new createJob_args(); - } - - public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Response>() { - public void onComplete(Response o) { - createJob_result result = new createJob_result(); - result.success = o; - try { - fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); - return; - } catch (Exception e) { - LOGGER.error("Exception writing to internal frame buffer", e); - } - fb.close(); - } - public void onError(Exception e) { - byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; - org.apache.thrift.TBase msg; - createJob_result result = new createJob_result(); - { - msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; - msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); - } - try { - fcall.sendResponse(fb,msg,msgType,seqid); - return; - } catch (Exception ex) { - LOGGER.error("Exception writing to internal frame buffer", ex); - } - fb.close(); - } - }; - } - - protected boolean isOneway() { - return false; - } - - public void start(I iface, createJob_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { - iface.createJob(args.description,resultHandler); - } - } - - public static class scheduleCronJob<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, scheduleCronJob_args, Response> { - public scheduleCronJob() { - super("scheduleCronJob"); - } - - public scheduleCronJob_args getEmptyArgsInstance() { - return new scheduleCronJob_args(); - } - - public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Response>() { - public void onComplete(Response o) { - scheduleCronJob_result result = new scheduleCronJob_result(); - result.success = o; - try { - fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); - return; - } catch (Exception e) { - LOGGER.error("Exception writing to internal frame buffer", e); - } - fb.close(); - } - public void onError(Exception e) { - byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; - org.apache.thrift.TBase msg; - scheduleCronJob_result result = new scheduleCronJob_result(); - { - msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; - msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); - } - try { - fcall.sendResponse(fb,msg,msgType,seqid); - return; - } catch (Exception ex) { - LOGGER.error("Exception writing to internal frame buffer", ex); - } - fb.close(); - } - }; - } - - protected boolean isOneway() { - return false; - } - - public void start(I iface, scheduleCronJob_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { - iface.scheduleCronJob(args.description,resultHandler); - } - } - - public static class descheduleCronJob<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, descheduleCronJob_args, Response> { - public descheduleCronJob() { - super("descheduleCronJob"); - } - - public descheduleCronJob_args getEmptyArgsInstance() { - return new descheduleCronJob_args(); - } - - public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Response>() { - public void onComplete(Response o) { - descheduleCronJob_result result = new descheduleCronJob_result(); - result.success = o; - try { - fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); - return; - } catch (Exception e) { - LOGGER.error("Exception writing to internal frame buffer", e); - } - fb.close(); - } - public void onError(Exception e) { - byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; - org.apache.thrift.TBase msg; - descheduleCronJob_result result = new descheduleCronJob_result(); - { - msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; - msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); - } - try { - fcall.sendResponse(fb,msg,msgType,seqid); - return; - } catch (Exception ex) { - LOGGER.error("Exception writing to internal frame buffer", ex); - } - fb.close(); - } - }; - } - - protected boolean isOneway() { - return false; - } - - public void start(I iface, descheduleCronJob_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { - iface.descheduleCronJob(args.job,resultHandler); - } - } - - public static class startCronJob<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, startCronJob_args, Response> { - public startCronJob() { - super("startCronJob"); - } - - public startCronJob_args getEmptyArgsInstance() { - return new startCronJob_args(); - } - - public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Response>() { - public void onComplete(Response o) { - startCronJob_result result = new startCronJob_result(); - result.success = o; - try { - fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); - return; - } catch (Exception e) { - LOGGER.error("Exception writing to internal frame buffer", e); - } - fb.close(); - } - public void onError(Exception e) { - byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; - org.apache.thrift.TBase msg; - startCronJob_result result = new startCronJob_result(); - { - msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; - msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); - } - try { - fcall.sendResponse(fb,msg,msgType,seqid); - return; - } catch (Exception ex) { - LOGGER.error("Exception writing to internal frame buffer", ex); - } - fb.close(); - } - }; - } - - protected boolean isOneway() { - return false; - } - - public void start(I iface, startCronJob_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { - iface.startCronJob(args.job,resultHandler); - } - } - - public static class restartShards<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, restartShards_args, Response> { - public restartShards() { - super("restartShards"); - } - - public restartShards_args getEmptyArgsInstance() { - return new restartShards_args(); - } - - public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Response>() { - public void onComplete(Response o) { - restartShards_result result = new restartShards_result(); - result.success = o; - try { - fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); - return; - } catch (Exception e) { - LOGGER.error("Exception writing to internal frame buffer", e); - } - fb.close(); - } - public void onError(Exception e) { - byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; - org.apache.thrift.TBase msg; - restartShards_result result = new restartShards_result(); - { - msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; - msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); - } - try { - fcall.sendResponse(fb,msg,msgType,seqid); - return; - } catch (Exception ex) { - LOGGER.error("Exception writing to internal frame buffer", ex); - } - fb.close(); - } - }; - } - - protected boolean isOneway() { - return false; - } - - public void start(I iface, restartShards_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { - iface.restartShards(args.job, args.shardIds,resultHandler); - } - } - - public static class killTasks<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, killTasks_args, Response> { - public killTasks() { - super("killTasks"); - } - - public killTasks_args getEmptyArgsInstance() { - return new killTasks_args(); - } - - public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Response>() { - public void onComplete(Response o) { - killTasks_result result = new killTasks_result(); - result.success = o; - try { - fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); - return; - } catch (Exception e) { - LOGGER.error("Exception writing to internal frame buffer", e); - } - fb.close(); - } - public void onError(Exception e) { - byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; - org.apache.thrift.TBase msg; - killTasks_result result = new killTasks_result(); - { - msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; - msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); - } - try { - fcall.sendResponse(fb,msg,msgType,seqid); - return; - } catch (Exception ex) { - LOGGER.error("Exception writing to internal frame buffer", ex); - } - fb.close(); - } - }; - } - - protected boolean isOneway() { - return false; - } - - public void start(I iface, killTasks_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { - iface.killTasks(args.job, args.instances,resultHandler); - } - } - - public static class addInstances<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addInstances_args, Response> { - public addInstances() { - super("addInstances"); - } - - public addInstances_args getEmptyArgsInstance() { - return new addInstances_args(); - } - - public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Response>() { - public void onComplete(Response o) { - addInstances_result result = new addInstances_result(); - result.success = o; - try { - fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); - return; - } catch (Exception e) { - LOGGER.error("Exception writing to internal frame buffer", e); - } - fb.close(); - } - public void onError(Exception e) { - byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; - org.apache.thrift.TBase msg; - addInstances_result result = new addInstances_result(); - { - msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; - msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); - } - try { - fcall.sendResponse(fb,msg,msgType,seqid); - return; - } catch (Exception ex) { - LOGGER.error("Exception writing to internal frame buffer", ex); - } - fb.close(); - } - }; - } - - protected boolean isOneway() { - return false; - } - - public void start(I iface, addInstances_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { - iface.addInstances(args.key, args.count,resultHandler); - } - } - - public static class replaceCronTemplate<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, replaceCronTemplate_args, Response> { - public replaceCronTemplate() { - super("replaceCronTemplate"); - } - - public replaceCronTemplate_args getEmptyArgsInstance() { - return new replaceCronTemplate_args(); - } - - public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Response>() { - public void onComplete(Response o) { - replaceCronTemplate_result result = new replaceCronTemplate_result(); - result.success = o; - try { - fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); - return; - } catch (Exception e) { - LOGGER.error("Exception writing to internal frame buffer", e); - } - fb.close(); - } - public void onError(Exception e) { - byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; - org.apache.thrift.TBase msg; - replaceCronTemplate_result result = new replaceCronTemplate_result(); - { - msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; - msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); - } - try { - fcall.sendResponse(fb,msg,msgType,seqid); - return; - } catch (Exception ex) { - LOGGER.error("Exception writing to internal frame buffer", ex); - } - fb.close(); - } - }; - } - - protected boolean isOneway() { - return false; - } - - public void start(I iface, replaceCronTemplate_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { - iface.replaceCronTemplate(args.config,resultHandler); - } - } - - public static class startJobUpdate<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, startJobUpdate_args, Response> { - public startJobUpdate() { - super("startJobUpdate"); - } - - public startJobUpdate_args getEmptyArgsInstance() { - return new startJobUpdate_args(); - } - - public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Response>() { - public void onComplete(Response o) { - startJobUpdate_result result = new startJobUpdate_result(); - result.success = o; - try { - fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); - return; - } catch (Exception e) { - LOGGER.error("Exception writing to internal frame buffer", e); - } - fb.close(); - } - public void onError(Exception e) { - byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; - org.apache.thrift.TBase msg; - startJobUpdate_result result = new startJobUpdate_result(); - { - msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; - msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); - } - try { - fcall.sendResponse(fb,msg,msgType,seqid); - return; - } catch (Exception ex) { - LOGGER.error("Exception writing to internal frame buffer", ex); - } - fb.close(); - } - }; - } - - protected boolean isOneway() { - return false; - } - - public void start(I iface, startJobUpdate_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { - iface.startJobUpdate(args.request, args.message,resultHandler); - } - } - - public static class pauseJobUpdate<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, pauseJobUpdate_args, Response> { - public pauseJobUpdate() { - super("pauseJobUpdate"); - } - - public pauseJobUpdate_args getEmptyArgsInstance() { - return new pauseJobUpdate_args(); - } - - public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Response>() { - public void onComplete(Response o) { - pauseJobUpdate_result result = new pauseJobUpdate_result(); - result.success = o; - try { - fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); - return; - } catch (Exception e) { - LOGGER.error("Exception writing to internal frame buffer", e); - } - fb.close(); - } - public void onError(Exception e) { - byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; - org.apache.thrift.TBase msg; - pauseJobUpdate_result result = new pauseJobUpdate_result(); - { - msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; - msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); - } - try { - fcall.sendResponse(fb,msg,msgType,seqid); - return; - } catch (Exception ex) { - LOGGER.error("Exception writing to internal frame buffer", ex); - } - fb.close(); - } - }; - } - - protected boolean isOneway() { - return false; - } - - public void start(I iface, pauseJobUpdate_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { - iface.pauseJobUpdate(args.key, args.message,resultHandler); - } - } - - public static class resumeJobUpdate<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, resumeJobUpdate_args, Response> { - public resumeJobUpdate() { - super("resumeJobUpdate"); - } - - public resumeJobUpdate_args getEmptyArgsInstance() { - return new resumeJobUpdate_args(); - } - - public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Response>() { - public void onComplete(Response o) { - resumeJobUpdate_result result = new resumeJobUpdate_result(); - result.success = o; - try { - fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); - return; - } catch (Exception e) { - LOGGER.error("Exception writing to internal frame buffer", e); - } - fb.close(); - } - public void onError(Exception e) { - byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; - org.apache.thrift.TBase msg; - resumeJobUpdate_result result = new resumeJobUpdate_result(); - { - msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; - msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); - } - try { - fcall.sendResponse(fb,msg,msgType,seqid); - return; - } catch (Exception ex) { - LOGGER.error("Exception writing to internal frame buffer", ex); - } - fb.close(); - } - }; - } - - protected boolean isOneway() { - return false; - } - - public void start(I iface, resumeJobUpdate_args args, org.apache.thrift.async.AsyncMethodCallback<Response> resultHandler) throws TException { - iface.resumeJobUpdate(args.key, args.message,resultHandler); - } - } - - public static class abortJobUpdate<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, abortJobUpdate_args, Response> { - public abortJobUpdate() { - super("abortJobUpdate"); - } - - public abortJobUpdate_args getEmptyArgsInstance() { - return new abortJobUpdate_args(); - } - - public AsyncMethodCallback<Response> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { -
<TRUNCATED>
