Search before asking
Apache SkyWalking Component
Java Agent (apache/skywalking-java)
What happened
- skywalking-java 9.4.0
- use rabbitmq consumer
consumer could not receive handleCancelOk callback.
public class MyConsumer implements Consumer {
// ...
@Override
public void handleCancelOk(final String consumerTag) {
System.out.println("handleCancelOk");
}
}
What you expected to happen
when use skywalking-java agent, rabbitmq consumer could receive handleCancelOk callback.
How to reproduce
public class MyConsumer implements Consumer {
// ...
@Override
public void handleCancelOk(final String consumerTag) {
System.out.println("handleCancelOk");
}
}
Anything else
TracerConsumer call wrong method, i will try to fix it.
public class TracerConsumer implements Consumer {
// ...
@Override
public void handleCancelOk(final String consumerTag) {
this.delegate.handleRecoverOk(consumerTag); // call wrong method
}
Are you willing to submit a pull request to fix on your own?
Code of Conduct
Search before asking
Apache SkyWalking Component
Java Agent (apache/skywalking-java)
What happened
consumer could not receive handleCancelOk callback.
What you expected to happen
when use skywalking-java agent, rabbitmq consumer could receive handleCancelOk callback.
How to reproduce
Anything else
TracerConsumer call wrong method, i will try to fix it.
Are you willing to submit a pull request to fix on your own?
Code of Conduct