This commit is contained in:
Arjen Poutsma
2008-08-28 18:27:52 +00:00
parent 8b47edd23c
commit 56c9ce8d50
2 changed files with 10 additions and 1 deletions

View File

@@ -58,7 +58,7 @@ public abstract class JmsTransportUtils {
private static final Pattern PRIORITY_PATTERN = Pattern.compile("priority=(\\d)");
private static final Pattern REPLY_TO_NAME_PATTERN = Pattern.compile("replyToName=(\\w+)");
private static final Pattern REPLY_TO_NAME_PATTERN = Pattern.compile("replyToName=([^&]+)");
private JmsTransportUtils() {
}

View File

@@ -93,4 +93,13 @@ public class JmsTransportUtilsTest extends TestCase {
replyToName = JmsTransportUtils.getReplyToName(uri);
assertNull("Invalid replyToName", replyToName);
}
public void testJndi() throws Exception {
URI uri = new URI("jms:jms/REQUEST_QUEUE?replyToName=jms/REPLY_QUEUE");
String destination = JmsTransportUtils.getDestinationName(uri);
assertEquals("Invalid destination name", "jms/REQUEST_QUEUE", destination);
String replyTo = JmsTransportUtils.getReplyToName(uri);
assertEquals("Invalid reply to name", "jms/REPLY_QUEUE", replyTo);
}
}