Skip to content

Commit

Permalink
[Proxy] Log warning when opening connection to broker fails (apache#1…
Browse files Browse the repository at this point in the history
…4710)

(cherry picked from commit 13c4562)
(cherry picked from commit 30783d0)
  • Loading branch information
lhotari committed Mar 22, 2022
1 parent 456b1aa commit f1f6121
Showing 1 changed file with 2 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -148,6 +148,8 @@ protected void initChannel(SocketChannel ch) {
f.addListener(future -> {
if (!future.isSuccess()) {
// Close the connection if the connection attempt has failed.
log.warn("[{}] Establishing connection to {} ({}) failed. Closing inbound channel.", inboundChannel,
targetBrokerAddress, targetBrokerUrl, future.cause());
inboundChannel.close();
return;
}
Expand Down

0 comments on commit f1f6121

Please sign in to comment.