Merge pull request #7 from protegeproject/remove-channel-transacted

Remove channel transacted
protegeproject · Nov 14, 2024 · 4868a0c · 4868a0c
2 parents 4b03061 + 0a1743a
commit 4868a0c
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/pom.xml b/pom.xml
@@ -10,7 +10,7 @@
     </parent>
     <groupId>edu.stanford.protege</groupId>
     <artifactId>webprotege-ipc</artifactId>
-    <version>1.0.5</version>
+    <version>1.0.6</version>
     <name>webprotege-ipc</name>
     <description>Inter Process Communication framework</description>
     <properties>

diff --git a/src/main/java/edu/stanford/protege/webprotege/ipc/impl/RabbitMqConfiguration.java b/src/main/java/edu/stanford/protege/webprotege/ipc/impl/RabbitMqConfiguration.java
@@ -109,6 +109,7 @@ public SimpleMessageListenerContainer replyListenerContainer(ConnectionFactory c
         SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
         container.setConnectionFactory(connectionFactory);
         container.setQueues(replyQueue);
+        container.setChannelTransacted(false);
         container.setConcurrency("15-20");
         return container;
     }
@@ -125,6 +126,7 @@ public SimpleMessageListenerContainer messageListenerContainers() {
         SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
         container.setQueueNames(getCommandQueue());
         container.setConnectionFactory(connectionFactory);
+        container.setChannelTransacted(false);
         container.setMessageListener(rabbitMqCommandHandlerWrapper());
         container.setConcurrency("15-20");
         return container;
@@ -134,7 +136,7 @@ public SimpleMessageListenerContainer messageListenerContainers() {
     @ConditionalOnProperty(prefix = "webprotege.rabbitmq", name = "commands-subscribe", havingValue = "true", matchIfMissing = true)
     public void  createBindings() {
         try (Connection connection = connectionFactory.createConnection();
-             Channel channel = connection.createChannel(true)) {
+             Channel channel = connection.createChannel(false)) {
             channel.exchangeDeclare(COMMANDS_EXCHANGE, "direct", true);
             channel.queueDeclare(getCommandQueue(), true, false, false, null);
             channel.queueDeclare(getCommandResponseQueue(), true, false, false, null);