Skip to content

Commit 0a4b6cb

Browse files
Read RABBITMQ_CERTS env var only when tls is in use
1 parent b0f1fbb commit 0a4b6cb

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

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

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,10 +31,11 @@ public static void main(String args[]) throws Exception {
3131
String password = args.length > 1 ? args[1] : getEnv("RABBITMQ_AMQP_PASSWORD", "guest");
3232

3333
boolean usemtls = Boolean.parseBoolean(getEnv("AMQP_USE_MTLS", "false"));
34-
String certsLocation = getEnv("RABBITMQ_CERTS");
34+
3535

3636
if ("amqps".equals(scheme)) {
3737
List<String> connectionParams = new ArrayList<String>();
38+
String certsLocation = getEnv("RABBITMQ_CERTS");
3839

3940
connectionParams.add("transport.trustStoreLocation=" + certsLocation + "/truststore.jks");
4041
connectionParams.add("transport.trustStorePassword=foobar");
@@ -84,6 +85,8 @@ public static void main(String args[]) throws Exception {
8485
TextMessage receivedMessage = (TextMessage) messageConsumer.receive(2000L);
8586

8687
assertEquals(message.getText(), receivedMessage.getText());
88+
89+
Thread.sleep(30000);
8790
}
8891
}
8992
private static Connection createConnection(ConnectionFactory factory,

0 commit comments

Comments
 (0)