@Test
public void getMessageType() throws Exception {

	URI uri = new URI("jms:RequestQueue?messageType=BYTESMESSAGE");
	int messageType = JmsTransportUtils.getMessageType(uri);
	assertEquals("Invalid messageType", JmsTransportConstants.BYTES_MESSAGE_TYPE, messageType);
	uri = new URI("jms:RequestQueue?messageType=TEXT_MESSAGE");
	messageType = JmsTransportUtils.getMessageType(uri);
	assertEquals("Invalid messageType", JmsTransportConstants.TEXT_MESSAGE_TYPE, messageType);
	uri = new URI("jms:RequestQueue?replyToName=RESP_QUEUE");
	messageType = JmsTransportUtils.getMessageType(uri);
	assertEquals("Invalid messageType", JmsTransportConstants.BYTES_MESSAGE_TYPE, messageType);
}