This is an automated email from the ASF dual-hosted git repository.
wqliang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
from 472d598ae [ISSUE #3837]Change to private and add the transient
modifier[HttpCommand] (#3841)
new 7a859a46e [ISSUE #3934] Fix checkStyle error in RocketMQ connector
module
new 7be6d98d9 remove unused import
new c5522ee9d Merge pull request #3935 from xwm1992/checkstyle-fix
The 4160 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../sink/connector/rocketmq/EventMeshTestUtils.java | 20 +++++++++++---------
.../sink/connector/rocketmq/RocketMQSinkWorker.java | 17 ++++++++---------
.../rocketmq/connector/RocketMQSinkConnector.java | 4 ++--
.../connector/rocketmq/EventMeshTestUtils.java | 20 +++++++++++---------
.../connector/rocketmq/RocketMQSourceWorker.java | 14 +++++++-------
.../source/connector/rocketmq/UtilsConstants.java | 1 -
.../rocketmq/connector/RocketMQSourceConnector.java | 12 +++++++-----
.../storage/rocketmq/admin/AbstractRmqAdmin.java | 18 ++++++++++++++++++
.../storage/rocketmq/admin/RocketMQAdmin.java | 9 +--------
9 files changed, 65 insertions(+), 50 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]