Source code: org/activemq/io/impl/ReceiptReaderTest.java
1 /*
2 * Created on Mar 8, 2004
3 *
4 * To change the template for this generated file go to
5 * Window - Preferences - Java - Code Generation - Code and Comments
6 */
7 package org.activemq.io.impl;
8
9 import org.activemq.message.Packet;
10 import org.activemq.message.PacketTestSupport;
11 import org.activemq.message.Receipt;
12
13
14 /**
15 * To change the template for this generated type comment go to
16 * Window - Preferences - Java - Code Generation - Code and Comments
17 */
18 public class ReceiptReaderTest extends PacketTestSupport {
19 private short id;
20 private short correlationId;
21
22 public static void main(String[] args) {
23 junit.textui.TestRunner.run(ReceiptReaderTest.class);
24 }
25
26 /*
27 * @see TestCase#setUp()
28 */
29 protected void setUp() throws Exception {
30 super.setUp();
31 this.id = 5445;
32 this.correlationId = 6677;
33 }
34
35 /*
36 * @see TestCase#tearDown()
37 */
38 protected void tearDown() throws Exception {
39 super.tearDown();
40 }
41
42 public void testGetPacketType() {
43 ReceiptReader reader = new ReceiptReader();
44 assertTrue(reader.getPacketType() == Packet.RECEIPT_INFO);
45 }
46
47 public void testReadPacket() {
48 Receipt info = (Receipt) createPacket();
49
50 ReceiptWriter writer = new ReceiptWriter();
51 ReceiptReader reader = new ReceiptReader();
52 try {
53 byte[] data = writer.writePacketToByteArray(info);
54 Receipt receipt = (Receipt) reader.readPacketFromByteArray(data);
55
56 assertPacket(receipt, info);
57 }
58 catch (Throwable e) {
59 e.printStackTrace();
60 assertTrue(false);
61 }
62 }
63
64 public void testTime() {
65
66 Receipt info = (Receipt) createPacket();
67
68 ReceiptWriter writer = new ReceiptWriter();
69 ReceiptReader reader = new ReceiptReader();
70
71 try {
72 int count = 100000;
73 long startTime = System.currentTimeMillis();
74 for (int i = 0; i < count; i++) {
75 byte[] data = writer.writePacketToByteArray(info);
76 Receipt test = (Receipt) reader.readPacketFromByteArray(data);
77 }
78 long finishTime = System.currentTimeMillis();
79 long totalTime = finishTime - startTime;
80 long ps = (count * 1000) / totalTime;
81 System.out.println("Time taken :" + totalTime + " for " + count + "iterations, = " + ps + " per sec.");
82
83 }
84 catch (Throwable e) {
85 e.printStackTrace();
86 assertTrue(false);
87 }
88 }
89
90 protected void assertValidPacket(Packet packet) {
91 Receipt receipt = (Receipt) packet;
92 assertTrue(receipt.getId() == this.id);
93 assertTrue(receipt.getCorrelationId() == this.correlationId);
94 }
95
96 protected Packet createPacket() {
97 Receipt info = new Receipt();
98 info.setId(this.id);
99 info.setCorrelationId(this.correlationId);
100 return info;
101 }
102
103 }