Last port to try-with-resource

This commit is contained in:
Thomas Stokes
2024-03-21 13:00:40 +01:00
parent b5e066df32
commit 1cdac2e549
@@ -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));