This is an automated email from the ASF dual-hosted git repository. machristie pushed a commit to branch registry-refactoring in repository https://gitbox.apache.org/repos/asf/airavata.git
commit 26f9d3dcdc7999e73aaff0bfa2589c1d0c7c5528 Author: Abhiit Karanjkar <[email protected]> AuthorDate: Tue Nov 29 15:03:57 2016 -0500 Adding offset and limit filed to user-profile cpi --- .../workspacecatalog/UserProfileRepository.java | 4 +- .../server/UserProfileHandler.java | 9 +- .../crude/cpi/UserProfileCrudeService.java | 674 +++++++++++++-------- .../crude/cpi/user_profile_crud_cpiConstants.java | 16 - 4 files changed, 438 insertions(+), 265 deletions(-) diff --git a/modules/registry-refactoring/src/main/java/org/apache/airavata/registry/core/repositories/workspacecatalog/UserProfileRepository.java b/modules/registry-refactoring/src/main/java/org/apache/airavata/registry/core/repositories/workspacecatalog/UserProfileRepository.java index 7c5bd4b..de0f99e 100644 --- a/modules/registry-refactoring/src/main/java/org/apache/airavata/registry/core/repositories/workspacecatalog/UserProfileRepository.java +++ b/modules/registry-refactoring/src/main/java/org/apache/airavata/registry/core/repositories/workspacecatalog/UserProfileRepository.java @@ -60,12 +60,12 @@ public class UserProfileRepository extends AbstractRepository<UserProfile, UserP return userProfile; } - public List<UserProfile> getAllUserProfilesInGateway(String gatewayId) { + public List<UserProfile> getAllUserProfilesInGateway(String gatewayId, int offset, int limit) { Map<String, Object> queryParam = new HashMap<String, Object>(); queryParam.put(UserProfile._Fields.GATEWAY_ID.getFieldName(), gatewayId); - List<UserProfile> resultList = select(QueryConstants.FIND_ALL_USER_PROFILES_BY_GATEWAY_ID, 0, 1, queryParam); + List<UserProfile> resultList = select(QueryConstants.FIND_ALL_USER_PROFILES_BY_GATEWAY_ID, limit, offset, queryParam); return resultList; } diff --git a/modules/user-profile/user-profile-service/src/main/java/com.apache.airavata.user.profile/server/UserProfileHandler.java b/modules/user-profile/user-profile-service/src/main/java/com.apache.airavata.user.profile/server/UserProfileHandler.java index 8f04204..6c2726d 100644 --- a/modules/user-profile/user-profile-service/src/main/java/com.apache.airavata.user.profile/server/UserProfileHandler.java +++ b/modules/user-profile/user-profile-service/src/main/java/com.apache.airavata.user.profile/server/UserProfileHandler.java @@ -60,12 +60,13 @@ public class UserProfileHandler implements UserProfileCrudeService.Iface { return deleteResult; } - public List<UserProfile> getAllUserProfilesInGateway(String gatewayId) throws RegistryServiceException, TException { + public List<UserProfile> getAllUserProfilesInGateway(String gatewayId, int offset, int limit) throws RegistryServiceException, TException { - List<UserProfile> usersInGateway = userProfileRepository.getAllUserProfilesInGateway(gatewayId); + List<UserProfile> usersInGateway = userProfileRepository.getAllUserProfilesInGateway(gatewayId, offset, limit); return usersInGateway; } + public UserProfile getUserProfileByName(String userName, String gatewayId) throws RegistryServiceException, TException { UserProfile userProfile = userProfileRepository.getUserProfileByNameAndGateWay(userName, gatewayId); @@ -76,8 +77,8 @@ public class UserProfileHandler implements UserProfileCrudeService.Iface { UserProfile userProfile = userProfileRepository.getUserProfileByNameAndGateWay(userName, gatewayId); - if(null != userProfile) - return true; + if (null != userProfile) + return true; return false; } } diff --git a/modules/user-profile/user-profile-stubs/src/main/java/org/apache/airavata/userprofile/crude/cpi/UserProfileCrudeService.java b/modules/user-profile/user-profile-stubs/src/main/java/org/apache/airavata/userprofile/crude/cpi/UserProfileCrudeService.java index afa0efd..7692d99 100644 --- a/modules/user-profile/user-profile-stubs/src/main/java/org/apache/airavata/userprofile/crude/cpi/UserProfileCrudeService.java +++ b/modules/user-profile/user-profile-stubs/src/main/java/org/apache/airavata/userprofile/crude/cpi/UserProfileCrudeService.java @@ -1,19 +1,3 @@ - /* - * 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) * @@ -50,42 +34,42 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-11-08") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-11-29") public class UserProfileCrudeService { public interface Iface { - public String addUserProfile(org.apache.airavata.model.user.UserProfile userProfile) throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException; + public String addUserProfile(org.apache.airavata.model.user.UserProfile userProfile) throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException; - public boolean updateUserProfile(org.apache.airavata.model.user.UserProfile userProfile) throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException; + public boolean updateUserProfile(org.apache.airavata.model.user.UserProfile userProfile) throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException; - public org.apache.airavata.model.user.UserProfile getUserProfileById(String userId, String gatewayId) throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException; + public org.apache.airavata.model.user.UserProfile getUserProfileById(String userId, String gatewayId) throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException; - public boolean deleteUserProfile(String userId) throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException; + public boolean deleteUserProfile(String userId) throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException; - public List<org.apache.airavata.model.user.UserProfile> getAllUserProfilesInGateway(String gatewayId) throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException; + public List<org.apache.airavata.model.user.UserProfile> getAllUserProfilesInGateway(String gatewayId, int offset, int limit) throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException; - public org.apache.airavata.model.user.UserProfile getUserProfileByName(String userName, String gatewayId) throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException; + public org.apache.airavata.model.user.UserProfile getUserProfileByName(String userName, String gatewayId) throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException; - public boolean doesUserExist(String userName, String gatewayId) throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException; + public boolean doesUserExist(String userName, String gatewayId) throws org.apache.airavata.registry.api.exception.RegistryServiceException, 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 addUserProfile(org.apache.airavata.model.user.UserProfile userProfile, AsyncMethodCallback resultHandler) throws TException; - public void updateUserProfile(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, AsyncMethodCallback resultHandler) throws TException; - public void getUserProfileById(String userId, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getUserProfileById(String userId, String gatewayId, AsyncMethodCallback resultHandler) throws TException; - public void deleteUserProfile(String userId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void deleteUserProfile(String userId, AsyncMethodCallback resultHandler) throws TException; - public void getAllUserProfilesInGateway(String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getAllUserProfilesInGateway(String gatewayId, int offset, int limit, AsyncMethodCallback resultHandler) throws TException; - public void getUserProfileByName(String userName, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void getUserProfileByName(String userName, String gatewayId, AsyncMethodCallback resultHandler) throws TException; - public void doesUserExist(String userName, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void doesUserExist(String userName, String gatewayId, AsyncMethodCallback resultHandler) throws TException; } @@ -109,20 +93,20 @@ public class UserProfileCrudeService { super(iprot, oprot); } - public String addUserProfile(org.apache.airavata.model.user.UserProfile userProfile) throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException + public String addUserProfile(org.apache.airavata.model.user.UserProfile userProfile) throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException { send_addUserProfile(userProfile); return recv_addUserProfile(); } - public void send_addUserProfile(org.apache.airavata.model.user.UserProfile userProfile) throws org.apache.thrift.TException + public void send_addUserProfile(org.apache.airavata.model.user.UserProfile userProfile) throws TException { addUserProfile_args args = new addUserProfile_args(); args.setUserProfile(userProfile); sendBase("addUserProfile", args); } - public String recv_addUserProfile() throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException + public String recv_addUserProfile() throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException { addUserProfile_result result = new addUserProfile_result(); receiveBase(result, "addUserProfile"); @@ -135,20 +119,20 @@ public class UserProfileCrudeService { 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.registry.api.exception.RegistryServiceException, org.apache.thrift.TException + public boolean updateUserProfile(org.apache.airavata.model.user.UserProfile userProfile) throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException { send_updateUserProfile(userProfile); return recv_updateUserProfile(); } - public void send_updateUserProfile(org.apache.airavata.model.user.UserProfile userProfile) throws org.apache.thrift.TException + public void send_updateUserProfile(org.apache.airavata.model.user.UserProfile userProfile) throws TException { updateUserProfile_args args = new updateUserProfile_args(); args.setUserProfile(userProfile); sendBase("updateUserProfile", args); } - public boolean recv_updateUserProfile() throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException + public boolean recv_updateUserProfile() throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException { updateUserProfile_result result = new updateUserProfile_result(); receiveBase(result, "updateUserProfile"); @@ -161,13 +145,13 @@ public class UserProfileCrudeService { 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.registry.api.exception.RegistryServiceException, org.apache.thrift.TException + public org.apache.airavata.model.user.UserProfile getUserProfileById(String userId, String gatewayId) throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException { send_getUserProfileById(userId, gatewayId); return recv_getUserProfileById(); } - public void send_getUserProfileById(String userId, String gatewayId) throws org.apache.thrift.TException + public void send_getUserProfileById(String userId, String gatewayId) throws TException { getUserProfileById_args args = new getUserProfileById_args(); args.setUserId(userId); @@ -175,7 +159,7 @@ public class UserProfileCrudeService { sendBase("getUserProfileById", args); } - public org.apache.airavata.model.user.UserProfile recv_getUserProfileById() throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException + public org.apache.airavata.model.user.UserProfile recv_getUserProfileById() throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException { getUserProfileById_result result = new getUserProfileById_result(); receiveBase(result, "getUserProfileById"); @@ -188,20 +172,20 @@ public class UserProfileCrudeService { 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.registry.api.exception.RegistryServiceException, org.apache.thrift.TException + public boolean deleteUserProfile(String userId) throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException { send_deleteUserProfile(userId); return recv_deleteUserProfile(); } - public void send_deleteUserProfile(String userId) throws org.apache.thrift.TException + public void send_deleteUserProfile(String userId) throws TException { deleteUserProfile_args args = new deleteUserProfile_args(); args.setUserId(userId); sendBase("deleteUserProfile", args); } - public boolean recv_deleteUserProfile() throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException + public boolean recv_deleteUserProfile() throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException { deleteUserProfile_result result = new deleteUserProfile_result(); receiveBase(result, "deleteUserProfile"); @@ -214,20 +198,22 @@ public class UserProfileCrudeService { 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) throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException + public List<org.apache.airavata.model.user.UserProfile> getAllUserProfilesInGateway(String gatewayId, int offset, int limit) throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException { - send_getAllUserProfilesInGateway(gatewayId); + send_getAllUserProfilesInGateway(gatewayId, offset, limit); return recv_getAllUserProfilesInGateway(); } - public void send_getAllUserProfilesInGateway(String gatewayId) throws org.apache.thrift.TException + public void send_getAllUserProfilesInGateway(String gatewayId, int offset, int limit) throws 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.registry.api.exception.RegistryServiceException, org.apache.thrift.TException + public List<org.apache.airavata.model.user.UserProfile> recv_getAllUserProfilesInGateway() throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException { getAllUserProfilesInGateway_result result = new getAllUserProfilesInGateway_result(); receiveBase(result, "getAllUserProfilesInGateway"); @@ -240,13 +226,13 @@ public class UserProfileCrudeService { 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.registry.api.exception.RegistryServiceException, org.apache.thrift.TException + public org.apache.airavata.model.user.UserProfile getUserProfileByName(String userName, String gatewayId) throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException { send_getUserProfileByName(userName, gatewayId); return recv_getUserProfileByName(); } - public void send_getUserProfileByName(String userName, String gatewayId) throws org.apache.thrift.TException + public void send_getUserProfileByName(String userName, String gatewayId) throws TException { getUserProfileByName_args args = new getUserProfileByName_args(); args.setUserName(userName); @@ -254,7 +240,7 @@ public class UserProfileCrudeService { sendBase("getUserProfileByName", args); } - public org.apache.airavata.model.user.UserProfile recv_getUserProfileByName() throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException + public org.apache.airavata.model.user.UserProfile recv_getUserProfileByName() throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException { getUserProfileByName_result result = new getUserProfileByName_result(); receiveBase(result, "getUserProfileByName"); @@ -267,13 +253,13 @@ public class UserProfileCrudeService { 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.registry.api.exception.RegistryServiceException, org.apache.thrift.TException + public boolean doesUserExist(String userName, String gatewayId) throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException { send_doesUserExist(userName, gatewayId); return recv_doesUserExist(); } - public void send_doesUserExist(String userName, String gatewayId) throws org.apache.thrift.TException + public void send_doesUserExist(String userName, String gatewayId) throws TException { doesUserExist_args args = new doesUserExist_args(); args.setUserName(userName); @@ -281,7 +267,7 @@ public class UserProfileCrudeService { sendBase("doesUserExist", args); } - public boolean recv_doesUserExist() throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException + public boolean recv_doesUserExist() throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException { doesUserExist_result result = new doesUserExist_result(); receiveBase(result, "doesUserExist"); @@ -312,7 +298,7 @@ public class UserProfileCrudeService { 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 { + public void addUserProfile(org.apache.airavata.model.user.UserProfile userProfile, AsyncMethodCallback resultHandler) throws TException { checkReady(); addUserProfile_call method_call = new addUserProfile_call(userProfile, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -321,12 +307,12 @@ public class UserProfileCrudeService { 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 { + public addUserProfile_call(org.apache.airavata.model.user.UserProfile userProfile, AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws 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 { + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws 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); @@ -334,8 +320,8 @@ public class UserProfileCrudeService { prot.writeMessageEnd(); } - public String getResult() throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + public String getResult() throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException { + if (getState() != State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); @@ -344,7 +330,7 @@ public class UserProfileCrudeService { } } - public void updateUserProfile(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, AsyncMethodCallback resultHandler) throws TException { checkReady(); updateUserProfile_call method_call = new updateUserProfile_call(userProfile, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -353,12 +339,12 @@ public class UserProfileCrudeService { 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 { + public updateUserProfile_call(org.apache.airavata.model.user.UserProfile userProfile, AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws 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 { + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws 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); @@ -366,8 +352,8 @@ public class UserProfileCrudeService { prot.writeMessageEnd(); } - public boolean getResult() throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + public boolean getResult() throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException { + if (getState() != State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); @@ -376,7 +362,7 @@ public class UserProfileCrudeService { } } - public void getUserProfileById(String userId, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void getUserProfileById(String userId, String gatewayId, AsyncMethodCallback resultHandler) throws TException { checkReady(); getUserProfileById_call method_call = new getUserProfileById_call(userId, gatewayId, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -386,13 +372,13 @@ public class UserProfileCrudeService { 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 { + public getUserProfileById_call(String userId, String gatewayId, AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws 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 { + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws 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); @@ -401,8 +387,8 @@ public class UserProfileCrudeService { prot.writeMessageEnd(); } - public org.apache.airavata.model.user.UserProfile getResult() throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + public org.apache.airavata.model.user.UserProfile getResult() throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException { + if (getState() != State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); @@ -411,7 +397,7 @@ public class UserProfileCrudeService { } } - public void deleteUserProfile(String userId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void deleteUserProfile(String userId, AsyncMethodCallback resultHandler) throws TException { checkReady(); deleteUserProfile_call method_call = new deleteUserProfile_call(userId, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -420,12 +406,12 @@ public class UserProfileCrudeService { 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 { + public deleteUserProfile_call(String userId, AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws 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 { + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws 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); @@ -433,8 +419,8 @@ public class UserProfileCrudeService { prot.writeMessageEnd(); } - public boolean getResult() throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + public boolean getResult() throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException { + if (getState() != State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); @@ -443,30 +429,36 @@ public class UserProfileCrudeService { } } - public void getAllUserProfilesInGateway(String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void getAllUserProfilesInGateway(String gatewayId, int offset, int limit, AsyncMethodCallback resultHandler) throws TException { checkReady(); - getAllUserProfilesInGateway_call method_call = new getAllUserProfilesInGateway_call(gatewayId, resultHandler, this, ___protocolFactory, ___transport); + 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; - public getAllUserProfilesInGateway_call(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 { + private int offset; + private int limit; + public getAllUserProfilesInGateway_call(String gatewayId, int offset, int limit, AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws 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 { + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws 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.registry.api.exception.RegistryServiceException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + public List<org.apache.airavata.model.user.UserProfile> getResult() throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException { + if (getState() != State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); @@ -475,7 +467,7 @@ public class UserProfileCrudeService { } } - public void getUserProfileByName(String userName, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void getUserProfileByName(String userName, String gatewayId, AsyncMethodCallback resultHandler) throws TException { checkReady(); getUserProfileByName_call method_call = new getUserProfileByName_call(userName, gatewayId, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -485,13 +477,13 @@ public class UserProfileCrudeService { 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 { + public getUserProfileByName_call(String userName, String gatewayId, AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws 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 { + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws 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); @@ -500,8 +492,8 @@ public class UserProfileCrudeService { prot.writeMessageEnd(); } - public org.apache.airavata.model.user.UserProfile getResult() throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + public org.apache.airavata.model.user.UserProfile getResult() throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException { + if (getState() != State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); @@ -510,7 +502,7 @@ public class UserProfileCrudeService { } } - public void doesUserExist(String userName, String gatewayId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + public void doesUserExist(String userName, String gatewayId, AsyncMethodCallback resultHandler) throws TException { checkReady(); doesUserExist_call method_call = new doesUserExist_call(userName, gatewayId, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; @@ -520,13 +512,13 @@ public class UserProfileCrudeService { 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 { + public doesUserExist_call(String userName, String gatewayId, AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws 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 { + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws 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); @@ -535,8 +527,8 @@ public class UserProfileCrudeService { prot.writeMessageEnd(); } - public boolean getResult() throws org.apache.airavata.registry.api.exception.RegistryServiceException, org.apache.thrift.TException { - if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + public boolean getResult() throws org.apache.airavata.registry.api.exception.RegistryServiceException, TException { + if (getState() != State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); @@ -581,7 +573,7 @@ public class UserProfileCrudeService { return false; } - public addUserProfile_result getResult(I iface, addUserProfile_args args) throws org.apache.thrift.TException { + public addUserProfile_result getResult(I iface, addUserProfile_args args) throws TException { addUserProfile_result result = new addUserProfile_result(); try { result.success = iface.addUserProfile(args.userProfile); @@ -605,7 +597,7 @@ public class UserProfileCrudeService { return false; } - public updateUserProfile_result getResult(I iface, updateUserProfile_args args) throws org.apache.thrift.TException { + public updateUserProfile_result getResult(I iface, updateUserProfile_args args) throws TException { updateUserProfile_result result = new updateUserProfile_result(); try { result.success = iface.updateUserProfile(args.userProfile); @@ -630,7 +622,7 @@ public class UserProfileCrudeService { return false; } - public getUserProfileById_result getResult(I iface, getUserProfileById_args args) throws org.apache.thrift.TException { + public getUserProfileById_result getResult(I iface, getUserProfileById_args args) throws TException { getUserProfileById_result result = new getUserProfileById_result(); try { result.success = iface.getUserProfileById(args.userId, args.gatewayId); @@ -654,7 +646,7 @@ public class UserProfileCrudeService { return false; } - public deleteUserProfile_result getResult(I iface, deleteUserProfile_args args) throws org.apache.thrift.TException { + public deleteUserProfile_result getResult(I iface, deleteUserProfile_args args) throws TException { deleteUserProfile_result result = new deleteUserProfile_result(); try { result.success = iface.deleteUserProfile(args.userId); @@ -679,10 +671,10 @@ public class UserProfileCrudeService { return false; } - public getAllUserProfilesInGateway_result getResult(I iface, getAllUserProfilesInGateway_args args) throws org.apache.thrift.TException { + public getAllUserProfilesInGateway_result getResult(I iface, getAllUserProfilesInGateway_args args) throws TException { getAllUserProfilesInGateway_result result = new getAllUserProfilesInGateway_result(); try { - result.success = iface.getAllUserProfilesInGateway(args.gatewayId); + result.success = iface.getAllUserProfilesInGateway(args.gatewayId, args.offset, args.limit); } catch (org.apache.airavata.registry.api.exception.RegistryServiceException registryException) { result.registryException = registryException; } @@ -703,7 +695,7 @@ public class UserProfileCrudeService { return false; } - public getUserProfileByName_result getResult(I iface, getUserProfileByName_args args) throws org.apache.thrift.TException { + public getUserProfileByName_result getResult(I iface, getUserProfileByName_args args) throws TException { getUserProfileByName_result result = new getUserProfileByName_result(); try { result.success = iface.getUserProfileByName(args.userName, args.gatewayId); @@ -727,7 +719,7 @@ public class UserProfileCrudeService { return false; } - public doesUserExist_result getResult(I iface, doesUserExist_args args) throws org.apache.thrift.TException { + public doesUserExist_result getResult(I iface, doesUserExist_args args) throws TException { doesUserExist_result result = new doesUserExist_result(); try { result.success = iface.doesUserExist(args.userName, args.gatewayId); @@ -814,7 +806,7 @@ public class UserProfileCrudeService { return false; } - public void start(I iface, addUserProfile_args args, org.apache.thrift.async.AsyncMethodCallback<String> resultHandler) throws TException { + public void start(I iface, addUserProfile_args args, AsyncMethodCallback<String> resultHandler) throws TException { iface.addUserProfile(args.userProfile,resultHandler); } } @@ -872,7 +864,7 @@ public class UserProfileCrudeService { return false; } - public void start(I iface, updateUserProfile_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + public void start(I iface, updateUserProfile_args args, AsyncMethodCallback<Boolean> resultHandler) throws TException { iface.updateUserProfile(args.userProfile,resultHandler); } } @@ -929,7 +921,7 @@ public class UserProfileCrudeService { return false; } - public void start(I iface, getUserProfileById_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.user.UserProfile> resultHandler) throws TException { + public void start(I iface, getUserProfileById_args args, AsyncMethodCallback<org.apache.airavata.model.user.UserProfile> resultHandler) throws TException { iface.getUserProfileById(args.userId, args.gatewayId,resultHandler); } } @@ -987,7 +979,7 @@ public class UserProfileCrudeService { return false; } - public void start(I iface, deleteUserProfile_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + public void start(I iface, deleteUserProfile_args args, AsyncMethodCallback<Boolean> resultHandler) throws TException { iface.deleteUserProfile(args.userId,resultHandler); } } @@ -1044,8 +1036,8 @@ public class UserProfileCrudeService { 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,resultHandler); + public void start(I iface, getAllUserProfilesInGateway_args args, AsyncMethodCallback<List<org.apache.airavata.model.user.UserProfile>> resultHandler) throws TException { + iface.getAllUserProfilesInGateway(args.gatewayId, args.offset, args.limit,resultHandler); } } @@ -1101,7 +1093,7 @@ public class UserProfileCrudeService { return false; } - public void start(I iface, getUserProfileByName_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.model.user.UserProfile> resultHandler) throws TException { + public void start(I iface, getUserProfileByName_args args, AsyncMethodCallback<org.apache.airavata.model.user.UserProfile> resultHandler) throws TException { iface.getUserProfileByName(args.userName, args.gatewayId,resultHandler); } } @@ -1159,7 +1151,7 @@ public class UserProfileCrudeService { return false; } - public void start(I iface, doesUserExist_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + public void start(I iface, doesUserExist_args args, AsyncMethodCallback<Boolean> resultHandler) throws TException { iface.doesUserExist(args.userName, args.gatewayId,resultHandler); } } @@ -1396,11 +1388,11 @@ public class UserProfileCrudeService { return _Fields.findByThriftId(fieldId); } - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot) throws TException { schemes.get(iprot.getScheme()).getScheme().read(iprot, this); } - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot) throws TException { schemes.get(oprot.getScheme()).getScheme().write(oprot, this); } @@ -1420,10 +1412,10 @@ public class UserProfileCrudeService { return sb.toString(); } - public void validate() throws org.apache.thrift.TException { + public void validate() throws TException { // check for required fields if (userProfile == null) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'userProfile' was not present! Struct: " + toString()); + throw new TProtocolException("Required field 'userProfile' was not present! Struct: " + toString()); } // check for sub-struct validity if (userProfile != null) { @@ -1434,7 +1426,7 @@ public class UserProfileCrudeService { 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) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -1442,7 +1434,7 @@ public class UserProfileCrudeService { 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) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -1455,7 +1447,7 @@ public class UserProfileCrudeService { 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 { + public void read(org.apache.thrift.protocol.TProtocol iprot, addUserProfile_args struct) throws TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -1485,7 +1477,7 @@ public class UserProfileCrudeService { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, addUserProfile_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, addUserProfile_args struct) throws TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -1509,13 +1501,13 @@ public class UserProfileCrudeService { 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 { + public void write(org.apache.thrift.protocol.TProtocol prot, addUserProfile_args struct) throws 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 { + public void read(org.apache.thrift.protocol.TProtocol prot, addUserProfile_args struct) throws TException { TTupleProtocol iprot = (TTupleProtocol) prot; struct.userProfile = new org.apache.airavata.model.user.UserProfile(); struct.userProfile.read(iprot); @@ -1829,11 +1821,11 @@ public class UserProfileCrudeService { return _Fields.findByThriftId(fieldId); } - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot) throws TException { schemes.get(iprot.getScheme()).getScheme().read(iprot, this); } - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot) throws TException { schemes.get(oprot.getScheme()).getScheme().write(oprot, this); } @@ -1861,7 +1853,7 @@ public class UserProfileCrudeService { return sb.toString(); } - public void validate() throws org.apache.thrift.TException { + public void validate() throws TException { // check for required fields // check for sub-struct validity } @@ -1869,7 +1861,7 @@ public class UserProfileCrudeService { 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) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -1877,7 +1869,7 @@ public class UserProfileCrudeService { 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) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -1890,7 +1882,7 @@ public class UserProfileCrudeService { 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 { + public void read(org.apache.thrift.protocol.TProtocol iprot, addUserProfile_result struct) throws TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -1928,7 +1920,7 @@ public class UserProfileCrudeService { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, addUserProfile_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, addUserProfile_result struct) throws TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -1957,7 +1949,7 @@ public class UserProfileCrudeService { 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 { + public void write(org.apache.thrift.protocol.TProtocol prot, addUserProfile_result struct) throws TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); if (struct.isSetSuccess()) { @@ -1976,7 +1968,7 @@ public class UserProfileCrudeService { } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, addUserProfile_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, addUserProfile_result struct) throws TException { TTupleProtocol iprot = (TTupleProtocol) prot; BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { @@ -2223,11 +2215,11 @@ public class UserProfileCrudeService { return _Fields.findByThriftId(fieldId); } - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot) throws TException { schemes.get(iprot.getScheme()).getScheme().read(iprot, this); } - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot) throws TException { schemes.get(oprot.getScheme()).getScheme().write(oprot, this); } @@ -2247,10 +2239,10 @@ public class UserProfileCrudeService { return sb.toString(); } - public void validate() throws org.apache.thrift.TException { + public void validate() throws TException { // check for required fields if (userProfile == null) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'userProfile' was not present! Struct: " + toString()); + throw new TProtocolException("Required field 'userProfile' was not present! Struct: " + toString()); } // check for sub-struct validity if (userProfile != null) { @@ -2261,7 +2253,7 @@ public class UserProfileCrudeService { 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) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -2269,7 +2261,7 @@ public class UserProfileCrudeService { 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) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -2282,7 +2274,7 @@ public class UserProfileCrudeService { private static class updateUserProfile_argsStandardScheme extends StandardScheme<updateUserProfile_args> { - public void read(org.apache.thrift.protocol.TProtocol iprot, updateUserProfile_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, updateUserProfile_args struct) throws TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -2312,7 +2304,7 @@ public class UserProfileCrudeService { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, updateUserProfile_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, updateUserProfile_args struct) throws TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -2336,13 +2328,13 @@ public class UserProfileCrudeService { private static class updateUserProfile_argsTupleScheme extends TupleScheme<updateUserProfile_args> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, updateUserProfile_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, updateUserProfile_args struct) throws TException { TTupleProtocol oprot = (TTupleProtocol) prot; struct.userProfile.write(oprot); } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, updateUserProfile_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, updateUserProfile_args struct) throws TException { TTupleProtocol iprot = (TTupleProtocol) prot; struct.userProfile = new org.apache.airavata.model.user.UserProfile(); struct.userProfile.read(iprot); @@ -2658,11 +2650,11 @@ public class UserProfileCrudeService { return _Fields.findByThriftId(fieldId); } - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot) throws TException { schemes.get(iprot.getScheme()).getScheme().read(iprot, this); } - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot) throws TException { schemes.get(oprot.getScheme()).getScheme().write(oprot, this); } @@ -2686,7 +2678,7 @@ public class UserProfileCrudeService { return sb.toString(); } - public void validate() throws org.apache.thrift.TException { + public void validate() throws TException { // check for required fields // check for sub-struct validity } @@ -2694,7 +2686,7 @@ public class UserProfileCrudeService { 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) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -2704,7 +2696,7 @@ public class UserProfileCrudeService { // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. __isset_bitfield = 0; read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -2717,7 +2709,7 @@ public class UserProfileCrudeService { private static class updateUserProfile_resultStandardScheme extends StandardScheme<updateUserProfile_result> { - public void read(org.apache.thrift.protocol.TProtocol iprot, updateUserProfile_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, updateUserProfile_result struct) throws TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -2755,7 +2747,7 @@ public class UserProfileCrudeService { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, updateUserProfile_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, updateUserProfile_result struct) throws TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -2784,7 +2776,7 @@ public class UserProfileCrudeService { private static class updateUserProfile_resultTupleScheme extends TupleScheme<updateUserProfile_result> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, updateUserProfile_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, updateUserProfile_result struct) throws TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); if (struct.isSetSuccess()) { @@ -2803,7 +2795,7 @@ public class UserProfileCrudeService { } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, updateUserProfile_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, updateUserProfile_result struct) throws TException { TTupleProtocol iprot = (TTupleProtocol) prot; BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { @@ -3124,11 +3116,11 @@ public class UserProfileCrudeService { return _Fields.findByThriftId(fieldId); } - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot) throws TException { schemes.get(iprot.getScheme()).getScheme().read(iprot, this); } - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot) throws TException { schemes.get(oprot.getScheme()).getScheme().write(oprot, this); } @@ -3156,13 +3148,13 @@ public class UserProfileCrudeService { return sb.toString(); } - public void validate() throws org.apache.thrift.TException { + public void validate() throws TException { // check for required fields if (userId == null) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'userId' was not present! Struct: " + toString()); + throw new TProtocolException("Required field 'userId' was not present! Struct: " + toString()); } if (gatewayId == null) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'gatewayId' was not present! Struct: " + toString()); + throw new TProtocolException("Required field 'gatewayId' was not present! Struct: " + toString()); } // check for sub-struct validity } @@ -3170,7 +3162,7 @@ public class UserProfileCrudeService { 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) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -3178,7 +3170,7 @@ public class UserProfileCrudeService { 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) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -3191,7 +3183,7 @@ public class UserProfileCrudeService { private static class getUserProfileById_argsStandardScheme extends StandardScheme<getUserProfileById_args> { - public void read(org.apache.thrift.protocol.TProtocol iprot, getUserProfileById_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, getUserProfileById_args struct) throws TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -3228,7 +3220,7 @@ public class UserProfileCrudeService { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, getUserProfileById_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, getUserProfileById_args struct) throws TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -3257,14 +3249,14 @@ public class UserProfileCrudeService { private static class getUserProfileById_argsTupleScheme extends TupleScheme<getUserProfileById_args> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, getUserProfileById_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, getUserProfileById_args struct) throws TException { TTupleProtocol oprot = (TTupleProtocol) prot; oprot.writeString(struct.userId); oprot.writeString(struct.gatewayId); } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, getUserProfileById_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, getUserProfileById_args struct) throws TException { TTupleProtocol iprot = (TTupleProtocol) prot; struct.userId = iprot.readString(); struct.setUserIdIsSet(true); @@ -3579,11 +3571,11 @@ public class UserProfileCrudeService { return _Fields.findByThriftId(fieldId); } - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot) throws TException { schemes.get(iprot.getScheme()).getScheme().read(iprot, this); } - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot) throws TException { schemes.get(oprot.getScheme()).getScheme().write(oprot, this); } @@ -3611,7 +3603,7 @@ public class UserProfileCrudeService { return sb.toString(); } - public void validate() throws org.apache.thrift.TException { + public void validate() throws TException { // check for required fields // check for sub-struct validity if (success != null) { @@ -3622,7 +3614,7 @@ public class UserProfileCrudeService { 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) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -3630,7 +3622,7 @@ public class UserProfileCrudeService { 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) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -3643,7 +3635,7 @@ public class UserProfileCrudeService { private static class getUserProfileById_resultStandardScheme extends StandardScheme<getUserProfileById_result> { - public void read(org.apache.thrift.protocol.TProtocol iprot, getUserProfileById_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, getUserProfileById_result struct) throws TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -3682,7 +3674,7 @@ public class UserProfileCrudeService { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, getUserProfileById_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, getUserProfileById_result struct) throws TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -3711,7 +3703,7 @@ public class UserProfileCrudeService { private static class getUserProfileById_resultTupleScheme extends TupleScheme<getUserProfileById_result> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, getUserProfileById_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, getUserProfileById_result struct) throws TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); if (struct.isSetSuccess()) { @@ -3730,7 +3722,7 @@ public class UserProfileCrudeService { } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, getUserProfileById_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, getUserProfileById_result struct) throws TException { TTupleProtocol iprot = (TTupleProtocol) prot; BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { @@ -3978,11 +3970,11 @@ public class UserProfileCrudeService { return _Fields.findByThriftId(fieldId); } - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot) throws TException { schemes.get(iprot.getScheme()).getScheme().read(iprot, this); } - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot) throws TException { schemes.get(oprot.getScheme()).getScheme().write(oprot, this); } @@ -4002,10 +3994,10 @@ public class UserProfileCrudeService { return sb.toString(); } - public void validate() throws org.apache.thrift.TException { + public void validate() throws TException { // check for required fields if (userId == null) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'userId' was not present! Struct: " + toString()); + throw new TProtocolException("Required field 'userId' was not present! Struct: " + toString()); } // check for sub-struct validity } @@ -4013,7 +4005,7 @@ public class UserProfileCrudeService { 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) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -4021,7 +4013,7 @@ public class UserProfileCrudeService { 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) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -4034,7 +4026,7 @@ public class UserProfileCrudeService { private static class deleteUserProfile_argsStandardScheme extends StandardScheme<deleteUserProfile_args> { - public void read(org.apache.thrift.protocol.TProtocol iprot, deleteUserProfile_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, deleteUserProfile_args struct) throws TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -4063,7 +4055,7 @@ public class UserProfileCrudeService { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, deleteUserProfile_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, deleteUserProfile_args struct) throws TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -4087,13 +4079,13 @@ public class UserProfileCrudeService { private static class deleteUserProfile_argsTupleScheme extends TupleScheme<deleteUserProfile_args> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, deleteUserProfile_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, deleteUserProfile_args struct) throws TException { TTupleProtocol oprot = (TTupleProtocol) prot; oprot.writeString(struct.userId); } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, deleteUserProfile_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, deleteUserProfile_args struct) throws TException { TTupleProtocol iprot = (TTupleProtocol) prot; struct.userId = iprot.readString(); struct.setUserIdIsSet(true); @@ -4408,11 +4400,11 @@ public class UserProfileCrudeService { return _Fields.findByThriftId(fieldId); } - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot) throws TException { schemes.get(iprot.getScheme()).getScheme().read(iprot, this); } - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot) throws TException { schemes.get(oprot.getScheme()).getScheme().write(oprot, this); } @@ -4436,7 +4428,7 @@ public class UserProfileCrudeService { return sb.toString(); } - public void validate() throws org.apache.thrift.TException { + public void validate() throws TException { // check for required fields // check for sub-struct validity } @@ -4444,7 +4436,7 @@ public class UserProfileCrudeService { 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) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -4454,7 +4446,7 @@ public class UserProfileCrudeService { // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. __isset_bitfield = 0; read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -4467,7 +4459,7 @@ public class UserProfileCrudeService { private static class deleteUserProfile_resultStandardScheme extends StandardScheme<deleteUserProfile_result> { - public void read(org.apache.thrift.protocol.TProtocol iprot, deleteUserProfile_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, deleteUserProfile_result struct) throws TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -4505,7 +4497,7 @@ public class UserProfileCrudeService { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, deleteUserProfile_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, deleteUserProfile_result struct) throws TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -4534,7 +4526,7 @@ public class UserProfileCrudeService { private static class deleteUserProfile_resultTupleScheme extends TupleScheme<deleteUserProfile_result> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, deleteUserProfile_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, deleteUserProfile_result struct) throws TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); if (struct.isSetSuccess()) { @@ -4553,7 +4545,7 @@ public class UserProfileCrudeService { } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, deleteUserProfile_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, deleteUserProfile_result struct) throws TException { TTupleProtocol iprot = (TTupleProtocol) prot; BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { @@ -4574,6 +4566,8 @@ public class UserProfileCrudeService { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getAllUserProfilesInGateway_args"); private static final org.apache.thrift.protocol.TField GATEWAY_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("gatewayId", org.apache.thrift.protocol.TType.STRING, (short)1); + private static final org.apache.thrift.protocol.TField OFFSET_FIELD_DESC = new org.apache.thrift.protocol.TField("offset", org.apache.thrift.protocol.TType.I32, (short)2); + private static final org.apache.thrift.protocol.TField LIMIT_FIELD_DESC = new org.apache.thrift.protocol.TField("limit", org.apache.thrift.protocol.TType.I32, (short)3); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { @@ -4582,10 +4576,14 @@ public class UserProfileCrudeService { } public String gatewayId; // required + public int offset; // required + public int limit; // 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 { - GATEWAY_ID((short)1, "gatewayId"); + GATEWAY_ID((short)1, "gatewayId"), + OFFSET((short)2, "offset"), + LIMIT((short)3, "limit"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -4602,6 +4600,10 @@ public class UserProfileCrudeService { switch(fieldId) { case 1: // GATEWAY_ID return GATEWAY_ID; + case 2: // OFFSET + return OFFSET; + case 3: // LIMIT + return LIMIT; default: return null; } @@ -4642,11 +4644,18 @@ public class UserProfileCrudeService { } // isset id assignments + private static final int __OFFSET_ISSET_ID = 0; + private static final int __LIMIT_ISSET_ID = 1; + private byte __isset_bitfield = 0; 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.GATEWAY_ID, new org.apache.thrift.meta_data.FieldMetaData("gatewayId", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.OFFSET, new org.apache.thrift.meta_data.FieldMetaData("offset", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); + tmpMap.put(_Fields.LIMIT, new org.apache.thrift.meta_data.FieldMetaData("limit", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); metaDataMap = Collections.unmodifiableMap(tmpMap); org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getAllUserProfilesInGateway_args.class, metaDataMap); } @@ -4655,19 +4664,28 @@ public class UserProfileCrudeService { } public getAllUserProfilesInGateway_args( - String gatewayId) + String gatewayId, + int offset, + int limit) { this(); this.gatewayId = gatewayId; + this.offset = offset; + setOffsetIsSet(true); + this.limit = limit; + setLimitIsSet(true); } /** * Performs a deep copy on <i>other</i>. */ public getAllUserProfilesInGateway_args(getAllUserProfilesInGateway_args other) { + __isset_bitfield = other.__isset_bitfield; if (other.isSetGatewayId()) { this.gatewayId = other.gatewayId; } + this.offset = other.offset; + this.limit = other.limit; } public getAllUserProfilesInGateway_args deepCopy() { @@ -4677,6 +4695,10 @@ public class UserProfileCrudeService { @Override public void clear() { this.gatewayId = null; + setOffsetIsSet(false); + this.offset = 0; + setLimitIsSet(false); + this.limit = 0; } public String getGatewayId() { @@ -4703,6 +4725,52 @@ public class UserProfileCrudeService { } } + public int getOffset() { + return this.offset; + } + + public getAllUserProfilesInGateway_args setOffset(int offset) { + this.offset = offset; + setOffsetIsSet(true); + return this; + } + + public void unsetOffset() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __OFFSET_ISSET_ID); + } + + /** Returns true if field offset is set (has been assigned a value) and false otherwise */ + public boolean isSetOffset() { + return EncodingUtils.testBit(__isset_bitfield, __OFFSET_ISSET_ID); + } + + public void setOffsetIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __OFFSET_ISSET_ID, value); + } + + public int getLimit() { + return this.limit; + } + + public getAllUserProfilesInGateway_args setLimit(int limit) { + this.limit = limit; + setLimitIsSet(true); + return this; + } + + public void unsetLimit() { + __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __LIMIT_ISSET_ID); + } + + /** Returns true if field limit is set (has been assigned a value) and false otherwise */ + public boolean isSetLimit() { + return EncodingUtils.testBit(__isset_bitfield, __LIMIT_ISSET_ID); + } + + public void setLimitIsSet(boolean value) { + __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __LIMIT_ISSET_ID, value); + } + public void setFieldValue(_Fields field, Object value) { switch (field) { case GATEWAY_ID: @@ -4713,6 +4781,22 @@ public class UserProfileCrudeService { } break; + case OFFSET: + if (value == null) { + unsetOffset(); + } else { + setOffset((Integer)value); + } + break; + + case LIMIT: + if (value == null) { + unsetLimit(); + } else { + setLimit((Integer)value); + } + break; + } } @@ -4721,6 +4805,12 @@ public class UserProfileCrudeService { case GATEWAY_ID: return getGatewayId(); + case OFFSET: + return getOffset(); + + case LIMIT: + return getLimit(); + } throw new IllegalStateException(); } @@ -4734,6 +4824,10 @@ public class UserProfileCrudeService { switch (field) { case GATEWAY_ID: return isSetGatewayId(); + case OFFSET: + return isSetOffset(); + case LIMIT: + return isSetLimit(); } throw new IllegalStateException(); } @@ -4760,6 +4854,24 @@ public class UserProfileCrudeService { return false; } + boolean this_present_offset = true; + boolean that_present_offset = true; + if (this_present_offset || that_present_offset) { + if (!(this_present_offset && that_present_offset)) + return false; + if (this.offset != that.offset) + return false; + } + + boolean this_present_limit = true; + boolean that_present_limit = true; + if (this_present_limit || that_present_limit) { + if (!(this_present_limit && that_present_limit)) + return false; + if (this.limit != that.limit) + return false; + } + return true; } @@ -4772,6 +4884,16 @@ public class UserProfileCrudeService { if (present_gatewayId) list.add(gatewayId); + boolean present_offset = true; + list.add(present_offset); + if (present_offset) + list.add(offset); + + boolean present_limit = true; + list.add(present_limit); + if (present_limit) + list.add(limit); + return list.hashCode(); } @@ -4793,6 +4915,26 @@ public class UserProfileCrudeService { return lastComparison; } } + lastComparison = Boolean.valueOf(isSetOffset()).compareTo(other.isSetOffset()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetOffset()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.offset, other.offset); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetLimit()).compareTo(other.isSetLimit()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetLimit()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.limit, other.limit); + if (lastComparison != 0) { + return lastComparison; + } + } return 0; } @@ -4800,11 +4942,11 @@ public class UserProfileCrudeService { return _Fields.findByThriftId(fieldId); } - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot) throws TException { schemes.get(iprot.getScheme()).getScheme().read(iprot, this); } - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot) throws TException { schemes.get(oprot.getScheme()).getScheme().write(oprot, this); } @@ -4820,30 +4962,42 @@ public class UserProfileCrudeService { sb.append(this.gatewayId); } first = false; + if (!first) sb.append(", "); + sb.append("offset:"); + sb.append(this.offset); + first = false; + if (!first) sb.append(", "); + sb.append("limit:"); + sb.append(this.limit); + first = false; sb.append(")"); return sb.toString(); } - public void validate() throws org.apache.thrift.TException { + public void validate() throws TException { // check for required fields if (gatewayId == null) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'gatewayId' was not present! Struct: " + toString()); + throw new TProtocolException("Required field 'gatewayId' was not present! Struct: " + toString()); } + // alas, we cannot check 'offset' because it's a primitive and you chose the non-beans generator. + // alas, we cannot check 'limit' because it's a primitive and you chose the non-beans generator. // 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) { + } catch (TException te) { throw new java.io.IOException(te); } } private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { try { + // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. + __isset_bitfield = 0; read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -4856,7 +5010,7 @@ public class UserProfileCrudeService { private static class getAllUserProfilesInGateway_argsStandardScheme extends StandardScheme<getAllUserProfilesInGateway_args> { - public void read(org.apache.thrift.protocol.TProtocol iprot, getAllUserProfilesInGateway_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, getAllUserProfilesInGateway_args struct) throws TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -4874,6 +5028,22 @@ public class UserProfileCrudeService { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; + case 2: // OFFSET + if (schemeField.type == org.apache.thrift.protocol.TType.I32) { + struct.offset = iprot.readI32(); + struct.setOffsetIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 3: // LIMIT + if (schemeField.type == org.apache.thrift.protocol.TType.I32) { + struct.limit = iprot.readI32(); + struct.setLimitIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; default: org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -4882,10 +5052,16 @@ public class UserProfileCrudeService { iprot.readStructEnd(); // check for required fields of primitive type, which can't be checked in the validate method + if (!struct.isSetOffset()) { + throw new TProtocolException("Required field 'offset' was not found in serialized data! Struct: " + toString()); + } + if (!struct.isSetLimit()) { + throw new TProtocolException("Required field 'limit' was not found in serialized data! Struct: " + toString()); + } struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, getAllUserProfilesInGateway_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, getAllUserProfilesInGateway_args struct) throws TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -4894,6 +5070,12 @@ public class UserProfileCrudeService { oprot.writeString(struct.gatewayId); oprot.writeFieldEnd(); } + oprot.writeFieldBegin(OFFSET_FIELD_DESC); + oprot.writeI32(struct.offset); + oprot.writeFieldEnd(); + oprot.writeFieldBegin(LIMIT_FIELD_DESC); + oprot.writeI32(struct.limit); + oprot.writeFieldEnd(); oprot.writeFieldStop(); oprot.writeStructEnd(); } @@ -4909,16 +5091,22 @@ public class UserProfileCrudeService { private static class getAllUserProfilesInGateway_argsTupleScheme extends TupleScheme<getAllUserProfilesInGateway_args> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, getAllUserProfilesInGateway_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, getAllUserProfilesInGateway_args struct) throws TException { TTupleProtocol oprot = (TTupleProtocol) prot; oprot.writeString(struct.gatewayId); + oprot.writeI32(struct.offset); + oprot.writeI32(struct.limit); } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, getAllUserProfilesInGateway_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, getAllUserProfilesInGateway_args struct) throws TException { TTupleProtocol iprot = (TTupleProtocol) prot; struct.gatewayId = iprot.readString(); struct.setGatewayIdIsSet(true); + struct.offset = iprot.readI32(); + struct.setOffsetIsSet(true); + struct.limit = iprot.readI32(); + struct.setLimitIsSet(true); } } @@ -5248,11 +5436,11 @@ public class UserProfileCrudeService { return _Fields.findByThriftId(fieldId); } - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot) throws TException { schemes.get(iprot.getScheme()).getScheme().read(iprot, this); } - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot) throws TException { schemes.get(oprot.getScheme()).getScheme().write(oprot, this); } @@ -5280,7 +5468,7 @@ public class UserProfileCrudeService { return sb.toString(); } - public void validate() throws org.apache.thrift.TException { + public void validate() throws TException { // check for required fields // check for sub-struct validity } @@ -5288,7 +5476,7 @@ public class UserProfileCrudeService { 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) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -5296,7 +5484,7 @@ public class UserProfileCrudeService { 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) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -5309,7 +5497,7 @@ public class UserProfileCrudeService { private static class getAllUserProfilesInGateway_resultStandardScheme extends StandardScheme<getAllUserProfilesInGateway_result> { - public void read(org.apache.thrift.protocol.TProtocol iprot, getAllUserProfilesInGateway_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, getAllUserProfilesInGateway_result struct) throws TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -5358,7 +5546,7 @@ public class UserProfileCrudeService { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, getAllUserProfilesInGateway_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, getAllUserProfilesInGateway_result struct) throws TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -5394,7 +5582,7 @@ public class UserProfileCrudeService { private static class getAllUserProfilesInGateway_resultTupleScheme extends TupleScheme<getAllUserProfilesInGateway_result> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, getAllUserProfilesInGateway_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, getAllUserProfilesInGateway_result struct) throws TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); if (struct.isSetSuccess()) { @@ -5419,7 +5607,7 @@ public class UserProfileCrudeService { } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, getAllUserProfilesInGateway_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, getAllUserProfilesInGateway_result struct) throws TException { TTupleProtocol iprot = (TTupleProtocol) prot; BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { @@ -5750,11 +5938,11 @@ public class UserProfileCrudeService { return _Fields.findByThriftId(fieldId); } - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot) throws TException { schemes.get(iprot.getScheme()).getScheme().read(iprot, this); } - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot) throws TException { schemes.get(oprot.getScheme()).getScheme().write(oprot, this); } @@ -5782,13 +5970,13 @@ public class UserProfileCrudeService { return sb.toString(); } - public void validate() throws org.apache.thrift.TException { + public void validate() throws TException { // check for required fields if (userName == null) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'userName' was not present! Struct: " + toString()); + throw new TProtocolException("Required field 'userName' was not present! Struct: " + toString()); } if (gatewayId == null) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'gatewayId' was not present! Struct: " + toString()); + throw new TProtocolException("Required field 'gatewayId' was not present! Struct: " + toString()); } // check for sub-struct validity } @@ -5796,7 +5984,7 @@ public class UserProfileCrudeService { 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) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -5804,7 +5992,7 @@ public class UserProfileCrudeService { 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) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -5817,7 +6005,7 @@ public class UserProfileCrudeService { private static class getUserProfileByName_argsStandardScheme extends StandardScheme<getUserProfileByName_args> { - public void read(org.apache.thrift.protocol.TProtocol iprot, getUserProfileByName_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, getUserProfileByName_args struct) throws TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -5854,7 +6042,7 @@ public class UserProfileCrudeService { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, getUserProfileByName_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, getUserProfileByName_args struct) throws TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -5883,14 +6071,14 @@ public class UserProfileCrudeService { private static class getUserProfileByName_argsTupleScheme extends TupleScheme<getUserProfileByName_args> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, getUserProfileByName_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, getUserProfileByName_args struct) throws TException { TTupleProtocol oprot = (TTupleProtocol) prot; oprot.writeString(struct.userName); oprot.writeString(struct.gatewayId); } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, getUserProfileByName_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, getUserProfileByName_args struct) throws TException { TTupleProtocol iprot = (TTupleProtocol) prot; struct.userName = iprot.readString(); struct.setUserNameIsSet(true); @@ -6205,11 +6393,11 @@ public class UserProfileCrudeService { return _Fields.findByThriftId(fieldId); } - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot) throws TException { schemes.get(iprot.getScheme()).getScheme().read(iprot, this); } - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot) throws TException { schemes.get(oprot.getScheme()).getScheme().write(oprot, this); } @@ -6237,7 +6425,7 @@ public class UserProfileCrudeService { return sb.toString(); } - public void validate() throws org.apache.thrift.TException { + public void validate() throws TException { // check for required fields // check for sub-struct validity if (success != null) { @@ -6248,7 +6436,7 @@ public class UserProfileCrudeService { 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) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -6256,7 +6444,7 @@ public class UserProfileCrudeService { 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) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -6269,7 +6457,7 @@ public class UserProfileCrudeService { private static class getUserProfileByName_resultStandardScheme extends StandardScheme<getUserProfileByName_result> { - public void read(org.apache.thrift.protocol.TProtocol iprot, getUserProfileByName_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, getUserProfileByName_result struct) throws TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -6308,7 +6496,7 @@ public class UserProfileCrudeService { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, getUserProfileByName_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, getUserProfileByName_result struct) throws TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -6337,7 +6525,7 @@ public class UserProfileCrudeService { private static class getUserProfileByName_resultTupleScheme extends TupleScheme<getUserProfileByName_result> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, getUserProfileByName_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, getUserProfileByName_result struct) throws TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); if (struct.isSetSuccess()) { @@ -6356,7 +6544,7 @@ public class UserProfileCrudeService { } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, getUserProfileByName_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, getUserProfileByName_result struct) throws TException { TTupleProtocol iprot = (TTupleProtocol) prot; BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { @@ -6678,11 +6866,11 @@ public class UserProfileCrudeService { return _Fields.findByThriftId(fieldId); } - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot) throws TException { schemes.get(iprot.getScheme()).getScheme().read(iprot, this); } - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot) throws TException { schemes.get(oprot.getScheme()).getScheme().write(oprot, this); } @@ -6710,13 +6898,13 @@ public class UserProfileCrudeService { return sb.toString(); } - public void validate() throws org.apache.thrift.TException { + public void validate() throws TException { // check for required fields if (userName == null) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'userName' was not present! Struct: " + toString()); + throw new TProtocolException("Required field 'userName' was not present! Struct: " + toString()); } if (gatewayId == null) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'gatewayId' was not present! Struct: " + toString()); + throw new TProtocolException("Required field 'gatewayId' was not present! Struct: " + toString()); } // check for sub-struct validity } @@ -6724,7 +6912,7 @@ public class UserProfileCrudeService { 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) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -6732,7 +6920,7 @@ public class UserProfileCrudeService { 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) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -6745,7 +6933,7 @@ public class UserProfileCrudeService { private static class doesUserExist_argsStandardScheme extends StandardScheme<doesUserExist_args> { - public void read(org.apache.thrift.protocol.TProtocol iprot, doesUserExist_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, doesUserExist_args struct) throws TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -6782,7 +6970,7 @@ public class UserProfileCrudeService { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, doesUserExist_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, doesUserExist_args struct) throws TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -6811,14 +6999,14 @@ public class UserProfileCrudeService { private static class doesUserExist_argsTupleScheme extends TupleScheme<doesUserExist_args> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, doesUserExist_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, doesUserExist_args struct) throws TException { TTupleProtocol oprot = (TTupleProtocol) prot; oprot.writeString(struct.userName); oprot.writeString(struct.gatewayId); } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, doesUserExist_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, doesUserExist_args struct) throws TException { TTupleProtocol iprot = (TTupleProtocol) prot; struct.userName = iprot.readString(); struct.setUserNameIsSet(true); @@ -7135,11 +7323,11 @@ public class UserProfileCrudeService { return _Fields.findByThriftId(fieldId); } - public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot) throws TException { schemes.get(iprot.getScheme()).getScheme().read(iprot, this); } - public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot) throws TException { schemes.get(oprot.getScheme()).getScheme().write(oprot, this); } @@ -7163,7 +7351,7 @@ public class UserProfileCrudeService { return sb.toString(); } - public void validate() throws org.apache.thrift.TException { + public void validate() throws TException { // check for required fields // check for sub-struct validity } @@ -7171,7 +7359,7 @@ public class UserProfileCrudeService { 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) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -7181,7 +7369,7 @@ public class UserProfileCrudeService { // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor. __isset_bitfield = 0; read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); - } catch (org.apache.thrift.TException te) { + } catch (TException te) { throw new java.io.IOException(te); } } @@ -7194,7 +7382,7 @@ public class UserProfileCrudeService { private static class doesUserExist_resultStandardScheme extends StandardScheme<doesUserExist_result> { - public void read(org.apache.thrift.protocol.TProtocol iprot, doesUserExist_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, doesUserExist_result struct) throws TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -7232,7 +7420,7 @@ public class UserProfileCrudeService { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, doesUserExist_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, doesUserExist_result struct) throws TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -7261,7 +7449,7 @@ public class UserProfileCrudeService { private static class doesUserExist_resultTupleScheme extends TupleScheme<doesUserExist_result> { @Override - public void write(org.apache.thrift.protocol.TProtocol prot, doesUserExist_result struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol prot, doesUserExist_result struct) throws TException { TTupleProtocol oprot = (TTupleProtocol) prot; BitSet optionals = new BitSet(); if (struct.isSetSuccess()) { @@ -7280,7 +7468,7 @@ public class UserProfileCrudeService { } @Override - public void read(org.apache.thrift.protocol.TProtocol prot, doesUserExist_result struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol prot, doesUserExist_result struct) throws TException { TTupleProtocol iprot = (TTupleProtocol) prot; BitSet incoming = iprot.readBitSet(2); if (incoming.get(0)) { diff --git a/modules/user-profile/user-profile-stubs/src/main/java/org/apache/airavata/userprofile/crude/cpi/user_profile_crud_cpiConstants.java b/modules/user-profile/user-profile-stubs/src/main/java/org/apache/airavata/userprofile/crude/cpi/user_profile_crud_cpiConstants.java index 91eb8c4..2dcfd0e 100644 --- a/modules/user-profile/user-profile-stubs/src/main/java/org/apache/airavata/userprofile/crude/cpi/user_profile_crud_cpiConstants.java +++ b/modules/user-profile/user-profile-stubs/src/main/java/org/apache/airavata/userprofile/crude/cpi/user_profile_crud_cpiConstants.java @@ -1,19 +1,3 @@ - /* - * 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) * -- To stop receiving notification emails like this one, please contact "[email protected]" <[email protected]>.
