@@ -266,4 +266,38 @@ public void testFloat64Array() {
266266 rawMessage .setFloat64Array ("data" , new double [] { 1 , 2 , 3 , 4 , 5 });
267267 checkSerializeAndDeserialize (rawMessage );
268268 }
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+ }
269303}
0 commit comments