Replicate gateway information if APPROVED in addGateway()
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/940e0bae Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/940e0bae Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/940e0bae Branch: refs/heads/registry-refactoring Commit: 940e0baed816df7ede6f736915bf2937599d6534 Parents: e1a9ab4 Author: Gourav Shenoy <[email protected]> Authored: Thu May 11 13:55:53 2017 -0400 Committer: Gourav Shenoy <[email protected]> Committed: Thu May 11 13:55:53 2017 -0400 ---------------------------------------------------------------------- .../handlers/TenantProfileServiceHandler.java | 15 +++++++++------ 1 file changed, 9 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata/blob/940e0bae/airavata-services/profile-service/profile-service-server/src/main/java/org/apache/airavata/service/profile/handlers/TenantProfileServiceHandler.java ---------------------------------------------------------------------- diff --git a/airavata-services/profile-service/profile-service-server/src/main/java/org/apache/airavata/service/profile/handlers/TenantProfileServiceHandler.java b/airavata-services/profile-service/profile-service-server/src/main/java/org/apache/airavata/service/profile/handlers/TenantProfileServiceHandler.java index 1327ae1..04870d9 100644 --- a/airavata-services/profile-service/profile-service-server/src/main/java/org/apache/airavata/service/profile/handlers/TenantProfileServiceHandler.java +++ b/airavata-services/profile-service/profile-service-server/src/main/java/org/apache/airavata/service/profile/handlers/TenantProfileServiceHandler.java @@ -74,12 +74,15 @@ public class TenantProfileServiceHandler implements TenantProfileService.Iface { try { gateway = tenantProfileRepository.create(gateway); if (gateway != null) { - logger.debug("Added Airavata Gateway with Id: " + gateway.getGatewayId()); - // replicate tenant at end-places - ProfileServiceUtils.getDbEventPublisher().publish( - ProfileServiceUtils.getDBEventMessageContext(EntityType.TENANT, CrudType.CREATE, gateway), - DBEventManagerConstants.getRoutingKey(DBEventService.DB_EVENT.toString()) - ); + logger.info("Added Airavata Gateway with Id: " + gateway.getGatewayId()); + // replicate tenant at end-places only if status is APPROVED + if (gateway.getGatewayApprovalStatus().equals(GatewayApprovalStatus.APPROVED)) { + logger.info("Gateway with ID: {}, is now APPROVED, replicating to subscribers.", gateway.getGatewayId()); + ProfileServiceUtils.getDbEventPublisher().publish( + ProfileServiceUtils.getDBEventMessageContext(EntityType.TENANT, CrudType.CREATE, gateway), + DBEventManagerConstants.getRoutingKey(DBEventService.DB_EVENT.toString()) + ); + } // return gatewayId return gateway.getGatewayId(); } else {
