You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ra...@apache.org on 2007/11/13 05:41:58 UTC
svn commit: r594429 - in
/incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf:
JMSConsumer.java JMSProducer.java MessageConsumerTest.java
MessageProducerTest.java
Author: rajith
Date: Mon Nov 12 20:41:57 2007
New Revision: 594429
URL: http://svn.apache.org/viewvc?rev=594429&view=rev
Log:
Fixed errors in the calculation
Modified:
incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/JMSConsumer.java
incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/JMSProducer.java
incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageConsumerTest.java
incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageProducerTest.java
Modified: incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/JMSConsumer.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/JMSConsumer.java?rev=594429&r1=594428&r2=594429&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/JMSConsumer.java (original)
+++ incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/JMSConsumer.java Mon Nov 12 20:41:57 2007
@@ -57,10 +57,10 @@
if (msg != null)
{
long msgId = Integer.parseInt(msg.getJMSCorrelationID());
- if (_currentMsgCount+1 != msgId)
+ /*if (_currentMsgCount+1 != msgId)
{
- _logger.error("Error : Message received out of order in JMSConsumer:" + _id + " message id was " + msgId);
- }
+ _logger.error("Error : Message received out of order in JMSConsumer:" + _id + " message id was " + msgId + " expected: " + _currentMsgCount+1);
+ }*/
_currentMsgCount ++;
}
}
@@ -83,6 +83,7 @@
public void stopConsuming()
{
_run.set(false);
+ System.out.println("Producer received notification to stop");
}
public String getId()
Modified: incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/JMSProducer.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/JMSProducer.java?rev=594429&r1=594428&r2=594429&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/JMSProducer.java (original)
+++ incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/JMSProducer.java Mon Nov 12 20:41:57 2007
@@ -78,6 +78,7 @@
public void stopProducing()
{
_run.set(false);
+ System.out.println("Producer received notification to stop");
}
public String getId()
Modified: incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageConsumerTest.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageConsumerTest.java?rev=594429&r1=594428&r2=594429&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageConsumerTest.java (original)
+++ incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageConsumerTest.java Mon Nov 12 20:41:57 2007
@@ -124,9 +124,9 @@
_memoryLog.close();
if (printSummary)
{
- double totaltime = (d.getTime() - _startTime)*1000; // trying to get a per sec rate
+ double totaltime = d.getTime() - _startTime;
double dCount = totalMsgCount;
- double ratio = dCount/totaltime;
+ double ratio = (dCount/totaltime)*1000;
FileWriter _summaryLog = new FileWriter(_logFileName + "_Summary",true);
buf = new StringBuffer("MessageConsumerTest \n Test started at : ");
buf.append(df.format(new Date(_startTime))).append("\n Test finished at : ");
Modified: incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageProducerTest.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageProducerTest.java?rev=594429&r1=594428&r2=594429&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageProducerTest.java (original)
+++ incubator/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/client/perf/MessageProducerTest.java Mon Nov 12 20:41:57 2007
@@ -121,9 +121,9 @@
_memoryLog.close();
if (printSummary)
{
- double totaltime = (d.getTime() - _startTime)*1000; // trying to get a per sec rate
+ double totaltime = d.getTime() - _startTime;
double dCount = totalMsgCount;
- double ratio = dCount/totaltime;
+ double ratio = (dCount/totaltime)*1000;
FileWriter _summaryLog = new FileWriter(_logFileName + "_Summary",true);
buf = new StringBuffer("MessageProducerTest \n Test started at : ");
buf.append(df.format(new Date(_startTime))).append("\n Test finished at : ");