@@ -266,4 +266,38 @@ public void testFloat64Array() {
266
266
rawMessage .setFloat64Array ("data" , new double [] { 1 , 2 , 3 , 4 , 5 });
267
267
checkSerializeAndDeserialize (rawMessage );
268
268
}
269
+
270
+ @ Test
271
+ public void testChannelBufferFixedSizeWithInitialization () {
272
+ topicDefinitionResourceProvider .add ("foo/foo" , "uint8[5] data" );
273
+ ChannelBuffer buffer = MessageBuffers .dynamicBuffer ();
274
+ buffer .writeBytes (new byte [] { 1 , 2 , 3 , 4 , 5 });
275
+ RawMessage rawMessage = messageFactory .newFromType ("foo/foo" );
276
+ rawMessage .setChannelBuffer ("data" , buffer );
277
+ checkSerializeAndDeserialize (rawMessage );
278
+ }
279
+
280
+ @ Test
281
+ public void testChannelBufferFixedSizeNoInitialization () {
282
+ topicDefinitionResourceProvider .add ("foo/foo" , "uint8[5] data" );
283
+ ChannelBuffer buffer = MessageBuffers .dynamicBuffer ();
284
+ RawMessage rawMessage = messageFactory .newFromType ("foo/foo" );
285
+ rawMessage .setChannelBuffer ("data" , buffer );
286
+ checkSerializeAndDeserialize (rawMessage );
287
+ }
288
+
289
+ @ Test
290
+ public void testInt32FixedSizeArrayWithInitialization () {
291
+ topicDefinitionResourceProvider .add ("foo/foo" , "int32[5] data" );
292
+ RawMessage rawMessage = messageFactory .newFromType ("foo/foo" );
293
+ rawMessage .setInt32Array ("data" , new int [] { 1 , 2 , 3 , 4 , 5 });
294
+ checkSerializeAndDeserialize (rawMessage );
295
+ }
296
+
297
+ @ Test
298
+ public void testInt32FixedSizeArrayNoInitialization () {
299
+ topicDefinitionResourceProvider .add ("foo/foo" , "int32[5] data" );
300
+ RawMessage rawMessage = messageFactory .newFromType ("foo/foo" );
301
+ checkSerializeAndDeserialize (rawMessage );
302
+ }
269
303
}
0 commit comments