From ec2559906880ba1369a15b92b00c3d5482166a00 Mon Sep 17 00:00:00 2001 From: Benoit Devos Date: Thu, 25 Oct 2018 17:25:01 +0200 Subject: [PATCH 1/2] onConnectionEstablished(): log only main broker URI part. --- .../src/main/java/org/apache/qpid/jms/JmsConnection.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnection.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnection.java index cf78fe08e..65cc6812e 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnection.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnection.java @@ -1321,7 +1321,8 @@ public void run() { @Override public void onConnectionEstablished(final URI remoteURI) { - LOG.info("Connection {} connected to remote Broker: {}", connectionInfo.getId(), remoteURI); + LOG.info("Connection {} connected to remote Broker: {}://{}:{}", + connectionInfo.getId(), remoteURI.getScheme(), remoteURI.getHost(), remoteURI.getPort()); setMessageFactory(provider.getMessageFactory()); connectionInfo.setConnectedURI(provider.getRemoteURI()); From fbdbcd192212e97c72843a69ea7d68d4c0cacbae Mon Sep 17 00:00:00 2001 From: Benoit Devos Date: Thu, 25 Oct 2018 17:25:01 +0200 Subject: [PATCH 2/2] QPIDJMS-423 onConnectionEstablished(): log only main broker URI part. --- .../src/main/java/org/apache/qpid/jms/JmsConnection.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnection.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnection.java index cf78fe08e..65cc6812e 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnection.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsConnection.java @@ -1321,7 +1321,8 @@ public void run() { @Override public void onConnectionEstablished(final URI remoteURI) { - LOG.info("Connection {} connected to remote Broker: {}", connectionInfo.getId(), remoteURI); + LOG.info("Connection {} connected to remote Broker: {}://{}:{}", + connectionInfo.getId(), remoteURI.getScheme(), remoteURI.getHost(), remoteURI.getPort()); setMessageFactory(provider.getMessageFactory()); connectionInfo.setConnectedURI(provider.getRemoteURI());