JmsTransportUtils { public static String getReplyToName(URI uri) { return getStringParameter(REPLY_TO_NAME_PATTERN, uri); } private  JmsTransportUtils(); static String headerToJmsProperty(String headerName); static String jmsPropertyToHeader(String propertyName); static URI toUri(Destination destination); static String getDestinationName(URI uri); static void addHeader(Message message, String name, String value); static Iterator<String> getHeaderNames(Message message); static Iterator<String> getHeaders(Message message, String name); static int getDeliveryMode(URI uri); static int getMessageType(URI uri); static long getTimeToLive(URI uri); static int getPriority(URI uri); static String getReplyToName(URI uri);  }
@Test public void getReplyToName() throws Exception { URI uri = new URI("jms:RequestQueue?replyToName=RESP_QUEUE"); String replyToName = JmsTransportUtils.getReplyToName(uri); assertEquals("Invalid replyToName", "RESP_QUEUE", replyToName); uri = new URI("jms:RequestQueue?priority=5"); replyToName = JmsTransportUtils.getReplyToName(uri); Assert.assertNull("Invalid replyToName", replyToName); }