aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAnton Tananaev <anton.tananaev@gmail.com>2023-08-07 13:53:43 -0700
committerGitHub <noreply@github.com>2023-08-07 13:53:43 -0700
commit5a9313a13dcf9a7c47f95086e56def99297405f9 (patch)
tree1ee144e1f60b6064b5e301cba3328ceb7920ad28
parent36d319a81dc3d2c12222cce012c1a1a307a865b2 (diff)
parent78ead877bac40cd88fc342e966741b42568de5a5 (diff)
downloadtrackermap-server-5a9313a13dcf9a7c47f95086e56def99297405f9.tar.gz
trackermap-server-5a9313a13dcf9a7c47f95086e56def99297405f9.tar.bz2
trackermap-server-5a9313a13dcf9a7c47f95086e56def99297405f9.zip
Merge pull request #5153 from RodolfoSilva/hotfix/auto-close-connection
fix: AMQP auto close connection
-rw-r--r--src/main/java/org/traccar/forward/AmqpClient.java3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/main/java/org/traccar/forward/AmqpClient.java b/src/main/java/org/traccar/forward/AmqpClient.java
index 302aa664c..361cfffee 100644
--- a/src/main/java/org/traccar/forward/AmqpClient.java
+++ b/src/main/java/org/traccar/forward/AmqpClient.java
@@ -43,7 +43,8 @@ public class AmqpClient {
throw new RuntimeException("Error while setting URI for RabbitMQ connection factory", e);
}
- try (Connection connection = factory.newConnection()) {
+ try {
+ Connection connection = factory.newConnection();
channel = connection.createChannel();
channel.exchangeDeclare(exchange, BuiltinExchangeType.TOPIC, true);
} catch (IOException | TimeoutException e) {