@Test
	public void testBytesPassThru() {
		byte[] payload = "foo".getBytes();
		Message<byte[]> message = MessageBuilder.withPayload(payload).build();
		MessageValues converted = messageBus.serializePayloadIfNecessary(message
		);
		assertSame(payload, converted.getPayload());
		Message<?> convertedMessage = converted.toMessage();
		assertSame(payload, convertedMessage.getPayload());
		assertEquals(MimeTypeUtils.APPLICATION_OCTET_STREAM,
				contentTypeResolver.resolve(convertedMessage.getHeaders()));
		MessageValues reconstructed = messageBus.deserializePayloadIfNecessary(convertedMessage);
		payload = (byte[]) reconstructed.getPayload();
		assertSame(converted.getPayload(), payload);
		assertNull(reconstructed.get(XdHeaders.XD_ORIGINAL_CONTENT_TYPE));
	}
@author Gary Russell
@author David Turanski
spring-xd-dirt/src/test/java/org/springframework/xd/dirt/integration/bus/MessageBusSupportTests.java