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 <[email protected]> Authored: Tue Feb 24 10:52:56 2015 -0500 Committer: Chathuri Wimalasena <[email protected]> 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);
