http://git-wip-us.apache.org/repos/asf/airavata/blob/28709245/modules/user-profile/user-profile-stubs/src/main/java/org/apache/airavata/userprofile/cpi/UserProfileService.java ---------------------------------------------------------------------- diff --git a/modules/user-profile/user-profile-stubs/src/main/java/org/apache/airavata/userprofile/cpi/UserProfileService.java b/modules/user-profile/user-profile-stubs/src/main/java/org/apache/airavata/userprofile/cpi/UserProfileService.java deleted file mode 100644 index b2ddb46..0000000 --- a/modules/user-profile/user-profile-stubs/src/main/java/org/apache/airavata/userprofile/cpi/UserProfileService.java +++ /dev/null @@ -1,7523 +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. - */ - /* - * 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.userprofile.cpi; - -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)") -public class UserProfileService { - - public interface Iface { - - public String addUserProfile(org.apache.airavata.model.user.UserProfile userProfile) throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, org.apache.thrift.TException; - - public boolean updateUserProfile(org.apache.airavata.model.user.UserProfile userProfile) throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, org.apache.thrift.TException; - - public org.apache.airavata.model.user.UserProfile getUserProfileById(String userId, String gatewayId) throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, org.apache.thrift.TException; - - public boolean deleteUserProfile(String userId) throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, org.apache.thrift.TException; - - public List<org.apache.airavata.model.user.UserProfile> getAllUserProfilesInGateway(String gatewayId, int offset, int limit) throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, org.apache.thrift.TException; - - public org.apache.airavata.model.user.UserProfile getUserProfileByName(String userName, String gatewayId) throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, org.apache.thrift.TException; - - public boolean doesUserExist(String userName, String gatewayId) throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, org.apache.thrift.TException; - - } - - public interface AsyncIface { - - public void addUserProfile(org.apache.airavata.model.user.UserProfile userProfile, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void updateUserProfile(org.apache.airavata.model.user.UserProfile userProfile, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void getUserProfileById(String userId, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void deleteUserProfile(String userId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void getAllUserProfilesInGateway(String gatewayId, int offset, int limit, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void getUserProfileByName(String userName, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; - - public void doesUserExist(String userName, String gatewayId, 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 String addUserProfile(org.apache.airavata.model.user.UserProfile userProfile) throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, org.apache.thrift.TException - { - send_addUserProfile(userProfile); - return recv_addUserProfile(); - } - - public void send_addUserProfile(org.apache.airavata.model.user.UserProfile userProfile) throws org.apache.thrift.TException - { - addUserProfile_args args = new addUserProfile_args(); - args.setUserProfile(userProfile); - sendBase("addUserProfile", args); - } - - public String recv_addUserProfile() throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, org.apache.thrift.TException - { - addUserProfile_result result = new addUserProfile_result(); - receiveBase(result, "addUserProfile"); - if (result.isSetSuccess()) { - return result.success; - } - if (result.userProfileException != null) { - throw result.userProfileException; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "addUserProfile failed: unknown result"); - } - - public boolean updateUserProfile(org.apache.airavata.model.user.UserProfile userProfile) throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, org.apache.thrift.TException - { - send_updateUserProfile(userProfile); - return recv_updateUserProfile(); - } - - public void send_updateUserProfile(org.apache.airavata.model.user.UserProfile userProfile) throws org.apache.thrift.TException - { - updateUserProfile_args args = new updateUserProfile_args(); - args.setUserProfile(userProfile); - sendBase("updateUserProfile", args); - } - - public boolean recv_updateUserProfile() throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, org.apache.thrift.TException - { - updateUserProfile_result result = new updateUserProfile_result(); - receiveBase(result, "updateUserProfile"); - if (result.isSetSuccess()) { - return result.success; - } - if (result.userProfileException != null) { - throw result.userProfileException; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "updateUserProfile failed: unknown result"); - } - - public org.apache.airavata.model.user.UserProfile getUserProfileById(String userId, String gatewayId) throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, org.apache.thrift.TException - { - send_getUserProfileById(userId, gatewayId); - return recv_getUserProfileById(); - } - - public void send_getUserProfileById(String userId, String gatewayId) throws org.apache.thrift.TException - { - getUserProfileById_args args = new getUserProfileById_args(); - args.setUserId(userId); - args.setGatewayId(gatewayId); - sendBase("getUserProfileById", args); - } - - public org.apache.airavata.model.user.UserProfile recv_getUserProfileById() throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, org.apache.thrift.TException - { - getUserProfileById_result result = new getUserProfileById_result(); - receiveBase(result, "getUserProfileById"); - if (result.isSetSuccess()) { - return result.success; - } - if (result.userProfileException != null) { - throw result.userProfileException; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getUserProfileById failed: unknown result"); - } - - public boolean deleteUserProfile(String userId) throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, org.apache.thrift.TException - { - send_deleteUserProfile(userId); - return recv_deleteUserProfile(); - } - - public void send_deleteUserProfile(String userId) throws org.apache.thrift.TException - { - deleteUserProfile_args args = new deleteUserProfile_args(); - args.setUserId(userId); - sendBase("deleteUserProfile", args); - } - - public boolean recv_deleteUserProfile() throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, org.apache.thrift.TException - { - deleteUserProfile_result result = new deleteUserProfile_result(); - receiveBase(result, "deleteUserProfile"); - if (result.isSetSuccess()) { - return result.success; - } - if (result.userProfileException != null) { - throw result.userProfileException; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "deleteUserProfile failed: unknown result"); - } - - public List<org.apache.airavata.model.user.UserProfile> getAllUserProfilesInGateway(String gatewayId, int offset, int limit) throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, org.apache.thrift.TException - { - send_getAllUserProfilesInGateway(gatewayId, offset, limit); - return recv_getAllUserProfilesInGateway(); - } - - public void send_getAllUserProfilesInGateway(String gatewayId, int offset, int limit) throws org.apache.thrift.TException - { - getAllUserProfilesInGateway_args args = new getAllUserProfilesInGateway_args(); - args.setGatewayId(gatewayId); - args.setOffset(offset); - args.setLimit(limit); - sendBase("getAllUserProfilesInGateway", args); - } - - public List<org.apache.airavata.model.user.UserProfile> recv_getAllUserProfilesInGateway() throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, org.apache.thrift.TException - { - getAllUserProfilesInGateway_result result = new getAllUserProfilesInGateway_result(); - receiveBase(result, "getAllUserProfilesInGateway"); - if (result.isSetSuccess()) { - return result.success; - } - if (result.userProfileException != null) { - throw result.userProfileException; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getAllUserProfilesInGateway failed: unknown result"); - } - - public org.apache.airavata.model.user.UserProfile getUserProfileByName(String userName, String gatewayId) throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, org.apache.thrift.TException - { - send_getUserProfileByName(userName, gatewayId); - return recv_getUserProfileByName(); - } - - public void send_getUserProfileByName(String userName, String gatewayId) throws org.apache.thrift.TException - { - getUserProfileByName_args args = new getUserProfileByName_args(); - args.setUserName(userName); - args.setGatewayId(gatewayId); - sendBase("getUserProfileByName", args); - } - - public org.apache.airavata.model.user.UserProfile recv_getUserProfileByName() throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, org.apache.thrift.TException - { - getUserProfileByName_result result = new getUserProfileByName_result(); - receiveBase(result, "getUserProfileByName"); - if (result.isSetSuccess()) { - return result.success; - } - if (result.userProfileException != null) { - throw result.userProfileException; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getUserProfileByName failed: unknown result"); - } - - public boolean doesUserExist(String userName, String gatewayId) throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, org.apache.thrift.TException - { - send_doesUserExist(userName, gatewayId); - return recv_doesUserExist(); - } - - public void send_doesUserExist(String userName, String gatewayId) throws org.apache.thrift.TException - { - doesUserExist_args args = new doesUserExist_args(); - args.setUserName(userName); - args.setGatewayId(gatewayId); - sendBase("doesUserExist", args); - } - - public boolean recv_doesUserExist() throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, org.apache.thrift.TException - { - doesUserExist_result result = new doesUserExist_result(); - receiveBase(result, "doesUserExist"); - if (result.isSetSuccess()) { - return result.success; - } - if (result.userProfileException != null) { - throw result.userProfileException; - } - throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "doesUserExist 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 addUserProfile(org.apache.airavata.model.user.UserProfile userProfile, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - addUserProfile_call method_call = new addUserProfile_call(userProfile, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class addUserProfile_call extends org.apache.thrift.async.TAsyncMethodCall { - private org.apache.airavata.model.user.UserProfile userProfile; - public addUserProfile_call(org.apache.airavata.model.user.UserProfile userProfile, 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.userProfile = userProfile; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("addUserProfile", org.apache.thrift.protocol.TMessageType.CALL, 0)); - addUserProfile_args args = new addUserProfile_args(); - args.setUserProfile(userProfile); - args.write(prot); - prot.writeMessageEnd(); - } - - public String getResult() throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, 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_addUserProfile(); - } - } - - public void updateUserProfile(org.apache.airavata.model.user.UserProfile userProfile, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - updateUserProfile_call method_call = new updateUserProfile_call(userProfile, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class updateUserProfile_call extends org.apache.thrift.async.TAsyncMethodCall { - private org.apache.airavata.model.user.UserProfile userProfile; - public updateUserProfile_call(org.apache.airavata.model.user.UserProfile userProfile, 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.userProfile = userProfile; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("updateUserProfile", org.apache.thrift.protocol.TMessageType.CALL, 0)); - updateUserProfile_args args = new updateUserProfile_args(); - args.setUserProfile(userProfile); - args.write(prot); - prot.writeMessageEnd(); - } - - public boolean getResult() throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, 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_updateUserProfile(); - } - } - - public void getUserProfileById(String userId, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - getUserProfileById_call method_call = new getUserProfileById_call(userId, gatewayId, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class getUserProfileById_call extends org.apache.thrift.async.TAsyncMethodCall { - private String userId; - private String gatewayId; - public getUserProfileById_call(String userId, String gatewayId, 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.userId = userId; - this.gatewayId = gatewayId; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getUserProfileById", org.apache.thrift.protocol.TMessageType.CALL, 0)); - getUserProfileById_args args = new getUserProfileById_args(); - args.setUserId(userId); - args.setGatewayId(gatewayId); - args.write(prot); - prot.writeMessageEnd(); - } - - public org.apache.airavata.model.user.UserProfile getResult() throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, 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_getUserProfileById(); - } - } - - public void deleteUserProfile(String userId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - deleteUserProfile_call method_call = new deleteUserProfile_call(userId, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class deleteUserProfile_call extends org.apache.thrift.async.TAsyncMethodCall { - private String userId; - public deleteUserProfile_call(String userId, 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.userId = userId; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("deleteUserProfile", org.apache.thrift.protocol.TMessageType.CALL, 0)); - deleteUserProfile_args args = new deleteUserProfile_args(); - args.setUserId(userId); - args.write(prot); - prot.writeMessageEnd(); - } - - public boolean getResult() throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, 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_deleteUserProfile(); - } - } - - public void getAllUserProfilesInGateway(String gatewayId, int offset, int limit, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - getAllUserProfilesInGateway_call method_call = new getAllUserProfilesInGateway_call(gatewayId, offset, limit, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class getAllUserProfilesInGateway_call extends org.apache.thrift.async.TAsyncMethodCall { - private String gatewayId; - private int offset; - private int limit; - public getAllUserProfilesInGateway_call(String gatewayId, int offset, int limit, 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.gatewayId = gatewayId; - this.offset = offset; - this.limit = limit; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getAllUserProfilesInGateway", org.apache.thrift.protocol.TMessageType.CALL, 0)); - getAllUserProfilesInGateway_args args = new getAllUserProfilesInGateway_args(); - args.setGatewayId(gatewayId); - args.setOffset(offset); - args.setLimit(limit); - args.write(prot); - prot.writeMessageEnd(); - } - - public List<org.apache.airavata.model.user.UserProfile> getResult() throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, 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_getAllUserProfilesInGateway(); - } - } - - public void getUserProfileByName(String userName, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - getUserProfileByName_call method_call = new getUserProfileByName_call(userName, gatewayId, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class getUserProfileByName_call extends org.apache.thrift.async.TAsyncMethodCall { - private String userName; - private String gatewayId; - public getUserProfileByName_call(String userName, String gatewayId, 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.userName = userName; - this.gatewayId = gatewayId; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getUserProfileByName", org.apache.thrift.protocol.TMessageType.CALL, 0)); - getUserProfileByName_args args = new getUserProfileByName_args(); - args.setUserName(userName); - args.setGatewayId(gatewayId); - args.write(prot); - prot.writeMessageEnd(); - } - - public org.apache.airavata.model.user.UserProfile getResult() throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, 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_getUserProfileByName(); - } - } - - public void doesUserExist(String userName, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { - checkReady(); - doesUserExist_call method_call = new doesUserExist_call(userName, gatewayId, resultHandler, this, ___protocolFactory, ___transport); - this.___currentMethod = method_call; - ___manager.call(method_call); - } - - public static class doesUserExist_call extends org.apache.thrift.async.TAsyncMethodCall { - private String userName; - private String gatewayId; - public doesUserExist_call(String userName, String gatewayId, 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.userName = userName; - this.gatewayId = gatewayId; - } - - public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { - prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("doesUserExist", org.apache.thrift.protocol.TMessageType.CALL, 0)); - doesUserExist_args args = new doesUserExist_args(); - args.setUserName(userName); - args.setGatewayId(gatewayId); - args.write(prot); - prot.writeMessageEnd(); - } - - public boolean getResult() throws org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException, 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_doesUserExist(); - } - } - - } - - 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("addUserProfile", new addUserProfile()); - processMap.put("updateUserProfile", new updateUserProfile()); - processMap.put("getUserProfileById", new getUserProfileById()); - processMap.put("deleteUserProfile", new deleteUserProfile()); - processMap.put("getAllUserProfilesInGateway", new getAllUserProfilesInGateway()); - processMap.put("getUserProfileByName", new getUserProfileByName()); - processMap.put("doesUserExist", new doesUserExist()); - return processMap; - } - - public static class addUserProfile<I extends Iface> extends org.apache.thrift.ProcessFunction<I, addUserProfile_args> { - public addUserProfile() { - super("addUserProfile"); - } - - public addUserProfile_args getEmptyArgsInstance() { - return new addUserProfile_args(); - } - - protected boolean isOneway() { - return false; - } - - public addUserProfile_result getResult(I iface, addUserProfile_args args) throws org.apache.thrift.TException { - addUserProfile_result result = new addUserProfile_result(); - try { - result.success = iface.addUserProfile(args.userProfile); - } catch (org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException userProfileException) { - result.userProfileException = userProfileException; - } - return result; - } - } - - public static class updateUserProfile<I extends Iface> extends org.apache.thrift.ProcessFunction<I, updateUserProfile_args> { - public updateUserProfile() { - super("updateUserProfile"); - } - - public updateUserProfile_args getEmptyArgsInstance() { - return new updateUserProfile_args(); - } - - protected boolean isOneway() { - return false; - } - - public updateUserProfile_result getResult(I iface, updateUserProfile_args args) throws org.apache.thrift.TException { - updateUserProfile_result result = new updateUserProfile_result(); - try { - result.success = iface.updateUserProfile(args.userProfile); - result.setSuccessIsSet(true); - } catch (org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException userProfileException) { - result.userProfileException = userProfileException; - } - return result; - } - } - - public static class getUserProfileById<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getUserProfileById_args> { - public getUserProfileById() { - super("getUserProfileById"); - } - - public getUserProfileById_args getEmptyArgsInstance() { - return new getUserProfileById_args(); - } - - protected boolean isOneway() { - return false; - } - - public getUserProfileById_result getResult(I iface, getUserProfileById_args args) throws org.apache.thrift.TException { - getUserProfileById_result result = new getUserProfileById_result(); - try { - result.success = iface.getUserProfileById(args.userId, args.gatewayId); - } catch (org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException userProfileException) { - result.userProfileException = userProfileException; - } - return result; - } - } - - public static class deleteUserProfile<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deleteUserProfile_args> { - public deleteUserProfile() { - super("deleteUserProfile"); - } - - public deleteUserProfile_args getEmptyArgsInstance() { - return new deleteUserProfile_args(); - } - - protected boolean isOneway() { - return false; - } - - public deleteUserProfile_result getResult(I iface, deleteUserProfile_args args) throws org.apache.thrift.TException { - deleteUserProfile_result result = new deleteUserProfile_result(); - try { - result.success = iface.deleteUserProfile(args.userId); - result.setSuccessIsSet(true); - } catch (org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException userProfileException) { - result.userProfileException = userProfileException; - } - return result; - } - } - - public static class getAllUserProfilesInGateway<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getAllUserProfilesInGateway_args> { - public getAllUserProfilesInGateway() { - super("getAllUserProfilesInGateway"); - } - - public getAllUserProfilesInGateway_args getEmptyArgsInstance() { - return new getAllUserProfilesInGateway_args(); - } - - protected boolean isOneway() { - return false; - } - - public getAllUserProfilesInGateway_result getResult(I iface, getAllUserProfilesInGateway_args args) throws org.apache.thrift.TException { - getAllUserProfilesInGateway_result result = new getAllUserProfilesInGateway_result(); - try { - result.success = iface.getAllUserProfilesInGateway(args.gatewayId, args.offset, args.limit); - } catch (org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException userProfileException) { - result.userProfileException = userProfileException; - } - return result; - } - } - - public static class getUserProfileByName<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getUserProfileByName_args> { - public getUserProfileByName() { - super("getUserProfileByName"); - } - - public getUserProfileByName_args getEmptyArgsInstance() { - return new getUserProfileByName_args(); - } - - protected boolean isOneway() { - return false; - } - - public getUserProfileByName_result getResult(I iface, getUserProfileByName_args args) throws org.apache.thrift.TException { - getUserProfileByName_result result = new getUserProfileByName_result(); - try { - result.success = iface.getUserProfileByName(args.userName, args.gatewayId); - } catch (org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException userProfileException) { - result.userProfileException = userProfileException; - } - return result; - } - } - - public static class doesUserExist<I extends Iface> extends org.apache.thrift.ProcessFunction<I, doesUserExist_args> { - public doesUserExist() { - super("doesUserExist"); - } - - public doesUserExist_args getEmptyArgsInstance() { - return new doesUserExist_args(); - } - - protected boolean isOneway() { - return false; - } - - public doesUserExist_result getResult(I iface, doesUserExist_args args) throws org.apache.thrift.TException { - doesUserExist_result result = new doesUserExist_result(); - try { - result.success = iface.doesUserExist(args.userName, args.gatewayId); - result.setSuccessIsSet(true); - } catch (org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException userProfileException) { - result.userProfileException = userProfileException; - } - 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("addUserProfile", new addUserProfile()); - processMap.put("updateUserProfile", new updateUserProfile()); - processMap.put("getUserProfileById", new getUserProfileById()); - processMap.put("deleteUserProfile", new deleteUserProfile()); - processMap.put("getAllUserProfilesInGateway", new getAllUserProfilesInGateway()); - processMap.put("getUserProfileByName", new getUserProfileByName()); - processMap.put("doesUserExist", new doesUserExist()); - return processMap; - } - - public static class addUserProfile<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, addUserProfile_args, String> { - public addUserProfile() { - super("addUserProfile"); - } - - public addUserProfile_args getEmptyArgsInstance() { - return new addUserProfile_args(); - } - - public AsyncMethodCallback<String> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<String>() { - public void onComplete(String o) { - addUserProfile_result result = new addUserProfile_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; - addUserProfile_result result = new addUserProfile_result(); - if (e instanceof org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException) { - result.userProfileException = (org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException) e; - result.setUserProfileExceptionIsSet(true); - msg = result; - } - else - { - 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, addUserProfile_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { - iface.addUserProfile(args.userProfile,resultHandler); - } - } - - public static class updateUserProfile<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, updateUserProfile_args, Boolean> { - public updateUserProfile() { - super("updateUserProfile"); - } - - public updateUserProfile_args getEmptyArgsInstance() { - return new updateUserProfile_args(); - } - - public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Boolean>() { - public void onComplete(Boolean o) { - updateUserProfile_result result = new updateUserProfile_result(); - result.success = o; - result.setSuccessIsSet(true); - 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; - updateUserProfile_result result = new updateUserProfile_result(); - if (e instanceof org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException) { - result.userProfileException = (org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException) e; - result.setUserProfileExceptionIsSet(true); - msg = result; - } - else - { - 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, updateUserProfile_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.updateUserProfile(args.userProfile,resultHandler); - } - } - - public static class getUserProfileById<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUserProfileById_args, org.apache.airavata.model.user.UserProfile> { - public getUserProfileById() { - super("getUserProfileById"); - } - - public getUserProfileById_args getEmptyArgsInstance() { - return new getUserProfileById_args(); - } - - public AsyncMethodCallback<org.apache.airavata.model.user.UserProfile> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<org.apache.airavata.model.user.UserProfile>() { - public void onComplete(org.apache.airavata.model.user.UserProfile o) { - getUserProfileById_result result = new getUserProfileById_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; - getUserProfileById_result result = new getUserProfileById_result(); - if (e instanceof org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException) { - result.userProfileException = (org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException) e; - result.setUserProfileExceptionIsSet(true); - msg = result; - } - else - { - 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, getUserProfileById_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.user.UserProfile> resultHandler) throws TException { - iface.getUserProfileById(args.userId, args.gatewayId,resultHandler); - } - } - - public static class deleteUserProfile<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteUserProfile_args, Boolean> { - public deleteUserProfile() { - super("deleteUserProfile"); - } - - public deleteUserProfile_args getEmptyArgsInstance() { - return new deleteUserProfile_args(); - } - - public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Boolean>() { - public void onComplete(Boolean o) { - deleteUserProfile_result result = new deleteUserProfile_result(); - result.success = o; - result.setSuccessIsSet(true); - 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; - deleteUserProfile_result result = new deleteUserProfile_result(); - if (e instanceof org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException) { - result.userProfileException = (org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException) e; - result.setUserProfileExceptionIsSet(true); - msg = result; - } - else - { - 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, deleteUserProfile_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.deleteUserProfile(args.userId,resultHandler); - } - } - - public static class getAllUserProfilesInGateway<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getAllUserProfilesInGateway_args, List<org.apache.airavata.model.user.UserProfile>> { - public getAllUserProfilesInGateway() { - super("getAllUserProfilesInGateway"); - } - - public getAllUserProfilesInGateway_args getEmptyArgsInstance() { - return new getAllUserProfilesInGateway_args(); - } - - public AsyncMethodCallback<List<org.apache.airavata.model.user.UserProfile>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.model.user.UserProfile>>() { - public void onComplete(List<org.apache.airavata.model.user.UserProfile> o) { - getAllUserProfilesInGateway_result result = new getAllUserProfilesInGateway_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; - getAllUserProfilesInGateway_result result = new getAllUserProfilesInGateway_result(); - if (e instanceof org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException) { - result.userProfileException = (org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException) e; - result.setUserProfileExceptionIsSet(true); - msg = result; - } - else - { - 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, getAllUserProfilesInGateway_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.model.user.UserProfile>> resultHandler) throws TException { - iface.getAllUserProfilesInGateway(args.gatewayId, args.offset, args.limit,resultHandler); - } - } - - public static class getUserProfileByName<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getUserProfileByName_args, org.apache.airavata.model.user.UserProfile> { - public getUserProfileByName() { - super("getUserProfileByName"); - } - - public getUserProfileByName_args getEmptyArgsInstance() { - return new getUserProfileByName_args(); - } - - public AsyncMethodCallback<org.apache.airavata.model.user.UserProfile> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<org.apache.airavata.model.user.UserProfile>() { - public void onComplete(org.apache.airavata.model.user.UserProfile o) { - getUserProfileByName_result result = new getUserProfileByName_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; - getUserProfileByName_result result = new getUserProfileByName_result(); - if (e instanceof org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException) { - result.userProfileException = (org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException) e; - result.setUserProfileExceptionIsSet(true); - msg = result; - } - else - { - 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, getUserProfileByName_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.user.UserProfile> resultHandler) throws TException { - iface.getUserProfileByName(args.userName, args.gatewayId,resultHandler); - } - } - - public static class doesUserExist<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, doesUserExist_args, Boolean> { - public doesUserExist() { - super("doesUserExist"); - } - - public doesUserExist_args getEmptyArgsInstance() { - return new doesUserExist_args(); - } - - public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Boolean>() { - public void onComplete(Boolean o) { - doesUserExist_result result = new doesUserExist_result(); - result.success = o; - result.setSuccessIsSet(true); - 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; - doesUserExist_result result = new doesUserExist_result(); - if (e instanceof org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException) { - result.userProfileException = (org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException) e; - result.setUserProfileExceptionIsSet(true); - msg = result; - } - else - { - 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, doesUserExist_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.doesUserExist(args.userName, args.gatewayId,resultHandler); - } - } - - } - - public static class addUserProfile_args implements org.apache.thrift.TBase<addUserProfile_args, addUserProfile_args._Fields>, java.io.Serializable, Cloneable, Comparable<addUserProfile_args> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("addUserProfile_args"); - - private static final org.apache.thrift.protocol.TField USER_PROFILE_FIELD_DESC = new org.apache.thrift.protocol.TField("userProfile", org.apache.thrift.protocol.TType.STRUCT, (short)1); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new addUserProfile_argsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new addUserProfile_argsTupleSchemeFactory()); - } - - public org.apache.airavata.model.user.UserProfile userProfile; // required - - /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - public enum _Fields implements org.apache.thrift.TFieldIdEnum { - USER_PROFILE((short)1, "userProfile"); - - private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); - - static { - for (_Fields field : EnumSet.allOf(_Fields.class)) { - byName.put(field.getFieldName(), field); - } - } - - /** - * Find the _Fields constant that matches fieldId, or null if its not found. - */ - public static _Fields findByThriftId(int fieldId) { - switch(fieldId) { - case 1: // USER_PROFILE - return USER_PROFILE; - default: - return null; - } - } - - /** - * Find the _Fields constant that matches fieldId, throwing an exception - * if it is not found. - */ - public static _Fields findByThriftIdOrThrow(int fieldId) { - _Fields fields = findByThriftId(fieldId); - if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); - return fields; - } - - /** - * Find the _Fields constant that matches name, or null if its not found. - */ - public static _Fields findByName(String name) { - return byName.get(name); - } - - private final short _thriftId; - private final String _fieldName; - - _Fields(short thriftId, String fieldName) { - _thriftId = thriftId; - _fieldName = fieldName; - } - - public short getThriftFieldId() { - return _thriftId; - } - - public String getFieldName() { - return _fieldName; - } - } - - // isset id assignments - public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; - static { - Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); - tmpMap.put(_Fields.USER_PROFILE, new org.apache.thrift.meta_data.FieldMetaData("userProfile", org.apache.thrift.TFieldRequirementType.REQUIRED, - new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, org.apache.airavata.model.user.UserProfile.class))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(addUserProfile_args.class, metaDataMap); - } - - public addUserProfile_args() { - } - - public addUserProfile_args( - org.apache.airavata.model.user.UserProfile userProfile) - { - this(); - this.userProfile = userProfile; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public addUserProfile_args(addUserProfile_args other) { - if (other.isSetUserProfile()) { - this.userProfile = new org.apache.airavata.model.user.UserProfile(other.userProfile); - } - } - - public addUserProfile_args deepCopy() { - return new addUserProfile_args(this); - } - - @Override - public void clear() { - this.userProfile = null; - } - - public org.apache.airavata.model.user.UserProfile getUserProfile() { - return this.userProfile; - } - - public addUserProfile_args setUserProfile(org.apache.airavata.model.user.UserProfile userProfile) { - this.userProfile = userProfile; - return this; - } - - public void unsetUserProfile() { - this.userProfile = null; - } - - /** Returns true if field userProfile is set (has been assigned a value) and false otherwise */ - public boolean isSetUserProfile() { - return this.userProfile != null; - } - - public void setUserProfileIsSet(boolean value) { - if (!value) { - this.userProfile = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case USER_PROFILE: - if (value == null) { - unsetUserProfile(); - } else { - setUserProfile((org.apache.airavata.model.user.UserProfile)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case USER_PROFILE: - return getUserProfile(); - - } - throw new IllegalStateException(); - } - - /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ - public boolean isSet(_Fields field) { - if (field == null) { - throw new IllegalArgumentException(); - } - - switch (field) { - case USER_PROFILE: - return isSetUserProfile(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof addUserProfile_args) - return this.equals((addUserProfile_args)that); - return false; - } - - public boolean equals(addUserProfile_args that) { - if (that == null) - return false; - - boolean this_present_userProfile = true && this.isSetUserProfile(); - boolean that_present_userProfile = true && that.isSetUserProfile(); - if (this_present_userProfile || that_present_userProfile) { - if (!(this_present_userProfile && that_present_userProfile)) - return false; - if (!this.userProfile.equals(that.userProfile)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_userProfile = true && (isSetUserProfile()); - list.add(present_userProfile); - if (present_userProfile) - list.add(userProfile); - - return list.hashCode(); - } - - @Override - public int compareTo(addUserProfile_args other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(isSetUserProfile()).compareTo(other.isSetUserProfile()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetUserProfile()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.userProfile, other.userProfile); - if (lastComparison != 0) { - return lastComparison; - } - } - return 0; - } - - public _Fields fieldForId(int fieldId) { - return _Fields.findByThriftId(fieldId); - } - - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { - schemes.get(iprot.getScheme()).getScheme().read(iprot, this); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { - schemes.get(oprot.getScheme()).getScheme().write(oprot, this); - } - - @Override - public String toString() { - StringBuilder sb = new StringBuilder("addUserProfile_args("); - boolean first = true; - - sb.append("userProfile:"); - if (this.userProfile == null) { - sb.append("null"); - } else { - sb.append(this.userProfile); - } - first = false; - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - if (userProfile == null) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'userProfile' was not present! Struct: " + toString()); - } - // check for sub-struct validity - if (userProfile != null) { - userProfile.validate(); - } - } - - private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { - try { - write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { - try { - read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private static class addUserProfile_argsStandardSchemeFactory implements SchemeFactory { - public addUserProfile_argsStandardScheme getScheme() { - return new addUserProfile_argsStandardScheme(); - } - } - - private static class addUserProfile_argsStandardScheme extends StandardScheme<addUserProfile_args> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, addUserProfile_args struct) throws org.apache.thrift.TException { - org.apache.thrift.protocol.TField schemeField; - iprot.readStructBegin(); - while (true) - { - schemeField = iprot.readFieldBegin(); - if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { - break; - } - switch (schemeField.id) { - case 1: // USER_PROFILE - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.userProfile = new org.apache.airavata.model.user.UserProfile(); - struct.userProfile.read(iprot); - struct.setUserProfileIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - default: - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - iprot.readFieldEnd(); - } - iprot.readStructEnd(); - - // check for required fields of primitive type, which can't be checked in the validate method - struct.validate(); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot, addUserProfile_args struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.userProfile != null) { - oprot.writeFieldBegin(USER_PROFILE_FIELD_DESC); - struct.userProfile.write(oprot); - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class addUserProfile_argsTupleSchemeFactory implements SchemeFactory { - public addUserProfile_argsTupleScheme getScheme() { - return new addUserProfile_argsTupleScheme(); - } - } - - private static class addUserProfile_argsTupleScheme extends TupleScheme<addUserProfile_args> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, addUserProfile_args struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - struct.userProfile.write(oprot); - } - - @Override - public void read(org.apache.thrift.protocol.TProtocol prot, addUserProfile_args struct) throws org.apache.thrift.TException { - TTupleProtocol iprot = (TTupleProtocol) prot; - struct.userProfile = new org.apache.airavata.model.user.UserProfile(); - struct.userProfile.read(iprot); - struct.setUserProfileIsSet(true); - } - } - - } - - public static class addUserProfile_result implements org.apache.thrift.TBase<addUserProfile_result, addUserProfile_result._Fields>, java.io.Serializable, Cloneable, Comparable<addUserProfile_result> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("addUserProfile_result"); - - private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRING, (short)0); - private static final org.apache.thrift.protocol.TField USER_PROFILE_EXCEPTION_FIELD_DESC = new org.apache.thrift.protocol.TField("userProfileException", org.apache.thrift.protocol.TType.STRUCT, (short)1); - - private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); - static { - schemes.put(StandardScheme.class, new addUserProfile_resultStandardSchemeFactory()); - schemes.put(TupleScheme.class, new addUserProfile_resultTupleSchemeFactory()); - } - - public String success; // required - public org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException userProfileException; // required - - /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ - public enum _Fields implements org.apache.thrift.TFieldIdEnum { - SUCCESS((short)0, "success"), - USER_PROFILE_EXCEPTION((short)1, "userProfileException"); - - private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); - - static { - for (_Fields field : EnumSet.allOf(_Fields.class)) { - byName.put(field.getFieldName(), field); - } - } - - /** - * Find the _Fields constant that matches fieldId, or null if its not found. - */ - public static _Fields findByThriftId(int fieldId) { - switch(fieldId) { - case 0: // SUCCESS - return SUCCESS; - case 1: // USER_PROFILE_EXCEPTION - return USER_PROFILE_EXCEPTION; - default: - return null; - } - } - - /** - * Find the _Fields constant that matches fieldId, throwing an exception - * if it is not found. - */ - public static _Fields findByThriftIdOrThrow(int fieldId) { - _Fields fields = findByThriftId(fieldId); - if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); - return fields; - } - - /** - * Find the _Fields constant that matches name, or null if its not found. - */ - public static _Fields findByName(String name) { - return byName.get(name); - } - - private final short _thriftId; - private final String _fieldName; - - _Fields(short thriftId, String fieldName) { - _thriftId = thriftId; - _fieldName = fieldName; - } - - public short getThriftFieldId() { - return _thriftId; - } - - public String getFieldName() { - return _fieldName; - } - } - - // isset id assignments - public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; - static { - Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); - tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); - tmpMap.put(_Fields.USER_PROFILE_EXCEPTION, new org.apache.thrift.meta_data.FieldMetaData("userProfileException", org.apache.thrift.TFieldRequirementType.DEFAULT, - new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT))); - metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(addUserProfile_result.class, metaDataMap); - } - - public addUserProfile_result() { - } - - public addUserProfile_result( - String success, - org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException userProfileException) - { - this(); - this.success = success; - this.userProfileException = userProfileException; - } - - /** - * Performs a deep copy on <i>other</i>. - */ - public addUserProfile_result(addUserProfile_result other) { - if (other.isSetSuccess()) { - this.success = other.success; - } - if (other.isSetUserProfileException()) { - this.userProfileException = new org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException(other.userProfileException); - } - } - - public addUserProfile_result deepCopy() { - return new addUserProfile_result(this); - } - - @Override - public void clear() { - this.success = null; - this.userProfileException = null; - } - - public String getSuccess() { - return this.success; - } - - public addUserProfile_result setSuccess(String success) { - this.success = success; - return this; - } - - public void unsetSuccess() { - this.success = null; - } - - /** Returns true if field success is set (has been assigned a value) and false otherwise */ - public boolean isSetSuccess() { - return this.success != null; - } - - public void setSuccessIsSet(boolean value) { - if (!value) { - this.success = null; - } - } - - public org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException getUserProfileException() { - return this.userProfileException; - } - - public addUserProfile_result setUserProfileException(org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException userProfileException) { - this.userProfileException = userProfileException; - return this; - } - - public void unsetUserProfileException() { - this.userProfileException = null; - } - - /** Returns true if field userProfileException is set (has been assigned a value) and false otherwise */ - public boolean isSetUserProfileException() { - return this.userProfileException != null; - } - - public void setUserProfileExceptionIsSet(boolean value) { - if (!value) { - this.userProfileException = null; - } - } - - public void setFieldValue(_Fields field, Object value) { - switch (field) { - case SUCCESS: - if (value == null) { - unsetSuccess(); - } else { - setSuccess((String)value); - } - break; - - case USER_PROFILE_EXCEPTION: - if (value == null) { - unsetUserProfileException(); - } else { - setUserProfileException((org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException)value); - } - break; - - } - } - - public Object getFieldValue(_Fields field) { - switch (field) { - case SUCCESS: - return getSuccess(); - - case USER_PROFILE_EXCEPTION: - return getUserProfileException(); - - } - throw new IllegalStateException(); - } - - /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ - public boolean isSet(_Fields field) { - if (field == null) { - throw new IllegalArgumentException(); - } - - switch (field) { - case SUCCESS: - return isSetSuccess(); - case USER_PROFILE_EXCEPTION: - return isSetUserProfileException(); - } - throw new IllegalStateException(); - } - - @Override - public boolean equals(Object that) { - if (that == null) - return false; - if (that instanceof addUserProfile_result) - return this.equals((addUserProfile_result)that); - return false; - } - - public boolean equals(addUserProfile_result that) { - if (that == null) - return false; - - boolean this_present_success = true && this.isSetSuccess(); - boolean that_present_success = true && that.isSetSuccess(); - if (this_present_success || that_present_success) { - if (!(this_present_success && that_present_success)) - return false; - if (!this.success.equals(that.success)) - return false; - } - - boolean this_present_userProfileException = true && this.isSetUserProfileException(); - boolean that_present_userProfileException = true && that.isSetUserProfileException(); - if (this_present_userProfileException || that_present_userProfileException) { - if (!(this_present_userProfileException && that_present_userProfileException)) - return false; - if (!this.userProfileException.equals(that.userProfileException)) - return false; - } - - return true; - } - - @Override - public int hashCode() { - List<Object> list = new ArrayList<Object>(); - - boolean present_success = true && (isSetSuccess()); - list.add(present_success); - if (present_success) - list.add(success); - - boolean present_userProfileException = true && (isSetUserProfileException()); - list.add(present_userProfileException); - if (present_userProfileException) - list.add(userProfileException); - - return list.hashCode(); - } - - @Override - public int compareTo(addUserProfile_result other) { - if (!getClass().equals(other.getClass())) { - return getClass().getName().compareTo(other.getClass().getName()); - } - - int lastComparison = 0; - - lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(other.isSetSuccess()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetSuccess()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, other.success); - if (lastComparison != 0) { - return lastComparison; - } - } - lastComparison = Boolean.valueOf(isSetUserProfileException()).compareTo(other.isSetUserProfileException()); - if (lastComparison != 0) { - return lastComparison; - } - if (isSetUserProfileException()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.userProfileException, other.userProfileException); - if (lastComparison != 0) { - return lastComparison; - } - } - return 0; - } - - public _Fields fieldForId(int fieldId) { - return _Fields.findByThriftId(fieldId); - } - - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { - schemes.get(iprot.getScheme()).getScheme().read(iprot, this); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { - schemes.get(oprot.getScheme()).getScheme().write(oprot, this); - } - - @Override - public String toString() { - StringBuilder sb = new StringBuilder("addUserProfile_result("); - boolean first = true; - - sb.append("success:"); - if (this.success == null) { - sb.append("null"); - } else { - sb.append(this.success); - } - first = false; - if (!first) sb.append(", "); - sb.append("userProfileException:"); - if (this.userProfileException == null) { - sb.append("null"); - } else { - sb.append(this.userProfileException); - } - first = false; - sb.append(")"); - return sb.toString(); - } - - public void validate() throws org.apache.thrift.TException { - // check for required fields - // check for sub-struct validity - } - - private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { - try { - write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { - try { - read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { - throw new java.io.IOException(te); - } - } - - private static class addUserProfile_resultStandardSchemeFactory implements SchemeFactory { - public addUserProfile_resultStandardScheme getScheme() { - return new addUserProfile_resultStandardScheme(); - } - } - - private static class addUserProfile_resultStandardScheme extends StandardScheme<addUserProfile_result> { - - public void read(org.apache.thrift.protocol.TProtocol iprot, addUserProfile_result struct) throws org.apache.thrift.TException { - org.apache.thrift.protocol.TField schemeField; - iprot.readStructBegin(); - while (true) - { - schemeField = iprot.readFieldBegin(); - if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { - break; - } - switch (schemeField.id) { - case 0: // SUCCESS - if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { - struct.success = iprot.readString(); - struct.setSuccessIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - case 1: // USER_PROFILE_EXCEPTION - if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.userProfileException = new org.apache.airavata.userprofile.cpi.exception.UserProfileServiceException(); - struct.userProfileException.read(iprot); - struct.setUserProfileExceptionIsSet(true); - } else { - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - break; - default: - org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); - } - iprot.readFieldEnd(); - } - iprot.readStructEnd(); - - // check for required fields of primitive type, which can't be checked in the validate method - struct.validate(); - } - - public void write(org.apache.thrift.protocol.TProtocol oprot, addUserProfile_result struct) throws org.apache.thrift.TException { - struct.validate(); - - oprot.writeStructBegin(STRUCT_DESC); - if (struct.success != null) { - oprot.writeFieldBegin(SUCCESS_FIELD_DESC); - oprot.writeString(struct.success); - oprot.writeFieldEnd(); - } - if (struct.userProfileException != null) { - oprot.writeFieldBegin(USER_PROFILE_EXCEPTION_FIELD_DESC); - struct.userProfileException.write(oprot); - oprot.writeFieldEnd(); - } - oprot.writeFieldStop(); - oprot.writeStructEnd(); - } - - } - - private static class addUserProfile_resultTupleSchemeFactory implements SchemeFactory { - public addUserProfile_resultTupleScheme getScheme() { - return new addUserProfile_resultTupleScheme(); - } - } - - private static class addUserProfile_resultTupleScheme extends TupleScheme<addUserProfile_result> { - - @Override - public void write(org.apache.thrift.protocol.TProtocol prot, addUserProfile_result struct) throws org.apache.thrift.TException { - TTupleProtocol oprot = (TTupleProtocol) prot; - BitSet optionals = new BitSet(); - if (struct.isSetSuccess()) { - optionals.set(0); - } - if (struct.isSetUserProfileException()) { - optionals.set(1); - } - oprot.writeBitSet(optio
<TRUNCATED>
