Repository: stratos Updated Branches: refs/heads/stratos-4.1.x 529c38521 -> bf598dd36
Update the ArtifactDistributionCoordinator Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/bf598dd3 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/bf598dd3 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/bf598dd3 Branch: refs/heads/stratos-4.1.x Commit: bf598dd365e15dc7752b32de96289b726e559167 Parents: 529c385 Author: gayangunarathne <[email protected]> Authored: Fri Nov 20 14:03:51 2015 +0530 Committer: gayangunarathne <[email protected]> Committed: Fri Nov 20 14:03:51 2015 +0530 ---------------------------------------------------------------------- .../ArtifactDistributionCoordinator.java | 72 ++++++++++---------- 1 file changed, 36 insertions(+), 36 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/bf598dd3/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/components/ArtifactDistributionCoordinator.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/components/ArtifactDistributionCoordinator.java b/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/components/ArtifactDistributionCoordinator.java index e03bbcb..704bca1 100644 --- a/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/components/ArtifactDistributionCoordinator.java +++ b/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/components/ArtifactDistributionCoordinator.java @@ -124,47 +124,47 @@ public class ArtifactDistributionCoordinator { log.warn(String.format("Artifact updated event not sent, " + "application signups not found for repository: [repo-url] %s", repoUrl)); return; - } else { - for (ApplicationSignUp applicationSignUp : applicationSignUps) { - if (applicationSignUp.getArtifactRepositories() != null) { - for (ArtifactRepository artifactRepository : applicationSignUp.getArtifactRepositories()) { - if ((artifactRepository != null) && (artifactRepository.getRepoUrl().equals(repoUrl))) { - - - String applicationId = applicationSignUp.getApplicationId(); - int tenantId = applicationSignUp.getTenantId(); - String clusterId = findClusterId(applicationId, artifactRepository.getAlias()); - - publisher.publishArtifactUpdatedEvent(clusterId, - String.valueOf( - applicationSignUp.getTenantId()), - artifactRepository.getRepoUrl(), - artifactRepository.getRepoUsername(), - artifactRepository.getRepoPassword(), false); - - if (log.isInfoEnabled()) { - log.info( - String.format("Artifact updated event published: [application-id] %s" + - " " + - "[tenant-id] %d [cartridge-type] %s [alias] %s [repo-url" + - "] %s", - applicationId, - tenantId, - artifactRepository.getCartridgeType(), - artifactRepository.getAlias(), - artifactRepository.getRepoUrl())); - } + } + } else { + for (ApplicationSignUp applicationSignUp : applicationSignUps) { + if (applicationSignUp.getArtifactRepositories() != null) { + for (ArtifactRepository artifactRepository : applicationSignUp.getArtifactRepositories()) { + if ((artifactRepository != null) && (artifactRepository.getRepoUrl().equals(repoUrl))) { + + String applicationId = applicationSignUp.getApplicationId(); + int tenantId = applicationSignUp.getTenantId(); + String clusterId = findClusterId(applicationId, artifactRepository.getAlias()); + + publisher.publishArtifactUpdatedEvent(clusterId, + String.valueOf( + applicationSignUp.getTenantId()), + artifactRepository.getRepoUrl(), + artifactRepository.getRepoUsername(), + artifactRepository.getRepoPassword(), false); + + if (log.isInfoEnabled()) { + log.info( + String.format("Artifact updated event published: [application-id] %s" + + " " + + "[tenant-id] %d [cartridge-type] %s [alias] %s [repo-url" + + "] %s", + applicationId, + tenantId, + artifactRepository.getCartridgeType(), + artifactRepository.getAlias(), + artifactRepository.getRepoUrl())); } } - } else { - if (log.isWarnEnabled()) { - log.warn(String.format("Application signUp artifact repositories are empty for %s", - repoUrl)); - return; - } + } + } else { + if (log.isWarnEnabled()) { + log.warn(String.format("Application signUp artifact repositories are empty for %s", + repoUrl)); + return; } } } + } } catch (Exception e) { String message = "Could not notify artifact updated event";
