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 : ");
