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>
