mirror of https://github.com/apache/activemq.git
fixed up the protocol buffers test case
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@687030 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
a0ac983ea3
commit
02b9774dfc
|
@ -48,7 +48,7 @@
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>com.google.protobuf</groupId>
|
<groupId>com.google.protobuf</groupId>
|
||||||
<artifactId>protobuf-java</artifactId>
|
<artifactId>protobuf-java</artifactId>
|
||||||
<version>2.0.0beta</version>
|
<version>2.0.0-SNAPSHOT</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
|
|
||||||
|
|
|
@ -75,6 +75,7 @@ public class PerformanceTest extends TestSupport {
|
||||||
int previous = cin.pushLimit(size);
|
int previous = cin.pushLimit(size);
|
||||||
//cin.setSizeLimit(size + 4);
|
//cin.setSizeLimit(size + 4);
|
||||||
OpenWire.Message message = OpenWire.Message.parseFrom(cin);
|
OpenWire.Message message = OpenWire.Message.parseFrom(cin);
|
||||||
|
cin.resetBytesReadCounter();
|
||||||
cin.popLimit(previous);
|
cin.popLimit(previous);
|
||||||
|
|
||||||
if (verbose) {
|
if (verbose) {
|
||||||
|
|
|
@ -23,10 +23,9 @@ import junit.framework.TestCase;
|
||||||
* @version $Revision: 1.1 $
|
* @version $Revision: 1.1 $
|
||||||
*/
|
*/
|
||||||
public class TestSupport extends TestCase {
|
public class TestSupport extends TestCase {
|
||||||
// TODO seems like 4m messages cause Protocol Buffers to barf but 3m is fine :)
|
protected long messageCount = 10 * 1000 * 1000;
|
||||||
protected long messageCount = 4 * 1000 * 1000;
|
|
||||||
protected boolean verbose = false;
|
protected boolean verbose = false;
|
||||||
protected boolean doAssertions = true;
|
protected boolean doAssertions = false;
|
||||||
protected boolean useProducerId = false;
|
protected boolean useProducerId = false;
|
||||||
|
|
||||||
protected StopWatch createStopWatch(String name) {
|
protected StopWatch createStopWatch(String name) {
|
||||||
|
|
Loading…
Reference in New Issue