(airavata) branch master updated: update deprecated QueueingConsumer to DefaultConsumer and bump amqp-client to v5 (#539)

[yasith]

This is an automated email from the ASF dual-hosted git repository.

yasith pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airavata.git


The following commit(s) were added to refs/heads/master by this push:
     new b43124c9b0 update deprecated QueueingConsumer to DefaultConsumer and 
bump amqp-client to v5 (#539)
b43124c9b0 is described below

commit b43124c9b060eeee84f786e0ba94f81c6b02209a
Author: Yasith Jayawardana <yasit...@icloud.com>
AuthorDate: Wed Jul 2 14:57:25 2025 -0500

    update deprecated QueueingConsumer to DefaultConsumer and bump amqp-client 
to v5 (#539)
---
 .../org/apache/airavata/messaging/core/impl/ExperimentConsumer.java   | 4 ++--
 .../java/org/apache/airavata/messaging/core/impl/MessageConsumer.java | 2 +-
 .../java/org/apache/airavata/messaging/core/impl/ProcessConsumer.java | 4 ++--
 pom.xml                                                               | 2 +-
 4 files changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/airavata-api/src/main/java/org/apache/airavata/messaging/core/impl/ExperimentConsumer.java
 
b/airavata-api/src/main/java/org/apache/airavata/messaging/core/impl/ExperimentConsumer.java
index 78329693c1..aa67f7728a 100644
--- 
a/airavata-api/src/main/java/org/apache/airavata/messaging/core/impl/ExperimentConsumer.java
+++ 
b/airavata-api/src/main/java/org/apache/airavata/messaging/core/impl/ExperimentConsumer.java
@@ -22,8 +22,8 @@ package org.apache.airavata.messaging.core.impl;
 import com.rabbitmq.client.AMQP;
 import com.rabbitmq.client.Channel;
 import com.rabbitmq.client.Connection;
+import com.rabbitmq.client.DefaultConsumer;
 import com.rabbitmq.client.Envelope;
-import com.rabbitmq.client.QueueingConsumer;
 import java.io.IOException;
 import org.apache.airavata.common.utils.AiravataUtils;
 import org.apache.airavata.common.utils.ServerSettings;
@@ -36,7 +36,7 @@ import org.apache.thrift.TException;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-public class ExperimentConsumer extends QueueingConsumer {
+public class ExperimentConsumer extends DefaultConsumer {
     private static final Logger log = 
LoggerFactory.getLogger(ExperimentConsumer.class);
 
     private MessageHandler handler;
diff --git 
a/airavata-api/src/main/java/org/apache/airavata/messaging/core/impl/MessageConsumer.java
 
b/airavata-api/src/main/java/org/apache/airavata/messaging/core/impl/MessageConsumer.java
index 4c0325eef8..c99c4c7e4d 100644
--- 
a/airavata-api/src/main/java/org/apache/airavata/messaging/core/impl/MessageConsumer.java
+++ 
b/airavata-api/src/main/java/org/apache/airavata/messaging/core/impl/MessageConsumer.java
@@ -31,7 +31,7 @@ import org.apache.log4j.Logger;
 import org.apache.thrift.TBase;
 import org.apache.thrift.TException;
 
-public class MessageConsumer extends QueueingConsumer {
+public class MessageConsumer extends DefaultConsumer {
 
     private static final Logger logger = 
LogManager.getLogger(MessageConsumer.class);
 
diff --git 
a/airavata-api/src/main/java/org/apache/airavata/messaging/core/impl/ProcessConsumer.java
 
b/airavata-api/src/main/java/org/apache/airavata/messaging/core/impl/ProcessConsumer.java
index c56ac4212a..1a353ef2c1 100644
--- 
a/airavata-api/src/main/java/org/apache/airavata/messaging/core/impl/ProcessConsumer.java
+++ 
b/airavata-api/src/main/java/org/apache/airavata/messaging/core/impl/ProcessConsumer.java
@@ -22,8 +22,8 @@ package org.apache.airavata.messaging.core.impl;
 import com.rabbitmq.client.AMQP;
 import com.rabbitmq.client.Channel;
 import com.rabbitmq.client.Connection;
+import com.rabbitmq.client.DefaultConsumer;
 import com.rabbitmq.client.Envelope;
-import com.rabbitmq.client.QueueingConsumer;
 import java.io.IOException;
 import org.apache.airavata.common.utils.AiravataUtils;
 import org.apache.airavata.common.utils.ServerSettings;
@@ -39,7 +39,7 @@ import org.apache.thrift.TException;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-public class ProcessConsumer extends QueueingConsumer {
+public class ProcessConsumer extends DefaultConsumer {
     private static final Logger log = 
LoggerFactory.getLogger(ProcessConsumer.class);
 
     private MessageHandler handler;
diff --git a/pom.xml b/pom.xml
index b60915dfe3..f49d031c85 100644
--- a/pom.xml
+++ b/pom.xml
@@ -392,7 +392,7 @@ under the License.
             <dependency>
                 <groupId>com.rabbitmq</groupId>
                 <artifactId>amqp-client</artifactId>
-                <version>3.5.1</version>
+                <version>5.25.0</version>
             </dependency>
             <dependency>
                 <groupId>io.prometheus</groupId>