(skywalking-java) branch main updated: Fix: RabbitMQ Consumer could not receive handleCancelOk callback(#13334) (#759)

[wusheng]

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

wusheng pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/skywalking-java.git


The following commit(s) were added to refs/heads/main by this push:
     new 7f9287fcb1 Fix: RabbitMQ Consumer could not receive handleCancelOk 
callback(#13334) (#759)
7f9287fcb1 is described below

commit 7f9287fcb189048acd8d9ce8ab5687664ee150e0
Author: ayue <ericyu0...@163.com>
AuthorDate: Sat Jun 21 12:20:28 2025 +0800

    Fix: RabbitMQ Consumer could not receive handleCancelOk callback(#13334) 
(#759)
    
    Signed-off-by: ayue <ericyu0...@163.com>
---
 CHANGES.md                                                              | 1 +
 .../java/org/apache/skywalking/apm/plugin/rabbitmq/TracerConsumer.java  | 2 +-
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/CHANGES.md b/CHANGES.md
index eea1320db7..0a846a2630 100644
--- a/CHANGES.md
+++ b/CHANGES.md
@@ -13,6 +13,7 @@ Release Notes.
   initialized.
 * Fix retransform failure when enhancing both parent and child classes.
 * Add support for `dameng(DM)` JDBC url format in `URLParser`.
+* Fix RabbitMQ Consumer could not receive handleCancelOk callback.
 
 All issues and pull requests are 
[here](https://github.com/apache/skywalking/milestone/236?closed=1)
 
diff --git 
a/apm-sniffer/apm-sdk-plugin/rabbitmq-plugin/src/main/java/org/apache/skywalking/apm/plugin/rabbitmq/TracerConsumer.java
 
b/apm-sniffer/apm-sdk-plugin/rabbitmq-plugin/src/main/java/org/apache/skywalking/apm/plugin/rabbitmq/TracerConsumer.java
index bb6f134fca..c3ae14470e 100644
--- 
a/apm-sniffer/apm-sdk-plugin/rabbitmq-plugin/src/main/java/org/apache/skywalking/apm/plugin/rabbitmq/TracerConsumer.java
+++ 
b/apm-sniffer/apm-sdk-plugin/rabbitmq-plugin/src/main/java/org/apache/skywalking/apm/plugin/rabbitmq/TracerConsumer.java
@@ -50,7 +50,7 @@ public class TracerConsumer implements Consumer {
 
     @Override
     public void handleCancelOk(final String consumerTag) {
-        this.delegate.handleRecoverOk(consumerTag);
+        this.delegate.handleCancelOk(consumerTag);
     }
 
     @Override