airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chath...@apache.org
Subject [1/2] git commit: Adding broker url
Date Wed, 24 Sep 2014 19:54:37 GMT
Repository: airavata
Updated Branches:
  refs/heads/messaging_framework a7581e747 -> 88d8638f2


Adding broker url


Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/412f1e7a
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/412f1e7a
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/412f1e7a

Branch: refs/heads/messaging_framework
Commit: 412f1e7af00b7800b6794454b1c4265529eafbe7
Parents: a7581e7
Author: chathuriw <kamalasini@gmail.com>
Authored: Wed Sep 24 10:19:15 2014 -0400
Committer: Chathuri Wimalasena <kamalasini@gmail.com>
Committed: Wed Sep 24 10:19:15 2014 -0400

----------------------------------------------------------------------
 .../server/src/main/resources/airavata-server.properties     | 1 +
 .../messaging/core/impl/AiravataRabbitMQPublisher.java       | 8 ++++++++
 2 files changed, 9 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/airavata/blob/412f1e7a/modules/configuration/server/src/main/resources/airavata-server.properties
----------------------------------------------------------------------
diff --git a/modules/configuration/server/src/main/resources/airavata-server.properties b/modules/configuration/server/src/main/resources/airavata-server.properties
index ebf5350..51d71e1 100644
--- a/modules/configuration/server/src/main/resources/airavata-server.properties
+++ b/modules/configuration/server/src/main/resources/airavata-server.properties
@@ -189,6 +189,7 @@ connection.name=xsede
 activity.listeners=org.apache.airavata.gfac.core.monitor.AiravataJobStatusUpdator,org.apache.airavata.gfac.core.monitor.AiravataTaskStatusUpdator,org.apache.airavata.gfac.core.monitor.AiravataWorkflowNodeStatusUpdator,org.apache.airavata.api.server.listener.AiravataExperimentStatusUpdator,org.apache.airavata.gfac.core.monitor.GfacInternalStatusUpdator,org.apache.airavata.workflow.engine.util.ProxyMonitorPublisher
 #publisher
 activity.publisher=org.apache.airavata.messaging.core.impl.AiravataRabbitMQPublisher
+rabbitmq.broker.url=http://localhost
 
 ###---------------------------Orchestrator module Configurations---------------------------###
 #job.submitter=org.apache.airavata.orchestrator.core.impl.GFACEmbeddedJobSubmitter

http://git-wip-us.apache.org/repos/asf/airavata/blob/412f1e7a/modules/messaging/core/src/main/java/org/apache/airavata/messaging/core/impl/AiravataRabbitMQPublisher.java
----------------------------------------------------------------------
diff --git a/modules/messaging/core/src/main/java/org/apache/airavata/messaging/core/impl/AiravataRabbitMQPublisher.java
b/modules/messaging/core/src/main/java/org/apache/airavata/messaging/core/impl/AiravataRabbitMQPublisher.java
index 7fc5342..eaa6158 100644
--- a/modules/messaging/core/src/main/java/org/apache/airavata/messaging/core/impl/AiravataRabbitMQPublisher.java
+++ b/modules/messaging/core/src/main/java/org/apache/airavata/messaging/core/impl/AiravataRabbitMQPublisher.java
@@ -28,7 +28,15 @@ import org.apache.airavata.model.messaging.event.TaskStatusChangeEvent;
 import org.apache.airavata.model.messaging.event.WorkflowNodeStatusChangeEvent;
 
 public class AiravataRabbitMQPublisher implements Publisher {
+    private String brokerUrl;
+    private String routingKey;
+    private String exchangeName;
+    private int prefetchCount;
+    private boolean isRequeueOnFail;
+
     public AiravataRabbitMQPublisher() {
+
+        RabbitMQProducer rabbitMQProducer = new RabbitMQProducer(brokerUrl, routingKey, exchangeName,
prefetchCount, isRequeueOnFail);
     }
 
     public void publish(ExperimentStatusChangeEvent event) {


Mime
View raw message