Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

minor tweak trying to get PB to actually work :) 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@674841 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
James Strachan 2008-07-08 14:28:51 +00:00
parent f9b668b05b
commit 276826d80c
1 changed files with 3 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
activemq-protocol-buffer/src/test/java/org/apache/activemq/protocolbuffer/PerformanceTest.java
View File

@ -21,8 +21,6 @@ import com.google.protobuf.CodedInputStream;
import com.google.protobuf.CodedOutputStream; import com.google.protobuf.CodedOutputStream;
import junit.framework.TestCase; import junit.framework.TestCase;
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.FileInputStream; import java.io.FileInputStream;
import java.io.FileOutputStream; import java.io.FileOutputStream;
@ -35,7 +33,7 @@ public class PerformanceTest extends TestCase {
public void testPerformance() throws Exception { public void testPerformance() throws Exception {
BufferedOutputStream out = new BufferedOutputStream(new FileOutputStream(fileName)); FileOutputStream out = new FileOutputStream(fileName);
CodedOutputStream cout = CodedOutputStream.newInstance(out); CodedOutputStream cout = CodedOutputStream.newInstance(out);
OpenWire.Destination destination = OpenWire.Destination.newBuilder().setName("FOO.BAR").setType(OpenWire.Destination.DestinationType.QUEUE).build(); OpenWire.Destination destination = OpenWire.Destination.newBuilder().setName("FOO.BAR").setType(OpenWire.Destination.DestinationType.QUEUE).build();
@ -50,20 +48,16 @@ public class PerformanceTest extends TestCase {
System.out.println("Writing message: " + i + " = " + message); System.out.println("Writing message: " + i + " = " + message);
message.writeTo(cout); message.writeTo(cout);
//cout.flush();
}
cout.flush(); cout.flush();
}
out.close(); out.close();
// now lets try read them! // now lets try read them!
BufferedInputStream in = new BufferedInputStream(new FileInputStream(fileName)); FileInputStream in = new FileInputStream(fileName);
CodedInputStream cin = CodedInputStream.newInstance(in); CodedInputStream cin = CodedInputStream.newInstance(in);
for (int i = 0; i < messageCount; i++) { for (int i = 0; i < messageCount; i++) {
OpenWire.Message message = OpenWire.Message.parseFrom(cin); OpenWire.Message message = OpenWire.Message.parseFrom(cin);
// todo test its not null or something?
System.out.println("Reading message: " + i + " = " + message); System.out.println("Reading message: " + i + " = " + message);
} }
in.close(); in.close();
} }