From 1cdac2e54954b1c0718f1ea721718f24b50e43a0 Mon Sep 17 00:00:00 2001 From: Thomas Stokes Date: Thu, 21 Mar 2024 13:00:40 +0100 Subject: [PATCH] Last port to try-with-resource --- .../com/sap/sse/replication/impl/ReplicationServiceImpl.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/java/com.sap.sse.replication/src/com/sap/sse/replication/impl/ReplicationServiceImpl.java b/java/com.sap.sse.replication/src/com/sap/sse/replication/impl/ReplicationServiceImpl.java index c7cee246be3..4be88897944 100755 --- a/java/com.sap.sse.replication/src/com/sap/sse/replication/impl/ReplicationServiceImpl.java +++ b/java/com.sap.sse.replication/src/com/sap/sse/replication/impl/ReplicationServiceImpl.java @@ -712,7 +712,10 @@ public class ReplicationServiceImpl implements ReplicationService, OperationsToM .redirectConnectionWithBearerToken(initialLoadURL, /* HTTP request method */ "POST", master.getBearerToken()); final InputStream is = (InputStream) initialLoadConnection.getContent(); final InputStreamReader queueNameReader = new InputStreamReader(is, HttpUrlConnectionHelper.getCharsetFromConnectionOrDefault(initialLoadConnection, "UTF-8")); - final String queueName = new BufferedReader(queueNameReader).readLine(); + final String queueName; + try (BufferedReader reader = new BufferedReader(queueNameReader)) { + queueName = reader.readLine(); + } queueNameReader.close(); final Channel channel = master.createChannel(); initialLoadChannels.put(master, new InitialLoadRequest(channel, replicables, queueName));