http://git-wip-us.apache.org/repos/asf/airavata/blob/536cca16/modules/sharing-registry/sharing-registry-stubs/src/main/java/org/apache/airavata/sharing/registry/service/cpi/SharingRegistryService.java ---------------------------------------------------------------------- diff --git a/modules/sharing-registry/sharing-registry-stubs/src/main/java/org/apache/airavata/sharing/registry/service/cpi/SharingRegistryService.java b/modules/sharing-registry/sharing-registry-stubs/src/main/java/org/apache/airavata/sharing/registry/service/cpi/SharingRegistryService.java index 2fc5691..eb3d3be 100644 --- a/modules/sharing-registry/sharing-registry-stubs/src/main/java/org/apache/airavata/sharing/registry/service/cpi/SharingRegistryService.java +++ b/modules/sharing-registry/sharing-registry-stubs/src/main/java/org/apache/airavata/sharing/registry/service/cpi/SharingRegistryService.java @@ -54,6 +54,13 @@ public class SharingRegistryService { public boolean updateDomain(org.apache.airavata.sharing.registry.models.Domain domain) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException; /** + * <p>API method to check Domain Exists</p> + * + * @param domainId + */ + public boolean isDomainExists(String domainId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException; + + /** * <p>API method to delete domain</p> * * @param domainId @@ -90,6 +97,14 @@ public class SharingRegistryService { public boolean updatedUser(org.apache.airavata.sharing.registry.models.User user) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException; /** + * <p>API method to check User Exists</p> + * + * @param domainId + * @param userId + */ + public boolean isUserExists(String domainId, String userId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException; + + /** * <p>API method to delete user</p> * * @param domainId @@ -132,6 +147,14 @@ public class SharingRegistryService { public boolean updateGroup(org.apache.airavata.sharing.registry.models.UserGroup group) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException; /** + * <p>API method to check Group Exists</p> + * + * @param domainId + * @param groupId + */ + public boolean isGroupExists(String domainId, String groupId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException; + + /** * <p>API method to delete a group</p> * * @param domainId @@ -227,6 +250,14 @@ public class SharingRegistryService { public boolean updateEntityType(org.apache.airavata.sharing.registry.models.EntityType entityType) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException; /** + * <p>API method to check EntityType Exists</p> + * + * @param domainId + * @param entityTypeId + */ + public boolean isEntityTypeExists(String domainId, String entityTypeId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException; + + /** * <p>API method to delete entity type</p> * * @param domainId @@ -266,6 +297,14 @@ public class SharingRegistryService { public boolean updateEntity(org.apache.airavata.sharing.registry.models.Entity entity) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException; /** + * <p>API method to check Entity Exists</p> + * + * @param domainId + * @param entityId + */ + public boolean isEntityExists(String domainId, String entityId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException; + + /** * <p>API method to delete entity</p> * * @param domainId @@ -325,6 +364,14 @@ public class SharingRegistryService { public boolean updatePermissionType(org.apache.airavata.sharing.registry.models.PermissionType permissionType) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException; /** + * <p>API method to check Permission Exists</p> + * + * @param dimainId + * @param permissionId + */ + public boolean isPermissionExists(String dimainId, String permissionId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException; + + /** * <p>API method to delete permission type</p> * * @param domainId @@ -409,6 +456,8 @@ public class SharingRegistryService { public void updateDomain(org.apache.airavata.sharing.registry.models.Domain domain, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void isDomainExists(String domainId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void deleteDomain(String domainId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void getDomain(String domainId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; @@ -419,6 +468,8 @@ public class SharingRegistryService { public void updatedUser(org.apache.airavata.sharing.registry.models.User user, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void isUserExists(String domainId, String userId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void deleteUser(String domainId, String userId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void getUser(String domainId, String userId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; @@ -429,6 +480,8 @@ public class SharingRegistryService { public void updateGroup(org.apache.airavata.sharing.registry.models.UserGroup group, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void isGroupExists(String domainId, String groupId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void deleteGroup(String domainId, String groupId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void getGroup(String domainId, String groupId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; @@ -451,6 +504,8 @@ public class SharingRegistryService { public void updateEntityType(org.apache.airavata.sharing.registry.models.EntityType entityType, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void isEntityTypeExists(String domainId, String entityTypeId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void deleteEntityType(String domainId, String entityTypeId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void getEntityType(String domainId, String entityTypeId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; @@ -461,6 +516,8 @@ public class SharingRegistryService { public void updateEntity(org.apache.airavata.sharing.registry.models.Entity entity, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void isEntityExists(String domainId, String entityId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void deleteEntity(String domainId, String entityId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void getEntity(String domainId, String entityId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; @@ -475,6 +532,8 @@ public class SharingRegistryService { public void updatePermissionType(org.apache.airavata.sharing.registry.models.PermissionType permissionType, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void isPermissionExists(String dimainId, String permissionId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; + public void deletePermissionType(String domainId, String permissionTypeId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; public void getPermissionType(String domainId, String permissionTypeId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException; @@ -565,6 +624,32 @@ public class SharingRegistryService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "updateDomain failed: unknown result"); } + public boolean isDomainExists(String domainId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException + { + send_isDomainExists(domainId); + return recv_isDomainExists(); + } + + public void send_isDomainExists(String domainId) throws org.apache.thrift.TException + { + isDomainExists_args args = new isDomainExists_args(); + args.setDomainId(domainId); + sendBase("isDomainExists", args); + } + + public boolean recv_isDomainExists() throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException + { + isDomainExists_result result = new isDomainExists_result(); + receiveBase(result, "isDomainExists"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.sre != null) { + throw result.sre; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isDomainExists failed: unknown result"); + } + public boolean deleteDomain(String domainId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException { send_deleteDomain(domainId); @@ -696,6 +781,33 @@ public class SharingRegistryService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "updatedUser failed: unknown result"); } + public boolean isUserExists(String domainId, String userId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException + { + send_isUserExists(domainId, userId); + return recv_isUserExists(); + } + + public void send_isUserExists(String domainId, String userId) throws org.apache.thrift.TException + { + isUserExists_args args = new isUserExists_args(); + args.setDomainId(domainId); + args.setUserId(userId); + sendBase("isUserExists", args); + } + + public boolean recv_isUserExists() throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException + { + isUserExists_result result = new isUserExists_result(); + receiveBase(result, "isUserExists"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.sre != null) { + throw result.sre; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isUserExists failed: unknown result"); + } + public boolean deleteUser(String domainId, String userId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException { send_deleteUser(domainId, userId); @@ -830,6 +942,33 @@ public class SharingRegistryService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "updateGroup failed: unknown result"); } + public boolean isGroupExists(String domainId, String groupId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException + { + send_isGroupExists(domainId, groupId); + return recv_isGroupExists(); + } + + public void send_isGroupExists(String domainId, String groupId) throws org.apache.thrift.TException + { + isGroupExists_args args = new isGroupExists_args(); + args.setDomainId(domainId); + args.setGroupId(groupId); + sendBase("isGroupExists", args); + } + + public boolean recv_isGroupExists() throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException + { + isGroupExists_result result = new isGroupExists_result(); + receiveBase(result, "isGroupExists"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.sre != null) { + throw result.sre; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isGroupExists failed: unknown result"); + } + public boolean deleteGroup(String domainId, String groupId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException { send_deleteGroup(domainId, groupId); @@ -1131,6 +1270,33 @@ public class SharingRegistryService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "updateEntityType failed: unknown result"); } + public boolean isEntityTypeExists(String domainId, String entityTypeId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException + { + send_isEntityTypeExists(domainId, entityTypeId); + return recv_isEntityTypeExists(); + } + + public void send_isEntityTypeExists(String domainId, String entityTypeId) throws org.apache.thrift.TException + { + isEntityTypeExists_args args = new isEntityTypeExists_args(); + args.setDomainId(domainId); + args.setEntityTypeId(entityTypeId); + sendBase("isEntityTypeExists", args); + } + + public boolean recv_isEntityTypeExists() throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException + { + isEntityTypeExists_result result = new isEntityTypeExists_result(); + receiveBase(result, "isEntityTypeExists"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.sre != null) { + throw result.sre; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isEntityTypeExists failed: unknown result"); + } + public boolean deleteEntityType(String domainId, String entityTypeId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException { send_deleteEntityType(domainId, entityTypeId); @@ -1265,6 +1431,33 @@ public class SharingRegistryService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "updateEntity failed: unknown result"); } + public boolean isEntityExists(String domainId, String entityId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException + { + send_isEntityExists(domainId, entityId); + return recv_isEntityExists(); + } + + public void send_isEntityExists(String domainId, String entityId) throws org.apache.thrift.TException + { + isEntityExists_args args = new isEntityExists_args(); + args.setDomainId(domainId); + args.setEntityId(entityId); + sendBase("isEntityExists", args); + } + + public boolean recv_isEntityExists() throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException + { + isEntityExists_result result = new isEntityExists_result(); + receiveBase(result, "isEntityExists"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.sre != null) { + throw result.sre; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isEntityExists failed: unknown result"); + } + public boolean deleteEntity(String domainId, String entityId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException { send_deleteEntity(domainId, entityId); @@ -1457,6 +1650,33 @@ public class SharingRegistryService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "updatePermissionType failed: unknown result"); } + public boolean isPermissionExists(String dimainId, String permissionId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException + { + send_isPermissionExists(dimainId, permissionId); + return recv_isPermissionExists(); + } + + public void send_isPermissionExists(String dimainId, String permissionId) throws org.apache.thrift.TException + { + isPermissionExists_args args = new isPermissionExists_args(); + args.setDimainId(dimainId); + args.setPermissionId(permissionId); + sendBase("isPermissionExists", args); + } + + public boolean recv_isPermissionExists() throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException + { + isPermissionExists_result result = new isPermissionExists_result(); + receiveBase(result, "isPermissionExists"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.sre != null) { + throw result.sre; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isPermissionExists failed: unknown result"); + } + public boolean deletePermissionType(String domainId, String permissionTypeId) throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException { send_deletePermissionType(domainId, permissionTypeId); @@ -1768,6 +1988,38 @@ public class SharingRegistryService { } } + public void isDomainExists(String domainId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + isDomainExists_call method_call = new isDomainExists_call(domainId, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class isDomainExists_call extends org.apache.thrift.async.TAsyncMethodCall { + private String domainId; + public isDomainExists_call(String domainId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + super(client, protocolFactory, transport, resultHandler, false); + this.domainId = domainId; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("isDomainExists", org.apache.thrift.protocol.TMessageType.CALL, 0)); + isDomainExists_args args = new isDomainExists_args(); + args.setDomainId(domainId); + args.write(prot); + prot.writeMessageEnd(); + } + + public boolean getResult() throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); + } + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); + return (new Client(prot)).recv_isDomainExists(); + } + } + public void deleteDomain(String domainId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); deleteDomain_call method_call = new deleteDomain_call(domainId, resultHandler, this, ___protocolFactory, ___transport); @@ -1931,6 +2183,41 @@ public class SharingRegistryService { } } + public void isUserExists(String domainId, String userId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + isUserExists_call method_call = new isUserExists_call(domainId, userId, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class isUserExists_call extends org.apache.thrift.async.TAsyncMethodCall { + private String domainId; + private String userId; + public isUserExists_call(String domainId, String userId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + super(client, protocolFactory, transport, resultHandler, false); + this.domainId = domainId; + this.userId = userId; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("isUserExists", org.apache.thrift.protocol.TMessageType.CALL, 0)); + isUserExists_args args = new isUserExists_args(); + args.setDomainId(domainId); + args.setUserId(userId); + args.write(prot); + prot.writeMessageEnd(); + } + + public boolean getResult() throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); + } + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); + return (new Client(prot)).recv_isUserExists(); + } + } + public void deleteUser(String domainId, String userId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); deleteUser_call method_call = new deleteUser_call(domainId, userId, resultHandler, this, ___protocolFactory, ___transport); @@ -2103,6 +2390,41 @@ public class SharingRegistryService { } } + public void isGroupExists(String domainId, String groupId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + isGroupExists_call method_call = new isGroupExists_call(domainId, groupId, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class isGroupExists_call extends org.apache.thrift.async.TAsyncMethodCall { + private String domainId; + private String groupId; + public isGroupExists_call(String domainId, String groupId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + super(client, protocolFactory, transport, resultHandler, false); + this.domainId = domainId; + this.groupId = groupId; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("isGroupExists", org.apache.thrift.protocol.TMessageType.CALL, 0)); + isGroupExists_args args = new isGroupExists_args(); + args.setDomainId(domainId); + args.setGroupId(groupId); + args.write(prot); + prot.writeMessageEnd(); + } + + public boolean getResult() throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); + } + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); + return (new Client(prot)).recv_isGroupExists(); + } + } + public void deleteGroup(String domainId, String groupId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); deleteGroup_call method_call = new deleteGroup_call(domainId, groupId, resultHandler, this, ___protocolFactory, ___transport); @@ -2509,6 +2831,41 @@ public class SharingRegistryService { } } + public void isEntityTypeExists(String domainId, String entityTypeId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + isEntityTypeExists_call method_call = new isEntityTypeExists_call(domainId, entityTypeId, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class isEntityTypeExists_call extends org.apache.thrift.async.TAsyncMethodCall { + private String domainId; + private String entityTypeId; + public isEntityTypeExists_call(String domainId, String entityTypeId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + super(client, protocolFactory, transport, resultHandler, false); + this.domainId = domainId; + this.entityTypeId = entityTypeId; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("isEntityTypeExists", org.apache.thrift.protocol.TMessageType.CALL, 0)); + isEntityTypeExists_args args = new isEntityTypeExists_args(); + args.setDomainId(domainId); + args.setEntityTypeId(entityTypeId); + args.write(prot); + prot.writeMessageEnd(); + } + + public boolean getResult() throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); + } + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); + return (new Client(prot)).recv_isEntityTypeExists(); + } + } + public void deleteEntityType(String domainId, String entityTypeId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); deleteEntityType_call method_call = new deleteEntityType_call(domainId, entityTypeId, resultHandler, this, ___protocolFactory, ___transport); @@ -2681,6 +3038,41 @@ public class SharingRegistryService { } } + public void isEntityExists(String domainId, String entityId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + isEntityExists_call method_call = new isEntityExists_call(domainId, entityId, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class isEntityExists_call extends org.apache.thrift.async.TAsyncMethodCall { + private String domainId; + private String entityId; + public isEntityExists_call(String domainId, String entityId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + super(client, protocolFactory, transport, resultHandler, false); + this.domainId = domainId; + this.entityId = entityId; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("isEntityExists", org.apache.thrift.protocol.TMessageType.CALL, 0)); + isEntityExists_args args = new isEntityExists_args(); + args.setDomainId(domainId); + args.setEntityId(entityId); + args.write(prot); + prot.writeMessageEnd(); + } + + public boolean getResult() throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); + } + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); + return (new Client(prot)).recv_isEntityExists(); + } + } + public void deleteEntity(String domainId, String entityId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); deleteEntity_call method_call = new deleteEntity_call(domainId, entityId, resultHandler, this, ___protocolFactory, ___transport); @@ -2764,7 +3156,6 @@ public class SharingRegistryService { private List<org.apache.airavata.sharing.registry.models.SearchCriteria> filters; private int offset; private int limit; - public searchEntities_call(String domainId, String userId, List<org.apache.airavata.sharing.registry.models.SearchCriteria> filters, int offset, int limit, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { super(client, protocolFactory, transport, resultHandler, false); this.domainId = domainId; @@ -2936,6 +3327,41 @@ public class SharingRegistryService { } } + public void isPermissionExists(String dimainId, String permissionId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { + checkReady(); + isPermissionExists_call method_call = new isPermissionExists_call(dimainId, permissionId, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class isPermissionExists_call extends org.apache.thrift.async.TAsyncMethodCall { + private String dimainId; + private String permissionId; + public isPermissionExists_call(String dimainId, String permissionId, org.apache.thrift.async.AsyncMethodCallback resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + super(client, protocolFactory, transport, resultHandler, false); + this.dimainId = dimainId; + this.permissionId = permissionId; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("isPermissionExists", org.apache.thrift.protocol.TMessageType.CALL, 0)); + isPermissionExists_args args = new isPermissionExists_args(); + args.setDimainId(dimainId); + args.setPermissionId(permissionId); + args.write(prot); + prot.writeMessageEnd(); + } + + public boolean getResult() throws org.apache.airavata.sharing.registry.models.SharingRegistryException, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); + } + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); + return (new Client(prot)).recv_isPermissionExists(); + } + } + public void deletePermissionType(String domainId, String permissionTypeId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException { checkReady(); deletePermissionType_call method_call = new deletePermissionType_call(domainId, permissionTypeId, resultHandler, this, ___protocolFactory, ___transport); @@ -3270,16 +3696,19 @@ public class SharingRegistryService { private static <I extends Iface> Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> getProcessMap(Map<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) { processMap.put("createDomain", new createDomain()); processMap.put("updateDomain", new updateDomain()); + processMap.put("isDomainExists", new isDomainExists()); processMap.put("deleteDomain", new deleteDomain()); processMap.put("getDomain", new getDomain()); processMap.put("getDomains", new getDomains()); processMap.put("createUser", new createUser()); processMap.put("updatedUser", new updatedUser()); + processMap.put("isUserExists", new isUserExists()); processMap.put("deleteUser", new deleteUser()); processMap.put("getUser", new getUser()); processMap.put("getUsers", new getUsers()); processMap.put("createGroup", new createGroup()); processMap.put("updateGroup", new updateGroup()); + processMap.put("isGroupExists", new isGroupExists()); processMap.put("deleteGroup", new deleteGroup()); processMap.put("getGroup", new getGroup()); processMap.put("getGroups", new getGroups()); @@ -3291,11 +3720,13 @@ public class SharingRegistryService { processMap.put("removeChildGroupFromParentGroup", new removeChildGroupFromParentGroup()); processMap.put("createEntityType", new createEntityType()); processMap.put("updateEntityType", new updateEntityType()); + processMap.put("isEntityTypeExists", new isEntityTypeExists()); processMap.put("deleteEntityType", new deleteEntityType()); processMap.put("getEntityType", new getEntityType()); processMap.put("getEntityTypes", new getEntityTypes()); processMap.put("createEntity", new createEntity()); processMap.put("updateEntity", new updateEntity()); + processMap.put("isEntityExists", new isEntityExists()); processMap.put("deleteEntity", new deleteEntity()); processMap.put("getEntity", new getEntity()); processMap.put("searchEntities", new searchEntities()); @@ -3303,6 +3734,7 @@ public class SharingRegistryService { processMap.put("getListOfSharedGroups", new getListOfSharedGroups()); processMap.put("createPermissionType", new createPermissionType()); processMap.put("updatePermissionType", new updatePermissionType()); + processMap.put("isPermissionExists", new isPermissionExists()); processMap.put("deletePermissionType", new deletePermissionType()); processMap.put("getPermissionType", new getPermissionType()); processMap.put("getPermissionTypes", new getPermissionTypes()); @@ -3363,6 +3795,31 @@ public class SharingRegistryService { } } + public static class isDomainExists<I extends Iface> extends org.apache.thrift.ProcessFunction<I, isDomainExists_args> { + public isDomainExists() { + super("isDomainExists"); + } + + public isDomainExists_args getEmptyArgsInstance() { + return new isDomainExists_args(); + } + + protected boolean isOneway() { + return false; + } + + public isDomainExists_result getResult(I iface, isDomainExists_args args) throws org.apache.thrift.TException { + isDomainExists_result result = new isDomainExists_result(); + try { + result.success = iface.isDomainExists(args.domainId); + result.setSuccessIsSet(true); + } catch (org.apache.airavata.sharing.registry.models.SharingRegistryException sre) { + result.sre = sre; + } + return result; + } + } + public static class deleteDomain<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deleteDomain_args> { public deleteDomain() { super("deleteDomain"); @@ -3485,6 +3942,31 @@ public class SharingRegistryService { } } + public static class isUserExists<I extends Iface> extends org.apache.thrift.ProcessFunction<I, isUserExists_args> { + public isUserExists() { + super("isUserExists"); + } + + public isUserExists_args getEmptyArgsInstance() { + return new isUserExists_args(); + } + + protected boolean isOneway() { + return false; + } + + public isUserExists_result getResult(I iface, isUserExists_args args) throws org.apache.thrift.TException { + isUserExists_result result = new isUserExists_result(); + try { + result.success = iface.isUserExists(args.domainId, args.userId); + result.setSuccessIsSet(true); + } catch (org.apache.airavata.sharing.registry.models.SharingRegistryException sre) { + result.sre = sre; + } + return result; + } + } + public static class deleteUser<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deleteUser_args> { public deleteUser() { super("deleteUser"); @@ -3607,6 +4089,31 @@ public class SharingRegistryService { } } + public static class isGroupExists<I extends Iface> extends org.apache.thrift.ProcessFunction<I, isGroupExists_args> { + public isGroupExists() { + super("isGroupExists"); + } + + public isGroupExists_args getEmptyArgsInstance() { + return new isGroupExists_args(); + } + + protected boolean isOneway() { + return false; + } + + public isGroupExists_result getResult(I iface, isGroupExists_args args) throws org.apache.thrift.TException { + isGroupExists_result result = new isGroupExists_result(); + try { + result.success = iface.isGroupExists(args.domainId, args.groupId); + result.setSuccessIsSet(true); + } catch (org.apache.airavata.sharing.registry.models.SharingRegistryException sre) { + result.sre = sre; + } + return result; + } + } + public static class deleteGroup<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deleteGroup_args> { public deleteGroup() { super("deleteGroup"); @@ -3873,6 +4380,31 @@ public class SharingRegistryService { } } + public static class isEntityTypeExists<I extends Iface> extends org.apache.thrift.ProcessFunction<I, isEntityTypeExists_args> { + public isEntityTypeExists() { + super("isEntityTypeExists"); + } + + public isEntityTypeExists_args getEmptyArgsInstance() { + return new isEntityTypeExists_args(); + } + + protected boolean isOneway() { + return false; + } + + public isEntityTypeExists_result getResult(I iface, isEntityTypeExists_args args) throws org.apache.thrift.TException { + isEntityTypeExists_result result = new isEntityTypeExists_result(); + try { + result.success = iface.isEntityTypeExists(args.domainId, args.entityTypeId); + result.setSuccessIsSet(true); + } catch (org.apache.airavata.sharing.registry.models.SharingRegistryException sre) { + result.sre = sre; + } + return result; + } + } + public static class deleteEntityType<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deleteEntityType_args> { public deleteEntityType() { super("deleteEntityType"); @@ -3995,6 +4527,31 @@ public class SharingRegistryService { } } + public static class isEntityExists<I extends Iface> extends org.apache.thrift.ProcessFunction<I, isEntityExists_args> { + public isEntityExists() { + super("isEntityExists"); + } + + public isEntityExists_args getEmptyArgsInstance() { + return new isEntityExists_args(); + } + + protected boolean isOneway() { + return false; + } + + public isEntityExists_result getResult(I iface, isEntityExists_args args) throws org.apache.thrift.TException { + isEntityExists_result result = new isEntityExists_result(); + try { + result.success = iface.isEntityExists(args.domainId, args.entityId); + result.setSuccessIsSet(true); + } catch (org.apache.airavata.sharing.registry.models.SharingRegistryException sre) { + result.sre = sre; + } + return result; + } + } + public static class deleteEntity<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deleteEntity_args> { public deleteEntity() { super("deleteEntity"); @@ -4165,6 +4722,31 @@ public class SharingRegistryService { } } + public static class isPermissionExists<I extends Iface> extends org.apache.thrift.ProcessFunction<I, isPermissionExists_args> { + public isPermissionExists() { + super("isPermissionExists"); + } + + public isPermissionExists_args getEmptyArgsInstance() { + return new isPermissionExists_args(); + } + + protected boolean isOneway() { + return false; + } + + public isPermissionExists_result getResult(I iface, isPermissionExists_args args) throws org.apache.thrift.TException { + isPermissionExists_result result = new isPermissionExists_result(); + try { + result.success = iface.isPermissionExists(args.dimainId, args.permissionId); + result.setSuccessIsSet(true); + } catch (org.apache.airavata.sharing.registry.models.SharingRegistryException sre) { + result.sre = sre; + } + return result; + } + } + public static class deletePermissionType<I extends Iface> extends org.apache.thrift.ProcessFunction<I, deletePermissionType_args> { public deletePermissionType() { super("deletePermissionType"); @@ -4378,16 +4960,19 @@ public class SharingRegistryService { private static <I extends AsyncIface> Map<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase,?>> getProcessMap(Map<String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>> processMap) { processMap.put("createDomain", new createDomain()); processMap.put("updateDomain", new updateDomain()); + processMap.put("isDomainExists", new isDomainExists()); processMap.put("deleteDomain", new deleteDomain()); processMap.put("getDomain", new getDomain()); processMap.put("getDomains", new getDomains()); processMap.put("createUser", new createUser()); processMap.put("updatedUser", new updatedUser()); + processMap.put("isUserExists", new isUserExists()); processMap.put("deleteUser", new deleteUser()); processMap.put("getUser", new getUser()); processMap.put("getUsers", new getUsers()); processMap.put("createGroup", new createGroup()); processMap.put("updateGroup", new updateGroup()); + processMap.put("isGroupExists", new isGroupExists()); processMap.put("deleteGroup", new deleteGroup()); processMap.put("getGroup", new getGroup()); processMap.put("getGroups", new getGroups()); @@ -4399,11 +4984,13 @@ public class SharingRegistryService { processMap.put("removeChildGroupFromParentGroup", new removeChildGroupFromParentGroup()); processMap.put("createEntityType", new createEntityType()); processMap.put("updateEntityType", new updateEntityType()); + processMap.put("isEntityTypeExists", new isEntityTypeExists()); processMap.put("deleteEntityType", new deleteEntityType()); processMap.put("getEntityType", new getEntityType()); processMap.put("getEntityTypes", new getEntityTypes()); processMap.put("createEntity", new createEntity()); processMap.put("updateEntity", new updateEntity()); + processMap.put("isEntityExists", new isEntityExists()); processMap.put("deleteEntity", new deleteEntity()); processMap.put("getEntity", new getEntity()); processMap.put("searchEntities", new searchEntities()); @@ -4411,6 +4998,7 @@ public class SharingRegistryService { processMap.put("getListOfSharedGroups", new getListOfSharedGroups()); processMap.put("createPermissionType", new createPermissionType()); processMap.put("updatePermissionType", new updatePermissionType()); + processMap.put("isPermissionExists", new isPermissionExists()); processMap.put("deletePermissionType", new deletePermissionType()); processMap.put("getPermissionType", new getPermissionType()); processMap.put("getPermissionTypes", new getPermissionTypes()); @@ -4537,6 +5125,64 @@ public class SharingRegistryService { } } + public static class isDomainExists<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, isDomainExists_args, Boolean> { + public isDomainExists() { + super("isDomainExists"); + } + + public isDomainExists_args getEmptyArgsInstance() { + return new isDomainExists_args(); + } + + public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + isDomainExists_result result = new isDomainExists_result(); + result.success = o; + result.setSuccessIsSet(true); + try { + fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); + return; + } catch (Exception e) { + LOGGER.error("Exception writing to internal frame buffer", e); + } + fb.close(); + } + public void onError(Exception e) { + byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; + org.apache.thrift.TBase msg; + isDomainExists_result result = new isDomainExists_result(); + if (e instanceof org.apache.airavata.sharing.registry.models.SharingRegistryException) { + result.sre = (org.apache.airavata.sharing.registry.models.SharingRegistryException) e; + result.setSreIsSet(true); + msg = result; + } + else + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, isDomainExists_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.isDomainExists(args.domainId,resultHandler); + } + } + public static class deleteDomain<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteDomain_args, Boolean> { public deleteDomain() { super("deleteDomain"); @@ -4824,6 +5470,64 @@ public class SharingRegistryService { } } + public static class isUserExists<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, isUserExists_args, Boolean> { + public isUserExists() { + super("isUserExists"); + } + + public isUserExists_args getEmptyArgsInstance() { + return new isUserExists_args(); + } + + public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + isUserExists_result result = new isUserExists_result(); + result.success = o; + result.setSuccessIsSet(true); + try { + fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); + return; + } catch (Exception e) { + LOGGER.error("Exception writing to internal frame buffer", e); + } + fb.close(); + } + public void onError(Exception e) { + byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; + org.apache.thrift.TBase msg; + isUserExists_result result = new isUserExists_result(); + if (e instanceof org.apache.airavata.sharing.registry.models.SharingRegistryException) { + result.sre = (org.apache.airavata.sharing.registry.models.SharingRegistryException) e; + result.setSreIsSet(true); + msg = result; + } + else + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, isUserExists_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.isUserExists(args.domainId, args.userId,resultHandler); + } + } + public static class deleteUser<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteUser_args, Boolean> { public deleteUser() { super("deleteUser"); @@ -5111,6 +5815,64 @@ public class SharingRegistryService { } } + public static class isGroupExists<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, isGroupExists_args, Boolean> { + public isGroupExists() { + super("isGroupExists"); + } + + public isGroupExists_args getEmptyArgsInstance() { + return new isGroupExists_args(); + } + + public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + isGroupExists_result result = new isGroupExists_result(); + result.success = o; + result.setSuccessIsSet(true); + try { + fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); + return; + } catch (Exception e) { + LOGGER.error("Exception writing to internal frame buffer", e); + } + fb.close(); + } + public void onError(Exception e) { + byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; + org.apache.thrift.TBase msg; + isGroupExists_result result = new isGroupExists_result(); + if (e instanceof org.apache.airavata.sharing.registry.models.SharingRegistryException) { + result.sre = (org.apache.airavata.sharing.registry.models.SharingRegistryException) e; + result.setSreIsSet(true); + msg = result; + } + else + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, isGroupExists_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.isGroupExists(args.domainId, args.groupId,resultHandler); + } + } + public static class deleteGroup<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteGroup_args, Boolean> { public deleteGroup() { super("deleteGroup"); @@ -5738,6 +6500,64 @@ public class SharingRegistryService { } } + public static class isEntityTypeExists<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, isEntityTypeExists_args, Boolean> { + public isEntityTypeExists() { + super("isEntityTypeExists"); + } + + public isEntityTypeExists_args getEmptyArgsInstance() { + return new isEntityTypeExists_args(); + } + + public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + isEntityTypeExists_result result = new isEntityTypeExists_result(); + result.success = o; + result.setSuccessIsSet(true); + try { + fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); + return; + } catch (Exception e) { + LOGGER.error("Exception writing to internal frame buffer", e); + } + fb.close(); + } + public void onError(Exception e) { + byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; + org.apache.thrift.TBase msg; + isEntityTypeExists_result result = new isEntityTypeExists_result(); + if (e instanceof org.apache.airavata.sharing.registry.models.SharingRegistryException) { + result.sre = (org.apache.airavata.sharing.registry.models.SharingRegistryException) e; + result.setSreIsSet(true); + msg = result; + } + else + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, isEntityTypeExists_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.isEntityTypeExists(args.domainId, args.entityTypeId,resultHandler); + } + } + public static class deleteEntityType<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteEntityType_args, Boolean> { public deleteEntityType() { super("deleteEntityType"); @@ -6025,6 +6845,64 @@ public class SharingRegistryService { } } + public static class isEntityExists<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, isEntityExists_args, Boolean> { + public isEntityExists() { + super("isEntityExists"); + } + + public isEntityExists_args getEmptyArgsInstance() { + return new isEntityExists_args(); + } + + public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + isEntityExists_result result = new isEntityExists_result(); + result.success = o; + result.setSuccessIsSet(true); + try { + fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); + return; + } catch (Exception e) { + LOGGER.error("Exception writing to internal frame buffer", e); + } + fb.close(); + } + public void onError(Exception e) { + byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; + org.apache.thrift.TBase msg; + isEntityExists_result result = new isEntityExists_result(); + if (e instanceof org.apache.airavata.sharing.registry.models.SharingRegistryException) { + result.sre = (org.apache.airavata.sharing.registry.models.SharingRegistryException) e; + result.setSreIsSet(true); + msg = result; + } + else + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, isEntityExists_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.isEntityExists(args.domainId, args.entityId,resultHandler); + } + } + public static class deleteEntity<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deleteEntity_args, Boolean> { public deleteEntity() { super("deleteEntity"); @@ -6193,7 +7071,7 @@ public class SharingRegistryService { } public void start(I iface, searchEntities_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.sharing.registry.models.Entity>> resultHandler) throws TException { - iface.searchEntities(args.domainId, args.userId, args.filters, args.offset, args.limit, resultHandler); + iface.searchEntities(args.domainId, args.userId, args.filters, args.offset, args.limit,resultHandler); } } @@ -6426,20 +7304,20 @@ public class SharingRegistryService { } } - public static class deletePermissionType<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deletePermissionType_args, Boolean> { - public deletePermissionType() { - super("deletePermissionType"); + public static class isPermissionExists<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, isPermissionExists_args, Boolean> { + public isPermissionExists() { + super("isPermissionExists"); } - public deletePermissionType_args getEmptyArgsInstance() { - return new deletePermissionType_args(); + public isPermissionExists_args getEmptyArgsInstance() { + return new isPermissionExists_args(); } public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<Boolean>() { public void onComplete(Boolean o) { - deletePermissionType_result result = new deletePermissionType_result(); + isPermissionExists_result result = new isPermissionExists_result(); result.success = o; result.setSuccessIsSet(true); try { @@ -6453,121 +7331,7 @@ public class SharingRegistryService { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - deletePermissionType_result result = new deletePermissionType_result(); - if (e instanceof org.apache.airavata.sharing.registry.models.SharingRegistryException) { - result.sre = (org.apache.airavata.sharing.registry.models.SharingRegistryException) e; - result.setSreIsSet(true); - msg = result; - } - else - { - msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; - msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); - } - try { - fcall.sendResponse(fb,msg,msgType,seqid); - return; - } catch (Exception ex) { - LOGGER.error("Exception writing to internal frame buffer", ex); - } - fb.close(); - } - }; - } - - protected boolean isOneway() { - return false; - } - - public void start(I iface, deletePermissionType_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.deletePermissionType(args.domainId, args.permissionTypeId,resultHandler); - } - } - - public static class getPermissionType<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getPermissionType_args, org.apache.airavata.sharing.registry.models.PermissionType> { - public getPermissionType() { - super("getPermissionType"); - } - - public getPermissionType_args getEmptyArgsInstance() { - return new getPermissionType_args(); - } - - public AsyncMethodCallback<org.apache.airavata.sharing.registry.models.PermissionType> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<org.apache.airavata.sharing.registry.models.PermissionType>() { - public void onComplete(org.apache.airavata.sharing.registry.models.PermissionType o) { - getPermissionType_result result = new getPermissionType_result(); - result.success = o; - try { - fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); - return; - } catch (Exception e) { - LOGGER.error("Exception writing to internal frame buffer", e); - } - fb.close(); - } - public void onError(Exception e) { - byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; - org.apache.thrift.TBase msg; - getPermissionType_result result = new getPermissionType_result(); - if (e instanceof org.apache.airavata.sharing.registry.models.SharingRegistryException) { - result.sre = (org.apache.airavata.sharing.registry.models.SharingRegistryException) e; - result.setSreIsSet(true); - msg = result; - } - else - { - msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; - msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); - } - try { - fcall.sendResponse(fb,msg,msgType,seqid); - return; - } catch (Exception ex) { - LOGGER.error("Exception writing to internal frame buffer", ex); - } - fb.close(); - } - }; - } - - protected boolean isOneway() { - return false; - } - - public void start(I iface, getPermissionType_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.sharing.registry.models.PermissionType> resultHandler) throws TException { - iface.getPermissionType(args.domainId, args.permissionTypeId,resultHandler); - } - } - - public static class getPermissionTypes<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getPermissionTypes_args, List<org.apache.airavata.sharing.registry.models.PermissionType>> { - public getPermissionTypes() { - super("getPermissionTypes"); - } - - public getPermissionTypes_args getEmptyArgsInstance() { - return new getPermissionTypes_args(); - } - - public AsyncMethodCallback<List<org.apache.airavata.sharing.registry.models.PermissionType>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { - final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<List<org.apache.airavata.sharing.registry.models.PermissionType>>() { - public void onComplete(List<org.apache.airavata.sharing.registry.models.PermissionType> o) { - getPermissionTypes_result result = new getPermissionTypes_result(); - result.success = o; - try { - fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); - return; - } catch (Exception e) { - LOGGER.error("Exception writing to internal frame buffer", e); - } - fb.close(); - } - public void onError(Exception e) { - byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; - org.apache.thrift.TBase msg; - getPermissionTypes_result result = new getPermissionTypes_result(); + isPermissionExists_result result = new isPermissionExists_result(); if (e instanceof org.apache.airavata.sharing.registry.models.SharingRegistryException) { result.sre = (org.apache.airavata.sharing.registry.models.SharingRegistryException) e; result.setSreIsSet(true); @@ -6593,25 +7357,25 @@ public class SharingRegistryService { return false; } - public void start(I iface, getPermissionTypes_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.sharing.registry.models.PermissionType>> resultHandler) throws TException { - iface.getPermissionTypes(args.domainId, args.offset, args.limit,resultHandler); + public void start(I iface, isPermissionExists_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.isPermissionExists(args.dimainId, args.permissionId,resultHandler); } } - public static class shareEntityWithUsers<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, shareEntityWithUsers_args, Boolean> { - public shareEntityWithUsers() { - super("shareEntityWithUsers"); + public static class deletePermissionType<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, deletePermissionType_args, Boolean> { + public deletePermissionType() { + super("deletePermissionType"); } - public shareEntityWithUsers_args getEmptyArgsInstance() { - return new shareEntityWithUsers_args(); + public deletePermissionType_args getEmptyArgsInstance() { + return new deletePermissionType_args(); } public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; return new AsyncMethodCallback<Boolean>() { public void onComplete(Boolean o) { - shareEntityWithUsers_result result = new shareEntityWithUsers_result(); + deletePermissionType_result result = new deletePermissionType_result(); result.success = o; result.setSuccessIsSet(true); try { @@ -6625,7 +7389,7 @@ public class SharingRegistryService { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - shareEntityWithUsers_result result = new shareEntityWithUsers_result(); + deletePermissionType_result result = new deletePermissionType_result(); if (e instanceof org.apache.airavata.sharing.registry.models.SharingRegistryException) { result.sre = (org.apache.airavata.sharing.registry.models.SharingRegistryException) e; result.setSreIsSet(true); @@ -6651,27 +7415,26 @@ public class SharingRegistryService { return false; } - public void start(I iface, shareEntityWithUsers_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { - iface.shareEntityWithUsers(args.domainId, args.entityId, args.userList, args.perssionTypeId, args.cascadePermission,resultHandler); + public void start(I iface, deletePermissionType_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.deletePermissionType(args.domainId, args.permissionTypeId,resultHandler); } } - public static class revokeEntitySharingFromUsers<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, revokeEntitySharingFromUsers_args, Boolean> { - public revokeEntitySharingFromUsers() { - super("revokeEntitySharingFromUsers"); + public static class getPermissionType<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getPermissionType_args, org.apache.airavata.sharing.registry.models.PermissionType> { + public getPermissionType() { + super("getPermissionType"); } - public revokeEntitySharingFromUsers_args getEmptyArgsInstance() { - return new revokeEntitySharingFromUsers_args(); + public getPermissionType_args getEmptyArgsInstance() { + return new getPermissionType_args(); } - public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + public AsyncMethodCallback<org.apache.airavata.sharing.registry.models.PermissionType> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { final org.apache.thrift.AsyncProcessFunction fcall = this; - return new AsyncMethodCallback<Boolean>() { - public void onComplete(Boolean o) { - revokeEntitySharingFromUsers_result result = new revokeEntitySharingFromUsers_result(); + return new AsyncMethodCallback<org.apache.airavata.sharing.registry.models.PermissionType>() { + public void onComplete(org.apache.airavata.sharing.registry.models.PermissionType o) { + getPermissionType_result result = new getPermissionType_result(); result.success = o; - result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; @@ -6683,7 +7446,180 @@ public class SharingRegistryService { public void onError(Exception e) { byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; - revokeEntitySharingFromUsers_result result = new revokeEntitySharingFromUsers_result(); + getPermissionType_result result = new getPermissionType_result(); + if (e instanceof org.apache.airavata.sharing.registry.models.SharingRegistryException) { + result.sre = (org.apache.airavata.sharing.registry.models.SharingRegistryException) e; + result.setSreIsSet(true); + msg = result; + } + else + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, getPermissionType_args args, org.apache.thrift.async.AsyncMethodCallback<org.apache.airavata.sharing.registry.models.PermissionType> resultHandler) throws TException { + iface.getPermissionType(args.domainId, args.permissionTypeId,resultHandler); + } + } + + public static class getPermissionTypes<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, getPermissionTypes_args, List<org.apache.airavata.sharing.registry.models.PermissionType>> { + public getPermissionTypes() { + super("getPermissionTypes"); + } + + public getPermissionTypes_args getEmptyArgsInstance() { + return new getPermissionTypes_args(); + } + + public AsyncMethodCallback<List<org.apache.airavata.sharing.registry.models.PermissionType>> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<List<org.apache.airavata.sharing.registry.models.PermissionType>>() { + public void onComplete(List<org.apache.airavata.sharing.registry.models.PermissionType> o) { + getPermissionTypes_result result = new getPermissionTypes_result(); + result.success = o; + try { + fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); + return; + } catch (Exception e) { + LOGGER.error("Exception writing to internal frame buffer", e); + } + fb.close(); + } + public void onError(Exception e) { + byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; + org.apache.thrift.TBase msg; + getPermissionTypes_result result = new getPermissionTypes_result(); + if (e instanceof org.apache.airavata.sharing.registry.models.SharingRegistryException) { + result.sre = (org.apache.airavata.sharing.registry.models.SharingRegistryException) e; + result.setSreIsSet(true); + msg = result; + } + else + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, getPermissionTypes_args args, org.apache.thrift.async.AsyncMethodCallback<List<org.apache.airavata.sharing.registry.models.PermissionType>> resultHandler) throws TException { + iface.getPermissionTypes(args.domainId, args.offset, args.limit,resultHandler); + } + } + + public static class shareEntityWithUsers<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, shareEntityWithUsers_args, Boolean> { + public shareEntityWithUsers() { + super("shareEntityWithUsers"); + } + + public shareEntityWithUsers_args getEmptyArgsInstance() { + return new shareEntityWithUsers_args(); + } + + public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + shareEntityWithUsers_result result = new shareEntityWithUsers_result(); + result.success = o; + result.setSuccessIsSet(true); + try { + fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); + return; + } catch (Exception e) { + LOGGER.error("Exception writing to internal frame buffer", e); + } + fb.close(); + } + public void onError(Exception e) { + byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; + org.apache.thrift.TBase msg; + shareEntityWithUsers_result result = new shareEntityWithUsers_result(); + if (e instanceof org.apache.airavata.sharing.registry.models.SharingRegistryException) { + result.sre = (org.apache.airavata.sharing.registry.models.SharingRegistryException) e; + result.setSreIsSet(true); + msg = result; + } + else + { + msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; + msg = (org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); + } + try { + fcall.sendResponse(fb,msg,msgType,seqid); + return; + } catch (Exception ex) { + LOGGER.error("Exception writing to internal frame buffer", ex); + } + fb.close(); + } + }; + } + + protected boolean isOneway() { + return false; + } + + public void start(I iface, shareEntityWithUsers_args args, org.apache.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws TException { + iface.shareEntityWithUsers(args.domainId, args.entityId, args.userList, args.perssionTypeId, args.cascadePermission,resultHandler); + } + } + + public static class revokeEntitySharingFromUsers<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, revokeEntitySharingFromUsers_args, Boolean> { + public revokeEntitySharingFromUsers() { + super("revokeEntitySharingFromUsers"); + } + + public revokeEntitySharingFromUsers_args getEmptyArgsInstance() { + return new revokeEntitySharingFromUsers_args(); + } + + public AsyncMethodCallback<Boolean> getResultHandler(final AsyncFrameBuffer fb, final int seqid) { + final org.apache.thrift.AsyncProcessFunction fcall = this; + return new AsyncMethodCallback<Boolean>() { + public void onComplete(Boolean o) { + revokeEntitySharingFromUsers_result result = new revokeEntitySharingFromUsers_result(); + result.success = o; + result.setSuccessIsSet(true); + try { + fcall.sendResponse(fb,result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); + return; + } catch (Exception e) { + LOGGER.error("Exception writing to internal frame buffer", e); + } + fb.close(); + } + public void onError(Exception e) { + byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; + org.apache.thrift.TBase msg; + revokeEntitySharingFromUsers_result result = new revokeEntitySharingFromUsers_result(); if (e instanceof org.apache.airavata.sharing.registry.models.SharingRegistryException) { result.sre = (org.apache.airavata.sharing.registry.models.SharingRegistryException) e; result.setSreIsSet(true); @@ -8544,15 +9480,15 @@ public class SharingRegistryService { } - public static class deleteDomain_args implements org.apache.thrift.TBase<deleteDomain_args, deleteDomain_args._Fields>, java.io.Serializable, Cloneable, Comparable<deleteDomain_args> { - private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("deleteDomain_args"); + public static class isDomainExists_args implements org.apache.thrift.TBase<isDomainExists_args, isDomainExists_args._Fields>, java.io.Serializable, Cloneable, Comparable<isDomainExists_args> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("isDomainExists_args"); private static final org.apache.thrift.protocol.TField DOMAIN_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("domainId", org.apache.thrift.protocol.TType.STRING, (short)1); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { - schemes.put(StandardScheme.class, new deleteDomain_argsStandardSchemeFactory()); - schemes.put(TupleScheme.class, new deleteDomain_argsTupleSchemeFactory()); + schemes.put(StandardScheme.class, new isDomainExists_argsStandardSchemeFactory()); + schemes.put(TupleScheme.class, new isDomainExists_argsTupleSchemeFactory()); } public String domainId; // required @@ -8622,13 +9558,13 @@ public class SharingRegistryService { tmpMap.put(_Fields.DOMAIN_ID, new org.apache.thrift.meta_data.FieldMetaData("domainId", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); metaDataMap = Collections.unmodifiableMap(tmpMap); - org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(deleteDomain_args.class, metaDataMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(isDomainExists_args.class, metaDataMap); } - public deleteDomain_args() { + public isDomainExists_args() { } - public deleteDomain_args( + public isDomainExists_args( String domainId) { this(); @@ -8638,14 +9574,14 @@ public class SharingRegistryService { /** * Performs a deep copy on <i>other</i>. */ - public deleteDomain_args(deleteDomain_args other) { + public isDomainExists_args(isDomainExists_args other) { if (other.isSetDomainId()) { this.domainId = other.domainId; } } - public deleteDomain_args deepCopy() { - return new deleteDomain_args(this); + public isDomainExists_args deepCopy() { + return new isDomainExists_args(this); } @Override @@ -8657,7 +9593,7 @@ public class SharingRegistryService { return this.domainId; } - public deleteDomain_args setDomainId(String domainId) { + public isDomainExists_args setDomainId(String domainId) { this.domainId = domainId; return this; } @@ -8716,12 +9652,12 @@ public class SharingRegistryService { public boolean equals(Object that) { if (that == null) return false; - if (that instanceof deleteDomain_args) - return this.equals((deleteDomain_args)that); + if (that instanceof isDomainExists_args) + return this.equals((isDomainExists_args)that); return false; } - public boolean equals(deleteDomain_args that) { + public boolean equals(isDomainExists_args that) { if (that == null) return false; @@ -8750,7 +9686,7 @@ public class SharingRegistryService { } @Override - public int compareTo(deleteDomain_args other) { + public int compareTo(isDomainExists_args other) { if (!getClass().equals(other.getClass())) { return getClass().getName().compareTo(other.getClass().getName()); } @@ -8784,7 +9720,7 @@ public class SharingRegistryService { @Override public String toString() { - StringBuilder sb = new StringBuilder("deleteDomain_args("); + StringBuilder sb = new StringBuilder("isDomainExists_args("); boolean first = true; sb.append("domainId:"); @@ -8822,15 +9758,15 @@ public class SharingRegistryService { } } - private static class deleteDomain_argsStandardSchemeFactory implements SchemeFactory { - public deleteDomain_argsStandardScheme getScheme() { - return new deleteDomain_argsStandardScheme(); + private static class isDomainExists_argsStandardSchemeFactory implements SchemeFactory { + public isDomainExists_argsStandardScheme getScheme() { + return new isDomainExists_argsStandardScheme(); } } - private static class deleteDomain_argsStandardScheme extends StandardScheme<deleteDomain_args> { + private static class isDomainExists_argsStandardScheme extends StandardScheme<isDomainExists_args> { - public void read(org.apache.thrift.protocol.TProtocol iprot, deleteDomain_args struct) throws org.apache.thrift.TException { + public void read(org.apache.thrift.protocol.TProtocol iprot, isDomainExists_args struct) throws org.apache.thrift.TException { org.apache.thrift.protocol.TField schemeField; iprot.readStructBegin(); while (true) @@ -8859,7 +9795,7 @@ public class SharingRegistryService { struct.validate(); } - public void write(org.apache.thrift.protocol.TProtocol oprot, deleteDomain_args struct) throws org.apache.thrift.TException { + public void write(org.apache.thrift.protocol.TProtocol oprot, isDomainExists_args struct) throws org.apache.thrift.TException { struct.validate(); oprot.writeStructBegin(STRUCT_DESC); @@ -8874,22 +9810,22 @@ public class SharingRegistryService { } - private static class deleteDomain_argsTupleSchemeFactory implements SchemeFactory { -
<TRUNCATED>
