Skip to content

Commit acf2d6b

Browse files
URL passed to connectionFactory should not be encoded
1 parent 5b251d1 commit acf2d6b

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

selenium/amqp10-roundtriptest/src/main/java/com/rabbitmq/amqp1_0/RoundTripTest.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -46,11 +46,13 @@ public static void main(String args[]) throws Exception {
4646
connectionParams.add("transport.keyAlias=client-rabbitmq-tls");
4747
}
4848
if (!connectionParams.isEmpty()) {
49-
String uri2 = uri + "?" + java.net.URLEncoder.encode(String.join("&", connectionParams));
50-
System.out.println("Using AMQP URI " + uri2);
49+
uri = uri + "?" + String.join("&", connectionParams);
50+
System.out.println("Using AMQP URI " + uri);
5151
}
5252
}
5353

54+
assertNotNull(uri);
55+
5456
Hashtable<Object, Object> env = new Hashtable<>();
5557
env.put(Context.INITIAL_CONTEXT_FACTORY, "org.apache.qpid.jms.jndi.JmsInitialContextFactory");
5658
env.put("connectionfactory.myFactoryLookup", uri);
@@ -59,8 +61,6 @@ public static void main(String args[]) throws Exception {
5961
env.put("jms.requestTimeout", 5);
6062
javax.naming.Context context = new javax.naming.InitialContext(env);
6163

62-
assertNotNull(uri);
63-
6464
ConnectionFactory factory = (ConnectionFactory) context.lookup("myFactoryLookup");
6565
Destination queue = (Destination) context.lookup("myQueueLookup");
6666

0 commit comments

Comments
 (0)