DefaultMessageConvertor implements MessageConverter { @Override public byte[] convert(Exchange arg0) { Object msg = arg0.getIn().getBody(); if (msg instanceof String) { return ((String)msg).getBytes(); } else if (msg instanceof byte[]) { return (byte[])msg; } else { return msg.toString().getBytes(); } }  @Override byte[] convert(Exchange arg0);  }
@Test public void byteArrayNoop() { Message msg = new DefaultMessage(); byte[] bytes = new byte[14]; msg.setBody(bytes); when(exg.getIn()).thenReturn(msg); assertEquals(bytes, new DefaultMessageConvertor().convert(exg)); }
@Test public void convertString() { Message msg = new DefaultMessage(); msg.setBody("mymsg"); when(exg.getIn()).thenReturn(msg); assertArrayEquals("mymsg".getBytes(), new DefaultMessageConvertor().convert(exg)); }
@Test public void objectToString() { Object obj = new Object(); Message msg = new DefaultMessage(); msg.setBody(obj); when(exg.getIn()).thenReturn(msg); assertArrayEquals(obj.toString().getBytes(), new DefaultMessageConvertor().convert(exg)); }