airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From scnakand...@apache.org
Subject [39/61] [abbrv] airavata git commit: Replicate gateway information if APPROVED in addGateway()
Date Wed, 24 May 2017 21:34:49 GMT
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/master
Commit: 940e0baed816df7ede6f736915bf2937599d6534
Parents: e1a9ab4
Author: Gourav Shenoy <goshenoy@apache.org>
Authored: Thu May 11 13:55:53 2017 -0400
Committer: Gourav Shenoy <goshenoy@apache.org>
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 {


Mime
View raw message