airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lah...@apache.org
Subject [01/13] airavata git commit: removing stat collecting
Date Wed, 25 Feb 2015 06:09:42 GMT
Repository: airavata
Updated Branches:
  refs/heads/queue-gfac-rabbitmq ffbb1b9f6 -> 93ed077e8


removing stat collecting


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

Branch: refs/heads/queue-gfac-rabbitmq
Commit: 32f10d183bb53106426f4879b0cd97d138031f96
Parents: 33d2e27
Author: chathuriw <kamalasini@gmail.com>
Authored: Tue Feb 24 10:52:56 2015 -0500
Committer: Chathuri Wimalasena <kamalasini@gmail.com>
Committed: Tue Feb 24 10:52:56 2015 -0500

----------------------------------------------------------------------
 .../apache/airavata/messaging/core/impl/RabbitMQPublisher.java  | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/airavata/blob/32f10d18/modules/messaging/core/src/main/java/org/apache/airavata/messaging/core/impl/RabbitMQPublisher.java
----------------------------------------------------------------------
diff --git a/modules/messaging/core/src/main/java/org/apache/airavata/messaging/core/impl/RabbitMQPublisher.java
b/modules/messaging/core/src/main/java/org/apache/airavata/messaging/core/impl/RabbitMQPublisher.java
index a8b5150..f9bafd9 100644
--- a/modules/messaging/core/src/main/java/org/apache/airavata/messaging/core/impl/RabbitMQPublisher.java
+++ b/modules/messaging/core/src/main/java/org/apache/airavata/messaging/core/impl/RabbitMQPublisher.java
@@ -28,7 +28,6 @@ import org.apache.airavata.common.utils.ThriftUtils;
 import org.apache.airavata.messaging.core.MessageContext;
 import org.apache.airavata.messaging.core.MessagingConstants;
 import org.apache.airavata.messaging.core.Publisher;
-import org.apache.airavata.messaging.core.stats.StatCounter;
 import org.apache.airavata.model.messaging.event.*;
 import org.apache.thrift.TException;
 import org.slf4j.Logger;
@@ -40,7 +39,7 @@ public class RabbitMQPublisher implements Publisher {
 
     private RabbitMQProducer rabbitMQProducer;
 
-    StatCounter statCounter = StatCounter.getInstance();
+//    StatCounter statCounter = StatCounter.getInstance();
 
     public RabbitMQPublisher() throws Exception {
         String brokerUrl;
@@ -89,7 +88,7 @@ public class RabbitMQPublisher implements Publisher {
             }
             byte[] messageBody = ThriftUtils.serializeThriftObject(message);
             rabbitMQProducer.send(messageBody, routingKey);
-            statCounter.add(message);
+//            statCounter.add(message);
         } catch (TException e) {
             String msg = "Error while deserializing the object";
             log.error(msg, e);


Mime
View raw message