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/master Commit: 412f1e7af00b7800b6794454b1c4265529eafbe7 Parents: a7581e7 Author: chathuriw <[email protected]> Authored: Wed Sep 24 10:19:15 2014 -0400 Committer: Chathuri Wimalasena <[email protected]> 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) {
