http://git-wip-us.apache.org/repos/asf/zeppelin/blob/7af86168/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterEventService.java ---------------------------------------------------------------------- diff --git a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterEventService.java b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterEventService.java new file mode 100644 index 0000000..c0c4dae --- /dev/null +++ b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/thrift/RemoteInterpreterEventService.java @@ -0,0 +1,13261 @@ +/** + * 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.2) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.zeppelin.interpreter.thrift; + +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.2)", date = "2018-5-29") +public class RemoteInterpreterEventService { + + public interface Iface { + + public void registerInterpreterProcess(RegisterInfo registerInfo) throws org.apache.thrift.TException; + + public void appendOutput(OutputAppendEvent event) throws org.apache.thrift.TException; + + public void updateOutput(OutputUpdateEvent event) throws org.apache.thrift.TException; + + public void updateAllOutput(OutputUpdateAllEvent event) throws org.apache.thrift.TException; + + public void appendAppOutput(AppOutputAppendEvent event) throws org.apache.thrift.TException; + + public void updateAppOutput(AppOutputUpdateEvent event) throws org.apache.thrift.TException; + + public void updateAppStatus(AppStatusUpdateEvent event) throws org.apache.thrift.TException; + + public void runParagraphs(RunParagraphsEvent event) throws org.apache.thrift.TException; + + public void addAngularObject(String intpGroupId, String json) throws org.apache.thrift.TException; + + public void updateAngularObject(String intpGroupId, String json) throws org.apache.thrift.TException; + + public void removeAngularObject(String intpGroupId, String noteId, String paragraphId, String name) throws org.apache.thrift.TException; + + public void sendMetaInfo(String intpGroupId, String json) throws org.apache.thrift.TException; + + public void sendParagraphInfo(String intpGroupId, String json) throws org.apache.thrift.TException; + + public List<String> getAllResources(String intpGroupId) throws org.apache.thrift.TException; + + public ByteBuffer getResource(String resourceIdJson) throws org.apache.thrift.TException; + + public ByteBuffer invokeMethod(String intpGroupId, String invokeMethodJson) throws org.apache.thrift.TException; + + } + + public interface AsyncIface { + + public void registerInterpreterProcess(RegisterInfo registerInfo, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void appendOutput(OutputAppendEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void updateOutput(OutputUpdateEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void updateAllOutput(OutputUpdateAllEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void appendAppOutput(AppOutputAppendEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void updateAppOutput(AppOutputUpdateEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void updateAppStatus(AppStatusUpdateEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void runParagraphs(RunParagraphsEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void addAngularObject(String intpGroupId, String json, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void updateAngularObject(String intpGroupId, String json, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void removeAngularObject(String intpGroupId, String noteId, String paragraphId, String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void sendMetaInfo(String intpGroupId, String json, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void sendParagraphInfo(String intpGroupId, String json, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void getAllResources(String intpGroupId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void getResource(String resourceIdJson, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + public void invokeMethod(String intpGroupId, String invokeMethodJson, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + + } + + public static class Client extends org.apache.thrift.TServiceClient 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 void registerInterpreterProcess(RegisterInfo registerInfo) throws org.apache.thrift.TException + { + send_registerInterpreterProcess(registerInfo); + recv_registerInterpreterProcess(); + } + + public void send_registerInterpreterProcess(RegisterInfo registerInfo) throws org.apache.thrift.TException + { + registerInterpreterProcess_args args = new registerInterpreterProcess_args(); + args.setRegisterInfo(registerInfo); + sendBase("registerInterpreterProcess", args); + } + + public void recv_registerInterpreterProcess() throws org.apache.thrift.TException + { + registerInterpreterProcess_result result = new registerInterpreterProcess_result(); + receiveBase(result, "registerInterpreterProcess"); + return; + } + + public void appendOutput(OutputAppendEvent event) throws org.apache.thrift.TException + { + send_appendOutput(event); + recv_appendOutput(); + } + + public void send_appendOutput(OutputAppendEvent event) throws org.apache.thrift.TException + { + appendOutput_args args = new appendOutput_args(); + args.setEvent(event); + sendBase("appendOutput", args); + } + + public void recv_appendOutput() throws org.apache.thrift.TException + { + appendOutput_result result = new appendOutput_result(); + receiveBase(result, "appendOutput"); + return; + } + + public void updateOutput(OutputUpdateEvent event) throws org.apache.thrift.TException + { + send_updateOutput(event); + recv_updateOutput(); + } + + public void send_updateOutput(OutputUpdateEvent event) throws org.apache.thrift.TException + { + updateOutput_args args = new updateOutput_args(); + args.setEvent(event); + sendBase("updateOutput", args); + } + + public void recv_updateOutput() throws org.apache.thrift.TException + { + updateOutput_result result = new updateOutput_result(); + receiveBase(result, "updateOutput"); + return; + } + + public void updateAllOutput(OutputUpdateAllEvent event) throws org.apache.thrift.TException + { + send_updateAllOutput(event); + recv_updateAllOutput(); + } + + public void send_updateAllOutput(OutputUpdateAllEvent event) throws org.apache.thrift.TException + { + updateAllOutput_args args = new updateAllOutput_args(); + args.setEvent(event); + sendBase("updateAllOutput", args); + } + + public void recv_updateAllOutput() throws org.apache.thrift.TException + { + updateAllOutput_result result = new updateAllOutput_result(); + receiveBase(result, "updateAllOutput"); + return; + } + + public void appendAppOutput(AppOutputAppendEvent event) throws org.apache.thrift.TException + { + send_appendAppOutput(event); + recv_appendAppOutput(); + } + + public void send_appendAppOutput(AppOutputAppendEvent event) throws org.apache.thrift.TException + { + appendAppOutput_args args = new appendAppOutput_args(); + args.setEvent(event); + sendBase("appendAppOutput", args); + } + + public void recv_appendAppOutput() throws org.apache.thrift.TException + { + appendAppOutput_result result = new appendAppOutput_result(); + receiveBase(result, "appendAppOutput"); + return; + } + + public void updateAppOutput(AppOutputUpdateEvent event) throws org.apache.thrift.TException + { + send_updateAppOutput(event); + recv_updateAppOutput(); + } + + public void send_updateAppOutput(AppOutputUpdateEvent event) throws org.apache.thrift.TException + { + updateAppOutput_args args = new updateAppOutput_args(); + args.setEvent(event); + sendBase("updateAppOutput", args); + } + + public void recv_updateAppOutput() throws org.apache.thrift.TException + { + updateAppOutput_result result = new updateAppOutput_result(); + receiveBase(result, "updateAppOutput"); + return; + } + + public void updateAppStatus(AppStatusUpdateEvent event) throws org.apache.thrift.TException + { + send_updateAppStatus(event); + recv_updateAppStatus(); + } + + public void send_updateAppStatus(AppStatusUpdateEvent event) throws org.apache.thrift.TException + { + updateAppStatus_args args = new updateAppStatus_args(); + args.setEvent(event); + sendBase("updateAppStatus", args); + } + + public void recv_updateAppStatus() throws org.apache.thrift.TException + { + updateAppStatus_result result = new updateAppStatus_result(); + receiveBase(result, "updateAppStatus"); + return; + } + + public void runParagraphs(RunParagraphsEvent event) throws org.apache.thrift.TException + { + send_runParagraphs(event); + recv_runParagraphs(); + } + + public void send_runParagraphs(RunParagraphsEvent event) throws org.apache.thrift.TException + { + runParagraphs_args args = new runParagraphs_args(); + args.setEvent(event); + sendBase("runParagraphs", args); + } + + public void recv_runParagraphs() throws org.apache.thrift.TException + { + runParagraphs_result result = new runParagraphs_result(); + receiveBase(result, "runParagraphs"); + return; + } + + public void addAngularObject(String intpGroupId, String json) throws org.apache.thrift.TException + { + send_addAngularObject(intpGroupId, json); + recv_addAngularObject(); + } + + public void send_addAngularObject(String intpGroupId, String json) throws org.apache.thrift.TException + { + addAngularObject_args args = new addAngularObject_args(); + args.setIntpGroupId(intpGroupId); + args.setJson(json); + sendBase("addAngularObject", args); + } + + public void recv_addAngularObject() throws org.apache.thrift.TException + { + addAngularObject_result result = new addAngularObject_result(); + receiveBase(result, "addAngularObject"); + return; + } + + public void updateAngularObject(String intpGroupId, String json) throws org.apache.thrift.TException + { + send_updateAngularObject(intpGroupId, json); + recv_updateAngularObject(); + } + + public void send_updateAngularObject(String intpGroupId, String json) throws org.apache.thrift.TException + { + updateAngularObject_args args = new updateAngularObject_args(); + args.setIntpGroupId(intpGroupId); + args.setJson(json); + sendBase("updateAngularObject", args); + } + + public void recv_updateAngularObject() throws org.apache.thrift.TException + { + updateAngularObject_result result = new updateAngularObject_result(); + receiveBase(result, "updateAngularObject"); + return; + } + + public void removeAngularObject(String intpGroupId, String noteId, String paragraphId, String name) throws org.apache.thrift.TException + { + send_removeAngularObject(intpGroupId, noteId, paragraphId, name); + recv_removeAngularObject(); + } + + public void send_removeAngularObject(String intpGroupId, String noteId, String paragraphId, String name) throws org.apache.thrift.TException + { + removeAngularObject_args args = new removeAngularObject_args(); + args.setIntpGroupId(intpGroupId); + args.setNoteId(noteId); + args.setParagraphId(paragraphId); + args.setName(name); + sendBase("removeAngularObject", args); + } + + public void recv_removeAngularObject() throws org.apache.thrift.TException + { + removeAngularObject_result result = new removeAngularObject_result(); + receiveBase(result, "removeAngularObject"); + return; + } + + public void sendMetaInfo(String intpGroupId, String json) throws org.apache.thrift.TException + { + send_sendMetaInfo(intpGroupId, json); + recv_sendMetaInfo(); + } + + public void send_sendMetaInfo(String intpGroupId, String json) throws org.apache.thrift.TException + { + sendMetaInfo_args args = new sendMetaInfo_args(); + args.setIntpGroupId(intpGroupId); + args.setJson(json); + sendBase("sendMetaInfo", args); + } + + public void recv_sendMetaInfo() throws org.apache.thrift.TException + { + sendMetaInfo_result result = new sendMetaInfo_result(); + receiveBase(result, "sendMetaInfo"); + return; + } + + public void sendParagraphInfo(String intpGroupId, String json) throws org.apache.thrift.TException + { + send_sendParagraphInfo(intpGroupId, json); + recv_sendParagraphInfo(); + } + + public void send_sendParagraphInfo(String intpGroupId, String json) throws org.apache.thrift.TException + { + sendParagraphInfo_args args = new sendParagraphInfo_args(); + args.setIntpGroupId(intpGroupId); + args.setJson(json); + sendBase("sendParagraphInfo", args); + } + + public void recv_sendParagraphInfo() throws org.apache.thrift.TException + { + sendParagraphInfo_result result = new sendParagraphInfo_result(); + receiveBase(result, "sendParagraphInfo"); + return; + } + + public List<String> getAllResources(String intpGroupId) throws org.apache.thrift.TException + { + send_getAllResources(intpGroupId); + return recv_getAllResources(); + } + + public void send_getAllResources(String intpGroupId) throws org.apache.thrift.TException + { + getAllResources_args args = new getAllResources_args(); + args.setIntpGroupId(intpGroupId); + sendBase("getAllResources", args); + } + + public List<String> recv_getAllResources() throws org.apache.thrift.TException + { + getAllResources_result result = new getAllResources_result(); + receiveBase(result, "getAllResources"); + if (result.isSetSuccess()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getAllResources failed: unknown result"); + } + + public ByteBuffer getResource(String resourceIdJson) throws org.apache.thrift.TException + { + send_getResource(resourceIdJson); + return recv_getResource(); + } + + public void send_getResource(String resourceIdJson) throws org.apache.thrift.TException + { + getResource_args args = new getResource_args(); + args.setResourceIdJson(resourceIdJson); + sendBase("getResource", args); + } + + public ByteBuffer recv_getResource() throws org.apache.thrift.TException + { + getResource_result result = new getResource_result(); + receiveBase(result, "getResource"); + if (result.isSetSuccess()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getResource failed: unknown result"); + } + + public ByteBuffer invokeMethod(String intpGroupId, String invokeMethodJson) throws org.apache.thrift.TException + { + send_invokeMethod(intpGroupId, invokeMethodJson); + return recv_invokeMethod(); + } + + public void send_invokeMethod(String intpGroupId, String invokeMethodJson) throws org.apache.thrift.TException + { + invokeMethod_args args = new invokeMethod_args(); + args.setIntpGroupId(intpGroupId); + args.setInvokeMethodJson(invokeMethodJson); + sendBase("invokeMethod", args); + } + + public ByteBuffer recv_invokeMethod() throws org.apache.thrift.TException + { + invokeMethod_result result = new invokeMethod_result(); + receiveBase(result, "invokeMethod"); + if (result.isSetSuccess()) { + return result.success; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "invokeMethod failed: unknown result"); + } + + } + public static class AsyncClient extends org.apache.thrift.async.TAsyncClient 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 registerInterpreterProcess(RegisterInfo registerInfo, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + registerInterpreterProcess_call method_call = new registerInterpreterProcess_call(registerInfo, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class registerInterpreterProcess_call extends org.apache.thrift.async.TAsyncMethodCall { + private RegisterInfo registerInfo; + public registerInterpreterProcess_call(RegisterInfo registerInfo, 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.registerInfo = registerInfo; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("registerInterpreterProcess", org.apache.thrift.protocol.TMessageType.CALL, 0)); + registerInterpreterProcess_args args = new registerInterpreterProcess_args(); + args.setRegisterInfo(registerInfo); + args.write(prot); + prot.writeMessageEnd(); + } + + public void 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); + (new Client(prot)).recv_registerInterpreterProcess(); + } + } + + public void appendOutput(OutputAppendEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + appendOutput_call method_call = new appendOutput_call(event, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class appendOutput_call extends org.apache.thrift.async.TAsyncMethodCall { + private OutputAppendEvent event; + public appendOutput_call(OutputAppendEvent event, 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.event = event; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("appendOutput", org.apache.thrift.protocol.TMessageType.CALL, 0)); + appendOutput_args args = new appendOutput_args(); + args.setEvent(event); + args.write(prot); + prot.writeMessageEnd(); + } + + public void 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); + (new Client(prot)).recv_appendOutput(); + } + } + + public void updateOutput(OutputUpdateEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + updateOutput_call method_call = new updateOutput_call(event, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class updateOutput_call extends org.apache.thrift.async.TAsyncMethodCall { + private OutputUpdateEvent event; + public updateOutput_call(OutputUpdateEvent event, 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.event = event; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("updateOutput", org.apache.thrift.protocol.TMessageType.CALL, 0)); + updateOutput_args args = new updateOutput_args(); + args.setEvent(event); + args.write(prot); + prot.writeMessageEnd(); + } + + public void 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); + (new Client(prot)).recv_updateOutput(); + } + } + + public void updateAllOutput(OutputUpdateAllEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + updateAllOutput_call method_call = new updateAllOutput_call(event, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class updateAllOutput_call extends org.apache.thrift.async.TAsyncMethodCall { + private OutputUpdateAllEvent event; + public updateAllOutput_call(OutputUpdateAllEvent event, 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.event = event; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("updateAllOutput", org.apache.thrift.protocol.TMessageType.CALL, 0)); + updateAllOutput_args args = new updateAllOutput_args(); + args.setEvent(event); + args.write(prot); + prot.writeMessageEnd(); + } + + public void 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); + (new Client(prot)).recv_updateAllOutput(); + } + } + + public void appendAppOutput(AppOutputAppendEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + appendAppOutput_call method_call = new appendAppOutput_call(event, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class appendAppOutput_call extends org.apache.thrift.async.TAsyncMethodCall { + private AppOutputAppendEvent event; + public appendAppOutput_call(AppOutputAppendEvent event, 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.event = event; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("appendAppOutput", org.apache.thrift.protocol.TMessageType.CALL, 0)); + appendAppOutput_args args = new appendAppOutput_args(); + args.setEvent(event); + args.write(prot); + prot.writeMessageEnd(); + } + + public void 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); + (new Client(prot)).recv_appendAppOutput(); + } + } + + public void updateAppOutput(AppOutputUpdateEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + updateAppOutput_call method_call = new updateAppOutput_call(event, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class updateAppOutput_call extends org.apache.thrift.async.TAsyncMethodCall { + private AppOutputUpdateEvent event; + public updateAppOutput_call(AppOutputUpdateEvent event, 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.event = event; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("updateAppOutput", org.apache.thrift.protocol.TMessageType.CALL, 0)); + updateAppOutput_args args = new updateAppOutput_args(); + args.setEvent(event); + args.write(prot); + prot.writeMessageEnd(); + } + + public void 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); + (new Client(prot)).recv_updateAppOutput(); + } + } + + public void updateAppStatus(AppStatusUpdateEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + updateAppStatus_call method_call = new updateAppStatus_call(event, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class updateAppStatus_call extends org.apache.thrift.async.TAsyncMethodCall { + private AppStatusUpdateEvent event; + public updateAppStatus_call(AppStatusUpdateEvent event, 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.event = event; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("updateAppStatus", org.apache.thrift.protocol.TMessageType.CALL, 0)); + updateAppStatus_args args = new updateAppStatus_args(); + args.setEvent(event); + args.write(prot); + prot.writeMessageEnd(); + } + + public void 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); + (new Client(prot)).recv_updateAppStatus(); + } + } + + public void runParagraphs(RunParagraphsEvent event, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + runParagraphs_call method_call = new runParagraphs_call(event, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class runParagraphs_call extends org.apache.thrift.async.TAsyncMethodCall { + private RunParagraphsEvent event; + public runParagraphs_call(RunParagraphsEvent event, 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.event = event; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("runParagraphs", org.apache.thrift.protocol.TMessageType.CALL, 0)); + runParagraphs_args args = new runParagraphs_args(); + args.setEvent(event); + args.write(prot); + prot.writeMessageEnd(); + } + + public void 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); + (new Client(prot)).recv_runParagraphs(); + } + } + + public void addAngularObject(String intpGroupId, String json, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + addAngularObject_call method_call = new addAngularObject_call(intpGroupId, json, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class addAngularObject_call extends org.apache.thrift.async.TAsyncMethodCall { + private String intpGroupId; + private String json; + public addAngularObject_call(String intpGroupId, String json, 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.intpGroupId = intpGroupId; + this.json = json; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("addAngularObject", org.apache.thrift.protocol.TMessageType.CALL, 0)); + addAngularObject_args args = new addAngularObject_args(); + args.setIntpGroupId(intpGroupId); + args.setJson(json); + args.write(prot); + prot.writeMessageEnd(); + } + + public void 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); + (new Client(prot)).recv_addAngularObject(); + } + } + + public void updateAngularObject(String intpGroupId, String json, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + updateAngularObject_call method_call = new updateAngularObject_call(intpGroupId, json, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class updateAngularObject_call extends org.apache.thrift.async.TAsyncMethodCall { + private String intpGroupId; + private String json; + public updateAngularObject_call(String intpGroupId, String json, 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.intpGroupId = intpGroupId; + this.json = json; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("updateAngularObject", org.apache.thrift.protocol.TMessageType.CALL, 0)); + updateAngularObject_args args = new updateAngularObject_args(); + args.setIntpGroupId(intpGroupId); + args.setJson(json); + args.write(prot); + prot.writeMessageEnd(); + } + + public void 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); + (new Client(prot)).recv_updateAngularObject(); + } + } + + public void removeAngularObject(String intpGroupId, String noteId, String paragraphId, String name, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + removeAngularObject_call method_call = new removeAngularObject_call(intpGroupId, noteId, paragraphId, name, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class removeAngularObject_call extends org.apache.thrift.async.TAsyncMethodCall { + private String intpGroupId; + private String noteId; + private String paragraphId; + private String name; + public removeAngularObject_call(String intpGroupId, String noteId, String paragraphId, String name, 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.intpGroupId = intpGroupId; + this.noteId = noteId; + this.paragraphId = paragraphId; + this.name = name; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("removeAngularObject", org.apache.thrift.protocol.TMessageType.CALL, 0)); + removeAngularObject_args args = new removeAngularObject_args(); + args.setIntpGroupId(intpGroupId); + args.setNoteId(noteId); + args.setParagraphId(paragraphId); + args.setName(name); + args.write(prot); + prot.writeMessageEnd(); + } + + public void 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); + (new Client(prot)).recv_removeAngularObject(); + } + } + + public void sendMetaInfo(String intpGroupId, String json, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + sendMetaInfo_call method_call = new sendMetaInfo_call(intpGroupId, json, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class sendMetaInfo_call extends org.apache.thrift.async.TAsyncMethodCall { + private String intpGroupId; + private String json; + public sendMetaInfo_call(String intpGroupId, String json, 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.intpGroupId = intpGroupId; + this.json = json; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("sendMetaInfo", org.apache.thrift.protocol.TMessageType.CALL, 0)); + sendMetaInfo_args args = new sendMetaInfo_args(); + args.setIntpGroupId(intpGroupId); + args.setJson(json); + args.write(prot); + prot.writeMessageEnd(); + } + + public void 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); + (new Client(prot)).recv_sendMetaInfo(); + } + } + + public void sendParagraphInfo(String intpGroupId, String json, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + sendParagraphInfo_call method_call = new sendParagraphInfo_call(intpGroupId, json, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class sendParagraphInfo_call extends org.apache.thrift.async.TAsyncMethodCall { + private String intpGroupId; + private String json; + public sendParagraphInfo_call(String intpGroupId, String json, 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.intpGroupId = intpGroupId; + this.json = json; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("sendParagraphInfo", org.apache.thrift.protocol.TMessageType.CALL, 0)); + sendParagraphInfo_args args = new sendParagraphInfo_args(); + args.setIntpGroupId(intpGroupId); + args.setJson(json); + args.write(prot); + prot.writeMessageEnd(); + } + + public void 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); + (new Client(prot)).recv_sendParagraphInfo(); + } + } + + public void getAllResources(String intpGroupId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getAllResources_call method_call = new getAllResources_call(intpGroupId, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getAllResources_call extends org.apache.thrift.async.TAsyncMethodCall { + private String intpGroupId; + public getAllResources_call(String intpGroupId, 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.intpGroupId = intpGroupId; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getAllResources", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getAllResources_args args = new getAllResources_args(); + args.setIntpGroupId(intpGroupId); + args.write(prot); + prot.writeMessageEnd(); + } + + public List<String> 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_getAllResources(); + } + } + + public void getResource(String resourceIdJson, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + getResource_call method_call = new getResource_call(resourceIdJson, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getResource_call extends org.apache.thrift.async.TAsyncMethodCall { + private String resourceIdJson; + public getResource_call(String resourceIdJson, 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.resourceIdJson = resourceIdJson; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getResource", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getResource_args args = new getResource_args(); + args.setResourceIdJson(resourceIdJson); + args.write(prot); + prot.writeMessageEnd(); + } + + public ByteBuffer 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_getResource(); + } + } + + public void invokeMethod(String intpGroupId, String invokeMethodJson, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + invokeMethod_call method_call = new invokeMethod_call(intpGroupId, invokeMethodJson, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class invokeMethod_call extends org.apache.thrift.async.TAsyncMethodCall { + private String intpGroupId; + private String invokeMethodJson; + public invokeMethod_call(String intpGroupId, String invokeMethodJson, 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.intpGroupId = intpGroupId; + this.invokeMethodJson = invokeMethodJson; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("invokeMethod", org.apache.thrift.protocol.TMessageType.CALL, 0)); + invokeMethod_args args = new invokeMethod_args(); + args.setIntpGroupId(intpGroupId); + args.setInvokeMethodJson(invokeMethodJson); + args.write(prot); + prot.writeMessageEnd(); + } + + public ByteBuffer 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_invokeMethod(); + } + } + + } + + public static class Processor<I extends Iface> extends org.apache.thrift.TBaseProcessor<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("registerInterpreterProcess", new registerInterpreterProcess()); + processMap.put("appendOutput", new appendOutput()); + processMap.put("updateOutput", new updateOutput()); + processMap.put("updateAllOutput", new updateAllOutput()); + processMap.put("appendAppOutput", new appendAppOutput()); + processMap.put("updateAppOutput", new updateAppOutput()); + processMap.put("updateAppStatus", new updateAppStatus()); + processMap.put("runParagraphs", new runParagraphs()); + processMap.put("addAngularObject", new addAngularObject()); + processMap.put("updateAngularObject", new updateAngularObject()); + processMap.put("removeAngularObject", new removeAngularObject()); + processMap.put("sendMetaInfo", new sendMetaInfo()); + processMap.put("sendParagraphInfo", new sendParagraphInfo()); + processMap.put("getAllResources", new getAllResources()); + processMap.put("getResource", new getResource()); + processMap.put("invokeMethod", new invokeMethod()); + return processMap; + } + + public static class registerInterpreterProcess<I extends Iface> extends org.apache.thrift.ProcessFunction<I, registerInterpreterProcess_args> { + public registerInterpreterProcess() { + super("registerInterpreterProcess"); + } + + public registerInterpreterProcess_args getEmptyArgsInstance() { + return new registerInterpreterProcess_args(); + } + + protected boolean isOneway() { + return false; + } + + public registerInterpreterProcess_result getResult(I iface, registerInterpreterProcess_args args) throws org.apache.thrift.TException { + registerInterpreterProcess_result result = new registerInterpreterProcess_result(); + iface.registerInterpreterProcess(args.registerInfo); + return result; + } + } + + public static class appendOutput<I extends Iface> extends org.apache.thrift.ProcessFunction<I, appendOutput_args> { + public appendOutput() { + super("appendOutput"); + } + + public appendOutput_args getEmptyArgsInstance() { + return new appendOutput_args(); + } + + protected boolean isOneway() { + return false; + } + + public appendOutput_result getResult(I iface, appendOutput_args args) throws org.apache.thrift.TException { + appendOutput_result result = new appendOutput_result(); + iface.appendOutput(args.event); + return result; + } + } + + public static class updateOutput<I extends Iface> extends org.apache.thrift.ProcessFunction<I, updateOutput_args> { + public updateOutput() { + super("updateOutput"); + } + + public updateOutput_args getEmptyArgsInstance() { + return new updateOutput_args(); + } + + protected boolean isOneway() { + return false; + } + + public updateOutput_result getResult(I iface, updateOutput_args args) throws org.apache.thrift.TException { + updateOutput_result result = new updateOutput_result(); + iface.updateOutput(args.event); + return result; + } + } + + public static class updateAllOutput<I extends Iface> extends org.apache.thrift.ProcessFunction<I, updateAllOutput_args> { + public updateAllOutput() { + super("updateAllOutput"); + } + + public updateAllOutput_args getEmptyArgsInstance() { + return new updateAllOutput_args(); + } + + protected boolean isOneway() { + return false; + } + + public updateAllOutput_result getResult(I iface, updateAllOutput_args args) throws org.apache.thrift.TException { + updateAllOutput_result result = new updateAllOutput_result(); + iface.updateAllOutput(args.event); + return result; + } + } + + public static class appendAppOutput<I extends Iface> extends org.apache.thrift.ProcessFunction<I, appendAppOutput_args> { + public appendAppOutput() { + super("appendAppOutput"); + } + + public appendAppOutput_args getEmptyArgsInstance() { + return new appendAppOutput_args(); + } + + protected boolean isOneway() { + return false; + } + + public appendAppOutput_result getResult(I iface, appendAppOutput_args args) throws org.apache.thrift.TException { + appendAppOutput_result result = new appendAppOutput_result(); + iface.appendAppOutput(args.event); + return result; + } + } + + public static class updateAppOutput<I extends Iface> extends org.apache.thrift.ProcessFunction<I, updateAppOutput_args> { + public updateAppOutput() { + super("updateAppOutput"); + } + + public updateAppOutput_args getEmptyArgsInstance() { + return new updateAppOutput_args(); + } + + protected boolean isOneway() { + return false; + } + + public updateAppOutput_result getResult(I iface, updateAppOutput_args args) throws org.apache.thrift.TException { + updateAppOutput_result result = new updateAppOutput_result(); + iface.updateAppOutput(args.event); + return result; + } + } + + public static class updateAppStatus<I extends Iface> extends org.apache.thrift.ProcessFunction<I, updateAppStatus_args> { + public updateAppStatus() { + super("updateAppStatus"); + } + + public updateAppStatus_args getEmptyArgsInstance() { + return new updateAppStatus_args(); + } + + protected boolean isOneway() { + return false; + } + + public updateAppStatus_result getResult(I iface, updateAppStatus_args args) throws org.apache.thrift.TException { + updateAppStatus_result result = new updateAppStatus_result(); + iface.updateAppStatus(args.event); + return result; + } + } + + public static class runParagraphs<I extends Iface> extends org.apache.thrift.ProcessFunction<I, runParagraphs_args> { + public runParagraphs() { + super("runParagraphs"); + } + + public runParagraphs_args getEmptyArgsInstance() { + return new runParagraphs_args(); + } + + protected boolean isOneway() { + return false; + } + + public runParagraphs_result getResult(I iface, runParagraphs_args args) throws org.apache.thrift.TException { + runParagraphs_result result = new runParagraphs_result(); + iface.runParagraphs(args.event); + return result; + } + } + + public static class addAngularObject<I extends Iface> extends org.apache.thrift.ProcessFunction<I, addAngularObject_args> { + public addAngularObject() { + super("addAngularObject"); + } + + public addAngularObject_args getEmptyArgsInstance() { + return new addAngularObject_args(); + } + + protected boolean isOneway() { + return false; + } + + public addAngularObject_result getResult(I iface, addAngularObject_args args) throws org.apache.thrift.TException { + addAngularObject_result result = new addAngularObject_result(); + iface.addAngularObject(args.intpGroupId, args.json); + return result; + } + } + + public static class updateAngularObject<I extends Iface> extends org.apache.thrift.ProcessFunction<I, updateAngularObject_args> { + public updateAngularObject() { + super("updateAngularObject"); + } + + public updateAngularObject_args getEmptyArgsInstance() { + return new updateAngularObject_args(); + } + + protected boolean isOneway() { + return false; + } + + public updateAngularObject_result getResult(I iface, updateAngularObject_args args) throws org.apache.thrift.TException { + updateAngularObject_result result = new updateAngularObject_result(); + iface.updateAngularObject(args.intpGroupId, args.json); + return result; + } + } + + public static class removeAngularObject<I extends Iface> extends org.apache.thrift.ProcessFunction<I, removeAngularObject_args> { + public removeAngularObject() { + super("removeAngularObject"); + } + + public removeAngularObject_args getEmptyArgsInstance() { + return new removeAngularObject_args(); + } + + protected boolean isOneway() { + return false; + } + + public removeAngularObject_result getResult(I iface, removeAngularObject_args args) throws org.apache.thrift.TException { + removeAngularObject_result result = new removeAngularObject_result(); + iface.removeAngularObject(args.intpGroupId, args.noteId, args.paragraphId, args.name); + return result; + } + } + + public static class sendMetaInfo<I extends Iface> extends org.apache.thrift.ProcessFunction<I, sendMetaInfo_args> { + public sendMetaInfo() { + super("sendMetaInfo"); + } + + public sendMetaInfo_args getEmptyArgsInstance() { + return new sendMetaInfo_args(); + } + + protected boolean isOneway() { + return false; + } + + public sendMetaInfo_result getResult(I iface, sendMetaInfo_args args) throws org.apache.thrift.TException { + sendMetaInfo_result result = new sendMetaInfo_result(); + iface.sendMetaInfo(args.intpGroupId, args.json); + return result; + } + } + + public static class sendParagraphInfo<I extends Iface> extends org.apache.thrift.ProcessFunction<I, sendParagraphInfo_args> { + public sendParagraphInfo() { + super("sendParagraphInfo"); + } + + public sendParagraphInfo_args getEmptyArgsInstance() { + return new sendParagraphInfo_args(); + } + + protected boolean isOneway() { + return false; + } + + public sendParagraphInfo_result getResult(I iface, sendParagraphInfo_args args) throws org.apache.thrift.TException { + sendParagraphInfo_result result = new sendParagraphInfo_result(); + iface.sendParagraphInfo(args.intpGroupId, args.json); + return result; + } + } + + public static class getAllResources<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getAllResources_args> { + public getAllResources() { + super("getAllResources"); + } + + public getAllResources_args getEmptyArgsInstance() { + return new getAllResources_args(); + } + + protected boolean isOneway() { + return false; + } + + public getAllResources_result getResult(I iface, getAllResources_args args) throws org.apache.thrift.TException { + getAllResources_result result = new getAllResources_result(); + result.success = iface.getAllResources(args.intpGroupId); + return result; + } + } + + public static class getResource<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getResource_args> { + public getResource() { + super("getResource"); + } + + public getResource_args getEmptyArgsInstance() { + return new getResource_args(); + } + + protected boolean isOneway() { + return false; + } + + public getResource_result getResult(I iface, getResource_args args) throws org.apache.thrift.TException { + getResource_result result = new getResource_result(); + result.success = iface.getResource(args.resourceIdJson); + return result; + } + } + + public static class invokeMethod<I extends Iface> extends org.apache.thrift.ProcessFunction<I, invokeMethod_args> { + public invokeMethod() { + super("invokeMethod"); + } + + public invokeMethod_args getEmptyArgsInstance() { + return new invokeMethod_args(); + } + + protected boolean isOneway() { + return false; + } + + public invokeMethod_result getResult(I iface, invokeMethod_args args) throws org.apache.thrift.TException { + invokeMethod_result result = new invokeMethod_result(); + result.success = iface.invokeMethod(args.intpGroupId, args.invokeMethodJson); + return result; + } + } + + } + + public static class AsyncProcessor<I extends AsyncIface> extends org.apache.thrift.TBaseAsyncProcessor<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("registerInterpreterProcess", new registerInterpreterProcess()); + processMap.put("appendOutput", new appendOutput()); + processMap.put("updateOutput", new updateOutput()); + processMap.put("updateAllOutput", new updateAllOutput()); + processMap.put("appendAppOutput", new appendAppOutput()); + processMap.put("updateAppOutput", new updateAppOutput()); + processMap.put("updateAppStatus", new updateAppStatus()); + processMap.put("runParagraphs", new runParagraphs()); + processMap.put("addAngularObject", new addAngularObject()); + processMap.put("updateAngularObject", new updateAngularObject()); + processMap.put("removeAngularObject", new removeAngularObject()); + processMap.put("sendMetaInfo", new sendMetaInfo()); + processMap.put("sendParagraphInfo", new sendParagraphInfo()); + processMap.put("getAllResources", new getAllResources()); + processMap.put("getResource", new getResource()); + processMap.put("invokeMethod", new invokeMethod()); + return processMap; + } + + public static class registerInterpreterProcess<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, registerInterpreterProcess_args, Void> { + public registerInterpreterProcess() { + super("registerInterpreterProcess"); + } + + public registerInterpreterProcess_args getEmptyArgsInstance() { + return new registerInterpreterProcess_args(); + } + + public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + registerInterpreterProcess_result result = new registerInterpreterProcess_result(); + 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; + registerInterpreterProcess_result result = new registerInterpreterProcess_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, registerInterpreterProcess_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.registerInterpreterProcess(args.registerInfo,resultHandler); + } + } + + public static class appendOutput<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, appendOutput_args, Void> { + public appendOutput() { + super("appendOutput"); + } + + public appendOutput_args getEmptyArgsInstance() { + return new appendOutput_args(); + } + + public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + appendOutput_result result = new appendOutput_result(); + 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; + appendOutput_result result = new appendOutput_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, appendOutput_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.appendOutput(args.event,resultHandler); + } + } + + public static class updateOutput<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateOutput_args, Void> { + public updateOutput() { + super("updateOutput"); + } + + public updateOutput_args getEmptyArgsInstance() { + return new updateOutput_args(); + } + + public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + updateOutput_result result = new updateOutput_result(); + 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; + updateOutput_result result = new updateOutput_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, updateOutput_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.updateOutput(args.event,resultHandler); + } + } + + public static class updateAllOutput<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateAllOutput_args, Void> { + public updateAllOutput() { + super("updateAllOutput"); + } + + public updateAllOutput_args getEmptyArgsInstance() { + return new updateAllOutput_args(); + } + + public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + updateAllOutput_result result = new updateAllOutput_result(); + 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; + updateAllOutput_result result = new updateAllOutput_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, updateAllOutput_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.updateAllOutput(args.event,resultHandler); + } + } + + public static class appendAppOutput<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, appendAppOutput_args, Void> { + public appendAppOutput() { + super("appendAppOutput"); + } + + public appendAppOutput_args getEmptyArgsInstance() { + return new appendAppOutput_args(); + } + + public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + appendAppOutput_result result = new appendAppOutput_result(); + 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; + appendAppOutput_result result = new appendAppOutput_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, appendAppOutput_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.appendAppOutput(args.event,resultHandler); + } + } + + public static class updateAppOutput<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateAppOutput_args, Void> { + public updateAppOutput() { + super("updateAppOutput"); + } + + public updateAppOutput_args getEmptyArgsInstance() { + return new updateAppOutput_args(); + } + + public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + updateAppOutput_result result = new updateAppOutput_result(); + 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; + updateAppOutput_result result = new updateAppOutput_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, updateAppOutput_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.updateAppOutput(args.event,resultHandler); + } + } + + public static class updateAppStatus<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateAppStatus_args, Void> { + public updateAppStatus() { + super("updateAppStatus"); + } + + public updateAppStatus_args getEmptyArgsInstance() { + return new updateAppStatus_args(); + } + + public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + updateAppStatus_result result = new updateAppStatus_result(); + 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; + updateAppStatus_result result = new updateAppStatus_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, updateAppStatus_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.updateAppStatus(args.event,resultHandler); + } + } + + public static class runParagraphs<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, runParagraphs_args, Void> { + public runParagraphs() { + super("runParagraphs"); + } + + public runParagraphs_args getEmptyArgsInstance() { + return new runParagraphs_args(); + } + + public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + runParagraphs_result result = new runParagraphs_result(); + 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; + runParagraphs_result result = new runParagraphs_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, runParagraphs_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.runParagraphs(args.event,resultHandler); + } + } + + public static class addAngularObject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addAngularObject_args, Void> { + public addAngularObject() { + super("addAngularObject"); + } + + public addAngularObject_args getEmptyArgsInstance() { + return new addAngularObject_args(); + } + + public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + addAngularObject_result result = new addAngularObject_result(); + 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; + addAngularObject_result result = new addAngularObject_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, addAngularObject_args args, org.apache.thrift.async.AsyncMethodCallback<Void> resultHandler) throws TException { + iface.addAngularObject(args.intpGroupId, args.json,resultHandler); + } + } + + public static class updateAngularObject<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateAngularObject_args, Void> { + public updateAngularObject() { + super("updateAngularObject"); + } + + public updateAngularObject_args getEmptyArgsInstance() { + return new updateAngularObject_args(); + } + + public AsyncMethodCallback<Void> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Void>() { + public void onComplete(Void o) { + updateAngularObject_result result = new updateAngularObject_result(); + 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; + updateAngularObject_result result = new updateAngularObject_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, updateAngularObject_args args, org.apache.thrift.a
<TRUNCATED>
