This is an automated email from the ASF dual-hosted git repository.
wusheng pushed a change to branch fix
in repository https://gitbox.apache.org/repos/asf/skywalking-java.git
from 0b92eced4d Rename system env name from
`sw_plugin_kafka_producer_config` to `SW_PLUGIN_KAFKA_PRODUCER_CONFIG`
add bbb177a893 Support tracing for async producing, batch sync consuming,
and batch async consuming in rocketMQ-client-java-5.x-plugin (#665)
add eebc4512ec Convert the Redisson lock span into an async span (#667)
add f9dbe89741 Merge branch 'main' into fix
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 4 +-
.../v3/RedissonHighLevelLockInterceptor.java | 14 ++
.../redisson/v3/RedissonLockInterceptor.java | 14 ++
.../client/java/v5/MessageListenerInterceptor.java | 4 +-
...eptor.java => MessageSendAsyncInterceptor.java} | 83 ++++---
.../client/java/v5/MessageSendInterceptor.java | 22 +-
.../java/v5/RocketMqClientJavaPluginConfig.java} | 18 +-
.../v5/SimpleConsumerImplAsyncInterceptor.java | 126 +++++++++++
...tor.java => SimpleConsumerImplInterceptor.java} | 71 +++---
....java => ProducerImplAsyncInstrumentation.java} | 10 +-
.../SimpleConsumerImplAsyncInstrumentation.java} | 26 ++-
.../define/SimpleConsumerImplInstrumentation.java} | 26 ++-
.../src/main/resources/skywalking-plugin.def | 3 +
apm-sniffer/config/agent.config | 4 +
.../service-agent/java-agent/configurations.md | 2 +
.../rocketmq-5-grpc-scenario/bin/startup.sh | 2 +-
.../config/expectedData.yaml | 152 +++++++++++--
.../client/java/controller/CaseController.java | 148 ++++---------
.../client/java/controller/MessageService.java | 240 +++++++++++++++++++++
.../client/java/controller/ProducerSingleton.java | 61 ++++++
.../rocketmq-5-grpc-scenario/support-version.list | 1 +
21 files changed, 803 insertions(+), 228 deletions(-)
copy
apm-sniffer/apm-sdk-plugin/rocketMQ-client-java-5.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/rocketMQ/client/java/v5/{MessageSendInterceptor.java
=> MessageSendAsyncInterceptor.java} (59%)
copy
apm-sniffer/apm-sdk-plugin/{solrj-7.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/solrj/SolrJPluginConfig.java
=>
rocketMQ-client-java-5.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/rocketMQ/client/java/v5/RocketMqClientJavaPluginConfig.java}
(62%)
create mode 100644
apm-sniffer/apm-sdk-plugin/rocketMQ-client-java-5.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/rocketMQ/client/java/v5/SimpleConsumerImplAsyncInterceptor.java
copy
apm-sniffer/apm-sdk-plugin/rocketMQ-client-java-5.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/rocketMQ/client/java/v5/{MessageListenerInterceptor.java
=> SimpleConsumerImplInterceptor.java} (55%)
copy
apm-sniffer/apm-sdk-plugin/rocketMQ-client-java-5.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/rocketMQ/client/java/v5/define/{ProducerImplInstrumentation.java
=> ProducerImplAsyncInstrumentation.java} (83%)
copy
apm-sniffer/apm-sdk-plugin/{undertow-plugins/undertow-2.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/undertow/v2x/define/RequestDispatcherImplInstrumentation.java
=>
rocketMQ-client-java-5.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/rocketMQ/client/java/v5/define/SimpleConsumerImplAsyncInstrumentation.java}
(79%)
copy
apm-sniffer/apm-sdk-plugin/{undertow-plugins/undertow-2.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/undertow/v2x/define/RequestDispatcherImplInstrumentation.java
=>
rocketMQ-client-java-5.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/rocketMQ/client/java/v5/define/SimpleConsumerImplInstrumentation.java}
(79%)
create mode 100644
test/plugin/scenarios/rocketmq-5-grpc-scenario/src/main/java/test/apache/skywalking/apm/testcase/rocketmq/client/java/controller/MessageService.java
create mode 100644
test/plugin/scenarios/rocketmq-5-grpc-scenario/src/main/java/test/apache/skywalking/apm/testcase/rocketmq/client/java/controller/ProducerSingleton.java
