airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lah...@apache.org
Subject svn commit: r1172658 - in /incubator/airavata/trunk/modules/ws-messenger/samples/messagebroker/wse-multiple-producers-consumers-topics: conf/configurations.properties src/wsmg/samples/wse/Consumer.java
Date Mon, 19 Sep 2011 15:22:32 GMT
Author: lahiru
Date: Mon Sep 19 15:22:31 2011
New Revision: 1172658

URL: http://svn.apache.org/viewvc?rev=1172658&view=rev
Log:
fixing https://issues.apache.org/jira/browse/AIRAVATA-113.

Modified:
    incubator/airavata/trunk/modules/ws-messenger/samples/messagebroker/wse-multiple-producers-consumers-topics/conf/configurations.properties
    incubator/airavata/trunk/modules/ws-messenger/samples/messagebroker/wse-multiple-producers-consumers-topics/src/wsmg/samples/wse/Consumer.java

Modified: incubator/airavata/trunk/modules/ws-messenger/samples/messagebroker/wse-multiple-producers-consumers-topics/conf/configurations.properties
URL: http://svn.apache.org/viewvc/incubator/airavata/trunk/modules/ws-messenger/samples/messagebroker/wse-multiple-producers-consumers-topics/conf/configurations.properties?rev=1172658&r1=1172657&r2=1172658&view=diff
==============================================================================
--- incubator/airavata/trunk/modules/ws-messenger/samples/messagebroker/wse-multiple-producers-consumers-topics/conf/configurations.properties
(original)
+++ incubator/airavata/trunk/modules/ws-messenger/samples/messagebroker/wse-multiple-producers-consumers-topics/conf/configurations.properties
Mon Sep 19 15:22:31 2011
@@ -24,6 +24,6 @@ broker.notification.service.epr=http://l
 consumer.port=6060
 topic.prefix=topic_prefix_
 publish.time.interval=6
-producer.count.per.topic=1
-consumer.count.per.topic=1
+producer.count.per.topic=2
+consumer.count.per.topic=3
 number.of.topics=1

Modified: incubator/airavata/trunk/modules/ws-messenger/samples/messagebroker/wse-multiple-producers-consumers-topics/src/wsmg/samples/wse/Consumer.java
URL: http://svn.apache.org/viewvc/incubator/airavata/trunk/modules/ws-messenger/samples/messagebroker/wse-multiple-producers-consumers-topics/src/wsmg/samples/wse/Consumer.java?rev=1172658&r1=1172657&r2=1172658&view=diff
==============================================================================
--- incubator/airavata/trunk/modules/ws-messenger/samples/messagebroker/wse-multiple-producers-consumers-topics/src/wsmg/samples/wse/Consumer.java
(original)
+++ incubator/airavata/trunk/modules/ws-messenger/samples/messagebroker/wse-multiple-producers-consumers-topics/src/wsmg/samples/wse/Consumer.java
Mon Sep 19 15:22:31 2011
@@ -117,11 +117,9 @@ public class Consumer extends Thread {
 
 					numberOfMsgRecieved.incrementAndGet();
 
-					/*
-					 * System.out .println(String.format(
-					 * "consumer [%s] recieved: %s", getName(),
-					 * numberOfMsgRecieved));
-					 */
+					 System.out .println(String.format(
+					 "consumer [%s] recieved: %s", getName(),
+					 numberOfMsgRecieved));
 				} catch (Exception e) {
 					System.err.print("invalid msg recieved");
 				}



Mime
View raw message