Source code: proxy/protocol/SerializeTest.java
1 package proxy.protocol;
2
3 import junit.framework.*;
4
5 /**
6 * <p>Description: Tests serialization of requests in mobile.protocol and their
7 * construction i proxy.protocol</p>
8
9 * @author Pawel Koziol
10
11 */
12
13 public class SerializeTest
14 extends TestCase
15 implements mobile.bearer.http.Protocol {
16 proxy.protocol.Request pR;
17 mobile.protocol.Request mR;
18
19 /**
20 * The main method for this test.
21 */
22 public static void main(String[] args) {
23 junit.textui.TestRunner.run(suite());
24 }
25
26 protected void setUp() {
27
28 }
29
30 /**
31 * Builds a new test suite for this test.
32 */
33 public static Test suite() {
34 return new TestSuite(SerializeTest.class);
35 }
36
37 /**
38 A serialization tests of a Request with the LOOKUP code
39 */
40 public void testLookupQCF() {
41 mR = new mobile.protocol.Request();
42 mR.code = LOOKUP;
43 mR.id = 1;
44 Object data[] = new Object[1];
45 data[0] = new String("nazwaQCF");
46 mR.setData(data);
47 byte[] msg = mR.serialize();
48 pR = new proxy.protocol.Request(mR.code, 1, 1, 1, msg);
49 assertTrue( ( (String) pR.getData()[0]).equals(new String("nazwaQCF")));
50 }
51
52 /**
53 A serialization tests of a Request with the LOOKUP code
54 */
55
56 public void testLookupTCF() {
57 mR = new mobile.protocol.Request();
58 mR.code = LOOKUP;
59 mR.id = 1;
60 Object data[] = new Object[1];
61 data[0] = new String("nazwaTCF");
62 mR.setData(data);
63 byte[] msg = mR.serialize();
64 pR = new proxy.protocol.Request(mR.code, 1, 1, 1, msg);
65 assertTrue( ( (String) pR.getData()[0]).equals(new String("nazwaTCF")));
66 }
67 /**
68 A serialization tests of a Request with the LOOKUP code
69 */
70
71 public void testLookupQ() {
72 mR = new mobile.protocol.Request();
73 mR.code = LOOKUP;
74 mR.id = 1;
75 Object data[] = new Object[1];
76 data[0] = new String("nazwaQ");
77 mR.setData(data);
78 byte[] msg = mR.serialize();
79 pR = new proxy.protocol.Request(mR.code, 1, 1, 1, msg);
80 assertTrue( ( (String) pR.getData()[0]).equals(new String("nazwaQ")));
81 }
82 /**
83 A serialization tests of a Request with the LOOKUP code
84 */
85
86 public void testLookupT() {
87 mR = new mobile.protocol.Request();
88 mR.code = LOOKUP;
89 mR.id = 1;
90 Object data[] = new Object[1];
91 data[0] = new String("nazwaT");
92 mR.setData(data);
93 byte[] msg = mR.serialize();
94 pR = new proxy.protocol.Request(mR.code, 1, 1, 1, msg);
95 assertTrue( ( (String) pR.getData()[0]).equals(new String("nazwaT")));
96 }
97
98 /**
99 A serialization tests of a Connection creation.
100 */
101
102
103 public void testCreateQC() {
104 mR = new mobile.protocol.Request();
105 mR.code = CREATE_QUEUE_CONNECTION;
106 mR.id = 1;
107 Object data[] = new Object[1];
108 data[0] = new Integer(1234);
109 mR.setData(data);
110 byte[] msg = mR.serialize();
111 pR = new proxy.protocol.Request(mR.code, 1, 1, 1, msg);
112 assertTrue( ( (Integer) pR.getData()[0]).equals(new Integer(1234)));
113 }
114 /**
115 A serialization tests of a Connection creation.
116 */
117
118 public void testCreateTC() {
119 mR = new mobile.protocol.Request();
120 mR.code = CREATE_TOPIC_CONNECTION;
121 mR.id = 1;
122 Object data[] = new Object[1];
123 data[0] = new Integer(1234);
124 mR.setData(data);
125 byte[] msg = mR.serialize();
126 pR = new proxy.protocol.Request(mR.code, 1, 1, 1, msg);
127 assertTrue( ( (Integer) pR.getData()[0]).equals(new Integer(1234)));
128 }
129
130 /**
131 A serialization tests of a Session creation.
132 */
133
134 public void testCreateQSES() {
135 mR = new mobile.protocol.Request();
136 mR.code = CREATE_QUEUE_SESSION;
137 mR.id = 1;
138 Object data[] = new Object[3];
139 data[0] = new Integer(1234);
140 data[1] = new Boolean(true);
141 data[2] = new Integer(11);
142 mR.setData(data);
143 byte[] msg = mR.serialize();
144 pR = new proxy.protocol.Request(mR.code, 1, 1, 1, msg);
145 assertTrue( ( (Integer) pR.getData()[0]).equals(new Integer(1234)));
146 assertTrue( ( (Boolean) pR.getData()[1]).equals(new Boolean(true)));
147 assertTrue( ( (Integer) pR.getData()[2]).equals(new Integer(11)));
148 }
149
150 /**
151 A serialization tests of a Session creation.
152 */
153
154 public void testCreateQSES2() { /*false acknowledge value */
155 mR = new mobile.protocol.Request();
156 mR.code = CREATE_QUEUE_SESSION;
157 mR.id = 1;
158 Object data[] = new Object[3];
159 data[0] = new Integer(1234);
160 data[1] = new Boolean(false);
161 data[2] = new Integer(11);
162 mR.setData(data);
163 byte[] msg = mR.serialize();
164 pR = new proxy.protocol.Request(mR.code, 1, 1, 1, msg);
165 assertTrue( ( (Integer) pR.getData()[0]).equals(new Integer(1234)));
166 assertTrue( ( (Boolean) pR.getData()[1]).equals(new Boolean(false)));
167 assertTrue( ( (Integer) pR.getData()[2]).equals(new Integer(11)));
168 }
169
170 /**
171 A serialization tests of a Session creation.
172 */
173
174 public void testCreateTSES() {
175 mR = new mobile.protocol.Request();
176 mR.code = CREATE_TOPIC_SESSION;
177 mR.id = 1;
178 Object data[] = new Object[3];
179 data[0] = new Integer(1234);
180 data[1] = new Boolean(false);
181 data[2] = new Integer(11);
182 mR.setData(data);
183 byte[] msg = mR.serialize();
184 pR = new proxy.protocol.Request(mR.code, 1, 1, 1, msg);
185 assertTrue( ( (Integer) pR.getData()[0]).equals(new Integer(1234)));
186 assertTrue( ( (Boolean) pR.getData()[1]).equals(new Boolean(false)));
187 assertTrue( ( (Integer) pR.getData()[2]).equals(new Integer(11)));
188 }
189
190 /**
191 A serialization tests of a Producer creation.
192 */
193
194 public void testCreateQueueSen() {
195 mR = new mobile.protocol.Request();
196 mR.code = CREATE_QUEUE_SENDER;
197 mR.id = 1;
198 Object data[] = new Object[2];
199 data[0] = new Integer(1234);
200 data[1] = new Integer(11);
201 mR.setData(data);
202 byte[] msg = mR.serialize();
203 pR = new proxy.protocol.Request(mR.code, 1, 1, 1, msg);
204 assertTrue( ( (Integer) pR.getData()[0]).equals(new Integer(1234)));
205 assertTrue( ( (Integer) pR.getData()[1]).equals(new Integer(11)));
206 }
207 /**
208 A serialization tests of a Producer creation.
209 */
210
211 public void testCreateTopicRec() {
212 mR = new mobile.protocol.Request();
213 mR.code = CREATE_QUEUE_RECEIVER;
214 mR.id = 1;
215 Object data[] = new Object[2];
216 data[0] = new Integer(1234);
217 data[1] = new Integer(11);
218 mR.setData(data);
219 byte[] msg = mR.serialize();
220 pR = new proxy.protocol.Request(mR.code, 1, 1, 1, msg);
221 assertTrue( ( (Integer) pR.getData()[0]).equals(new Integer(1234)));
222 assertTrue( ( (Integer) pR.getData()[1]).equals(new Integer(11)));
223 }
224
225 /**
226 A serialization tests of Message sending.
227 */
228
229 public void testSendBytesMessage() {
230 mR = new mobile.protocol.Request();
231 mR.code = SEND_BYTES_MESSAGE;
232 mR.id = 1;
233 Object data[] = new Object[14];
234 data[0] = new Integer(1234);
235 data[1] = new Integer(1235);
236 data[2] = new Integer(1236);
237 data[3] = new byte[100];
238 data[4] = new String("JMSMessageId");
239 data[5] = new Long(1234567890);
240 data[6] = new String("JMSCorrelation");
241 data[7] = new Integer(1237);
242 data[8] = new Integer(1238);
243 data[9] = new Integer(1239);
244 data[10] = new Boolean(true);
245 data[11] = new String("JMSType");
246 data[12] = new Long(1234567890);
247 data[13] = new Integer(1230);
248 mR.setData(data);
249 byte[] msg = mR.serialize();
250 pR = new proxy.protocol.Request(mR.code, 1, 1, 1, msg);
251 assertTrue( ( (Integer) pR.getData()[0]).equals(new Integer(1234)));
252 assertTrue( ( (Integer) pR.getData()[1]).equals(new Integer(1235)));
253 assertTrue( ( (Integer) pR.getData()[2]).equals(new Integer(1236)));
254 assertTrue( ( (String) pR.getData()[4]).equals(new String("JMSMessageId")));
255 assertTrue( ( (Long) pR.getData()[5]).equals(new Long(1234567890)));
256 assertTrue( ( (String) pR.getData()[6]).equals(new String("JMSCorrelation")));
257 assertTrue( ( (Integer) pR.getData()[7]).equals(new Integer(1237)));
258 assertTrue( ( (Integer) pR.getData()[8]).equals(new Integer(1238)));
259 assertTrue( ( (Integer) pR.getData()[9]).equals(new Integer(1239)));
260 assertTrue( ( (Boolean) pR.getData()[10]).equals(new Boolean(true)));
261 assertTrue( ( (String) pR.getData()[11]).equals(new String("JMSType")));
262 assertTrue( ( (Long) pR.getData()[12]).equals(new Long(1234567890)));
263 assertTrue( ( (Integer) pR.getData()[13]).equals(new Integer(1230)));
264 }
265
266 /**
267 A serialization tests of Message sending.
268 */
269
270 public void testSendTextMessage() {
271 mR = new mobile.protocol.Request();
272 mR.code = SEND_TEXT_MESSAGE;
273 mR.id = 1;
274 Object data[] = new Object[14];
275 data[0] = new Integer(1234);
276 data[1] = new Integer(1235);
277 data[2] = new Integer(1236);
278 data[3] = new String("message");
279 data[4] = new String("JMSMessageId");
280 data[5] = new Long(1234567890);
281 data[6] = new String("JMSCorrelation");
282 data[7] = new Integer(1237);
283 data[8] = new Integer(1238);
284 data[9] = new Integer(1239);
285 data[10] = new Boolean(true);
286 data[11] = new String("JMSType");
287 data[12] = new Long(1234567890);
288 data[13] = new Integer(1230);
289 mR.setData(data);
290 byte[] msg = mR.serialize();
291 pR = new proxy.protocol.Request(mR.code, 1, 1, 1, msg);
292 assertTrue( ( (Integer) pR.getData()[0]).equals(new Integer(1234)));
293 assertTrue( ( (Integer) pR.getData()[1]).equals(new Integer(1235)));
294 assertTrue( ( (Integer) pR.getData()[2]).equals(new Integer(1236)));
295 assertTrue( ( (String) pR.getData()[3]).equals(new String("message")));
296 assertTrue( ( (String) pR.getData()[4]).equals(new String("JMSMessageId")));
297 assertTrue( ( (Long) pR.getData()[5]).equals(new Long(1234567890)));
298 assertTrue( ( (String) pR.getData()[6]).equals(new String("JMSCorrelation")));
299 assertTrue( ( (Integer) pR.getData()[7]).equals(new Integer(1237)));
300 assertTrue( ( (Integer) pR.getData()[8]).equals(new Integer(1238)));
301 assertTrue( ( (Integer) pR.getData()[9]).equals(new Integer(1239)));
302 assertTrue( ( (Boolean) pR.getData()[10]).equals(new Boolean(true)));
303 assertTrue( ( (String) pR.getData()[11]).equals(new String("JMSType")));
304 assertTrue( ( (Long) pR.getData()[12]).equals(new Long(1234567890)));
305 assertTrue( ( (Integer) pR.getData()[13]).equals(new Integer(1230)));
306 }
307
308 public void testSendNullBytesMessage() {
309 mR = new mobile.protocol.Request();
310 mR.code = SEND_BYTES_MESSAGE;
311 mR.id = 1;
312 Object data[] = new Object[14];
313 data[0] = new Integer(1234);
314 data[1] = new Integer(1235);
315 data[2] = new Integer(1236);
316 data[3] = new byte[100];
317 data[4] = null;
318 data[5] = new Long(1234567890);
319 data[6] = null;
320 data[7] = new Integer(1237);
321 data[8] = new Integer(1238);
322 data[9] = new Integer(1239);
323 data[10] = new Boolean(true);
324 data[11] = null;
325 data[12] = new Long(1234567890);
326 data[13] = new Integer(1230);
327 mR.setData(data);
328 byte[] msg = mR.serialize();
329 pR = new proxy.protocol.Request(mR.code, 1, 1, 1, msg);
330 assertTrue( ( (Integer) pR.getData()[0]).equals(new Integer(1234)));
331 assertTrue( ( (Integer) pR.getData()[1]).equals(new Integer(1235)));
332 assertTrue( ( (Integer) pR.getData()[2]).equals(new Integer(1236)));
333 // assertTrue( ( (String) pR.getData()[4]).equals(new String("JMSMessageId")));
334 assertTrue( ( (Long) pR.getData()[5]).equals(new Long(1234567890)));
335 // assertTrue( ( (String) pR.getData()[6]).equals(new String("JMSCorrelation")));
336 assertTrue( ( (Integer) pR.getData()[7]).equals(new Integer(1237)));
337 assertTrue( ( (Integer) pR.getData()[8]).equals(new Integer(1238)));
338 assertTrue( ( (Integer) pR.getData()[9]).equals(new Integer(1239)));
339 assertTrue( ( (Boolean) pR.getData()[10]).equals(new Boolean(true)));
340 // assertTrue( ( (String) pR.getData()[11]).equals(new String("JMSType")));
341 assertTrue( ( (Long) pR.getData()[12]).equals(new Long(1234567890)));
342 assertTrue( ( (Integer) pR.getData()[13]).equals(new Integer(1230)));
343 }
344
345 /**
346 A serialization tests of Message sending.
347 */
348
349 public void testSendNullTextMessage() {
350 mR = new mobile.protocol.Request();
351 mR.code = SEND_TEXT_MESSAGE;
352 mR.id = 1;
353 Object data[] = new Object[14];
354 data[0] = new Integer(1234);
355 data[1] = new Integer(1235);
356 data[2] = new Integer(1236);
357 data[3] = null;
358 data[4] =null;
359 data[5] = new Long(1234567890);
360 data[6] = null;
361 data[7] = new Integer(1237);
362 data[8] = new Integer(1238);
363 data[9] = new Integer(1239);
364 data[10] = new Boolean(true);
365 // data[11] = null;
366 data[12] = new Long(1234567890);
367 data[13] = new Integer(1230);
368 mR.setData(data);
369 byte[] msg = mR.serialize();
370 pR = new proxy.protocol.Request(mR.code, 1, 1, 1, msg);
371 assertTrue( ( (Integer) pR.getData()[0]).equals(new Integer(1234)));
372 assertTrue( ( (Integer) pR.getData()[1]).equals(new Integer(1235)));
373 assertTrue( ( (Integer) pR.getData()[2]).equals(new Integer(1236)));
374 // assertTrue( ( (String) pR.getData()[3]).equals(new String("message")));
375 // assertTrue( ( (String) pR.getData()[4]).equals(new String("JMSMessageId")));
376 assertTrue( ( (Long) pR.getData()[5]).equals(new Long(1234567890)));
377 // assertTrue( ( (String) pR.getData()[6]).equals(new String("JMSCorrelation")));
378 assertTrue( ( (Integer) pR.getData()[7]).equals(new Integer(1237)));
379 assertTrue( ( (Integer) pR.getData()[8]).equals(new Integer(1238)));
380 assertTrue( ( (Integer) pR.getData()[9]).equals(new Integer(1239)));
381 assertTrue( ( (Boolean) pR.getData()[10]).equals(new Boolean(true)));
382 // assertTrue( ( (String) pR.getData()[11]).equals(new String("JMSType")));
383 assertTrue( ( (Long) pR.getData()[12]).equals(new Long(1234567890)));
384 assertTrue( ( (Integer) pR.getData()[13]).equals(new Integer(1230)));
385 }
386
387
388
389
390 /**
391 A serialization tests of Message receipt.
392 */
393
394 public void testReceiveMessageQ() {
395 mR = new mobile.protocol.Request();
396 mR.code = RECEIVE_MESSAGE_FROM_QUEUE;
397 mR.id = 1;
398 Object data[] = new Object[3];
399 data[0] = new Integer(1234);
400 data[1] = new Integer(11);
401 data[2] = new Integer(12);
402 mR.setData(data);
403 byte[] msg = mR.serialize();
404 pR = new proxy.protocol.Request(mR.code, 1, 1, 1, msg);
405 assertTrue( ( (Integer) pR.getData()[0]).equals(new Integer(1234)));
406 assertTrue( ( (Integer) pR.getData()[1]).equals(new Integer(11)));
407 assertTrue( ( (Integer) pR.getData()[2]).equals(new Integer(12)));
408 }
409 public void testReceiveMessageT() {
410 mR = new mobile.protocol.Request();
411 mR.code = RECEIVE_MESSAGE_FROM_TOPIC;
412 mR.id = 1;
413 Object data[] = new Object[3];
414 data[0] = new Integer(1234);
415 data[1] = new Integer(11);
416 data[2] = new Integer(12);
417 mR.setData(data);
418 byte[] msg = mR.serialize();
419 pR = new proxy.protocol.Request(mR.code, 1, 1, 1, msg);
420 assertTrue( ( (Integer) pR.getData()[0]).equals(new Integer(1234)));
421 assertTrue( ( (Integer) pR.getData()[1]).equals(new Integer(11)));
422 assertTrue( ( (Integer) pR.getData()[2]).equals(new Integer(12)));
423 }
424
425
426
427 }