Fix: RabbitMQ Consumer could not receive handleCancelOk callback(#13334) (#759)

AYue-94 · web-flow · commit 7f9287fcb189 · 2025-06-21T12:20:28.000+08:00
Signed-off-by: ayue &lt;ericyu0421@163.com&gt;
diff --git 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
@@ -50,7 +50,7 @@ public void handleConsumeOk(final String consumerTag) {
 
     @Override
     public void handleCancelOk(final String consumerTag) {
-        this.delegate.handleRecoverOk(consumerTag);
+        this.delegate.handleCancelOk(consumerTag);
     }
 
     @Override

Original file line number	Diff line number	Diff line change
`@@ -50,7 +50,7 @@ public void handleConsumeOk(final String consumerTag) {`
`50`	`50`
`51`	`51`	`@Override`
`52`	`52`	`public void handleCancelOk(final String consumerTag) {`
`53`		`- this.delegate.handleRecoverOk(consumerTag);`
	`53`	`+ this.delegate.handleCancelOk(consumerTag);`
`54`	`54`	`}`
`55`	`55`
`56`	`56`	`@Override`