This is an automated email from the ASF dual-hosted git repository.
harshitha pushed a change to branch harshithasudhakar-eventmesh#4254
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
from 0b2632a1d Merge branch 'master' into harshithasudhakar-eventmesh#4254
add f046a2ef4 [ISSUE #4402] Refactor the retry module with
HashedWheelTimer. (#4505)
add 763440474 [ISSUE #4503]Rust sdk use nightly toolchain (#4504)
add a717d3503 [WIP][ISSUE #4043]initial implementation of filter and
transform (#4365)
add cf16cf60d [ISSUE#4508] Add unit test for SpringSourceConnector. (#4509)
add ae76d75a1 [ISSUE#4510] Add test case for SpringSinkConnector. (#4511)
add f948cc56f [ISSUE #4513]Add eventmesh filter & transform sub module
(#4514)
add 11def17e8 [ISSUE #4517]Fix Webhook callback path is not a valid Nacos
dataId (#4518)
add a091017d9 [ISSUE#4515] Add test case for ProtocolPluginFactory. (#4516)
add 55865a660 [ISSUE #4502] Optimizing Log Printing Using the LogUtils
add 2bfc1ae80 [ISSUE #4521] A poor naming. (#4524)
add 80c7f8822 [ISSUE #4319] C SDK Framework (#4323)
add 2f66f2082 [ISSUE #4320] C SDK Support For TCP (#4324)
add e13ac79c5 [ISSUE #4321] Add Examples And Configs For C SDK (#4326)
add 20155edc0 [ISSUE #4322] C SDK Makefile (#4327)
add bdacd2335 [ISSUE #3906] Do some code optimization.[EventMeshUtil]
(#4527)
add 4bda07944 [ISSUE #3825] Do some code optimization.[TopicMetadata]
(#4526)
add 40a2aea81 [ISSUE #4519]Rust sdk support CloudEvents (#4520)
add 42d6e556f [ISSUE#4536] Add unit test for RocketMQSinkConnector. (#4538)
add 360ed6624 [ISSUE #3902] Do some code optimization.[NetUtils] (#4528)
add 261223f36 [ISSUE#4531] Add unit test for RedisSinkConnector. (#4533)
add 7438a5542 [ISSUE #4529] Add sendcallback for springConnector. (#4532)
add 0b6ae9f11 [ISSUE #4549]Remove unnecessary transient modifiers. (#4550)
add fe7256fb4 [ISSUE#4535] Add unit test for RocketMQSourceConnector.
(#4546)
add c35052829 fix make libcurl.a error (#4542)
add 3a580dcd3 [MINOR] Fix ci check error (#4543)
add a60d46f2f Update SendAsyncMessageProcessor.java (#4054)
add 9cb170420 [ISSUE #3472]Do some code optimization[HttpProtocolAdaptor]
(#3883)
add 9fdc30a30 [ISSUE#4530] Add unit test for RedisSourceConnector. (#4545)
add 013512bd7 [ISSUE#4552] Add example for spring connector sdk. (#4553)
add 13f4d98ff [ISSUE#4178] When there are a large number of errors in the
HTTP target, RocketMQ consumption is slow (#4544)
new 36ebe5abe Merge branch 'master' into harshithasudhakar-eventmesh#4254
The 1 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:
.github/workflows/ci.yml | 8 +
.gitmodules | 7 +
build.gradle | 1 +
.../eventmesh/admin/config/AdminProperties.java | 2 +-
.../eventmesh/admin/config/MetaTypeConfig.java | 4 +-
.../admin/{common => constant}/ConfigConst.java | 2 +-
.../admin/{common => constant}/NacosConst.java | 2 +-
.../org/apache/eventmesh/admin/dto/Result.java | 50 +-
.../admin/enums/{Errors.java => Status.java} | 30 +-
.../eventmesh/admin/exception/BaseException.java | 20 +-
.../admin/exception/EventMeshAdminException.java | 6 +-
.../admin/exception/GlobalExceptionHandler.java | 9 +-
.../eventmesh/admin/exception/MetaException.java | 10 +-
.../service/impl/NacosSubscriptionService.java | 16 +-
.../ExceptionUtil.java} | 4 +-
eventmesh-common/build.gradle | 5 +
.../org/apache/eventmesh/common/Constants.java | 7 +
.../common/config/CommonConfiguration.java | 4 +
.../eventmesh/common/file/WatchFileManager.java | 10 +-
.../eventmesh/common/file/WatchFileTask.java | 10 +-
.../common/protocol/http/common/ProtocolKey.java | 1 +
.../eventmesh/common/protocol/tcp/codec/Codec.java | 13 +-
.../eventmesh/common/utils/JsonPathUtils.java | 144 +
.../apache/eventmesh/common/utils/NetUtils.java | 3 +-
.../connector/jdbc/connection/JdbcConnection.java | 35 +-
.../source/dialect/cdc/mysql/MysqlCdcEngine.java | 4 +-
.../source/dialect/mysql/MysqlDatabaseDialect.java | 17 +-
.../connector/PrometheusSourceConnector.java | 1 +
.../eventmesh-connector-redis/build.gradle | 3 +
.../connector/redis/AbstractRedisServer.java | 29 +-
.../sink/connector/RedisSinkConnectorTest.java | 101 +
.../source/connector/RedisSourceConnectorTest.java | 98 +
.../src/{main => test}/resources/sink-config.yml | 0
.../src/{main => test}/resources/source-config.yml | 0
.../eventmesh-connector-rocketmq/build.gradle | 3 +
.../sink/connector/RocketMQSinkConnectorTest.java | 93 +
.../connector/RocketMQSourceConnectorTest.java | 92 +
.../src/{main => test}/resources/sink-config.yml | 0
.../src/{main => test}/resources/source-config.yml | 0
.../eventmesh-connector-spring/build.gradle | 5 +
.../spring/source/MessageSendingOperations.java | 4 +
.../source/connector/SpringSourceConnector.java | 21 +
.../sink/connector/SpringSinkConnectorTest.java | 80 +
.../connector/SpringSourceConnectorTest.java | 59 +
eventmesh-examples/build.gradle | 1 +
.../WorkflowAsyncPublishInstance.java | 5 +-
.../grpc/sub/CloudEventsAsyncSubscribe.java | 5 +-
.../grpc/sub/CloudEventsSubscribeReply.java | 5 +-
.../grpc/sub/EventMeshAsyncSubscribe.java | 5 +-
.../grpc/sub/EventMeshSubscribeBroadcast.java | 5 +-
.../grpc/sub/EventMeshSubscribeReply.java | 5 +-
.../grpc/sub/WorkflowExpressAsyncSubscribe.java | 9 +-
.../grpc/sub/WorkflowOrderAsyncSubscribe.java | 9 +-
.../grpc/sub/WorkflowPaymentAsyncSubscribe.java | 9 +-
.../grpc/sub/app/controller/SubController.java | 5 +-
.../eventmesh/grpc/sub/app/service/SubService.java | 25 +-
.../eventmeshmessage/AsyncSyncRequestInstance.java | 11 +-
.../pub/eventmeshmessage/SyncRequestInstance.java | 7 +-
.../http/demo/sub/controller/SubController.java | 9 +-
.../http/demo/sub/service/SubService.java | 21 +-
.../spring/SpringBootDemoApplication.java | 14 +-
.../eventmesh/spring/pub/SpringPubController.java | 62 +
.../eventmesh/spring/sub/SpringSubHandler.java | 19 +-
.../tcp/demo/pub/cloudevents/AsyncPublish.java | 5 +-
.../tcp/demo/pub/cloudevents/SyncRequest.java | 9 +-
.../demo/pub/eventmeshmessage/AsyncPublish.java | 5 +-
.../eventmeshmessage/AsyncPublishBroadcast.java | 5 +-
.../tcp/demo/pub/eventmeshmessage/SyncRequest.java | 9 +-
.../tcp/demo/sub/cloudevents/AsyncSubscribe.java | 5 +-
.../tcp/demo/sub/cloudevents/SyncResponse.java | 5 +-
.../demo/sub/eventmeshmessage/AsyncSubscribe.java | 5 +-
.../eventmeshmessage/AsyncSubscribeBroadcast.java | 5 +-
.../demo/sub/eventmeshmessage/SyncResponse.java | 5 +-
.../src/main/resources/server-config.yml | 0
.../src/main/resources/sink-config.yml | 28 +
.../src/main/resources/source-config.yml | 28 +
.../build.gradle | 6 +-
.../org/apache/eventmesh/filter/PatternEntry.java | 68 +
.../filter/condition/AnythingButCondition.java | 71 +
.../eventmesh/filter/condition/Condition.java | 11 +-
.../filter/condition/ConditionsBuilder.java | 65 +
.../filter/condition/ExistsCondition.java | 20 +-
.../filter/condition/NumericCondition.java | 80 +
.../filter/condition/PrefixCondition.java | 25 +-
.../filter/condition/SpecifiedCondition.java | 25 +-
.../filter/condition/SuffixCondition.java | 25 +-
.../apache/eventmesh/filter/pattern/Pattern.java | 87 +
.../filter/patternbuild/PatternBuilder.java | 189 +
.../org/apache/eventmesh/filter/PatternTest.java | 147 +
.../metrics/api/model/HttpSummaryMetrics.java | 11 +-
.../metrics/api/model/RetrySummaryMetrics.java | 13 +-
.../metrics/api/model/TcpSummaryMetrics.java | 6 +-
.../apache/eventmesh/openconnect/SourceWorker.java | 29 +-
.../api/callback/SendExcepionContext.java | 40 +-
.../api/callback/SendMessageCallback.java | 9 +-
.../openconnect/api/callback/SendResult.java | 35 +-
.../offsetmgmt/api/data/ConnectRecord.java | 9 +-
.../offsetmgmt/api/data/DefaultKeyValue.java | 25 +-
.../openconnect/offsetmgmt/api/data/KeyValue.java | 4 +-
.../protocol/api/MockProtocolAdaptorImpl.java | 37 +-
.../protocol/api/ProtocolPluginFactoryTest.java | 69 +
...g.apache.eventmesh.protocol.api.ProtocolAdaptor | 17 +
.../protocol/http/HttpProtocolAdaptor.java | 5 +-
.../eventmesh-retry-api}/build.gradle | 11 +-
.../eventmesh/retry/api/AbstractRetryer.java | 87 +
.../org/apache/eventmesh/retry/api/Retryer.java | 20 +-
.../retry/api/conf/RetryConfiguration.java | 26 +-
.../retry/api/strategy/RetryStrategy.java | 14 +-
.../retry/api/timer/HashedWheelTimer.java | 802 +++
.../apache/eventmesh/retry/api/timer/Timeout.java | 56 +
.../apache/eventmesh/retry/api/timer/Timer.java | 62 +
.../eventmesh/retry/api/timer/TimerTask.java | 27 +-
.../eventmesh-retry-rocketmq}/build.gradle | 12 +-
.../eventmesh-retry-rocketmq/gradle.properties | 19 +
.../retry/rocketmq/RocketMQRetryStrategyImpl.java | 75 +
...ache.eventmesh.retry.api.strategy.RetryStrategy | 16 +
eventmesh-runtime/build.gradle | 2 +
eventmesh-runtime/conf/eventmesh.properties | 2 +
.../handler/RedirectClientByIpPortHandler.java | 2 +-
.../admin/handler/RedirectClientByPathHandler.java | 2 +-
.../handler/RedirectClientBySubSystemHandler.java | 22 +-
.../admin/handler/RejectAllClientHandler.java | 5 +-
.../admin/handler/RejectClientByIpPortHandler.java | 2 +-
.../handler/RejectClientBySubSystemHandler.java | 2 +-
.../admin/handler/ShowClientBySystemHandler.java | 5 +-
.../runtime/admin/response/GetMetricsResponse.java | 8 +-
.../eventmesh/runtime/boot/AbstractHTTPServer.java | 41 +-
.../runtime/boot/AbstractRemotingServer.java | 57 +-
.../eventmesh/runtime/boot/AbstractTCPServer.java | 17 +-
.../runtime/boot/EventMeshGrpcServer.java | 20 +-
.../runtime/boot/EventMeshHTTPServer.java | 21 +-
.../eventmesh/runtime/boot/EventMeshServer.java | 21 +-
.../eventmesh/runtime/boot/EventMeshStartup.java | 10 +-
.../eventmesh/runtime/boot/EventMeshTCPServer.java | 27 +-
.../eventmesh/runtime/boot/RemotingServer.java | 11 +-
.../configuration/EventMeshHTTPConfiguration.java | 1 +
.../runtime/core/protocol/AbstractRetryer.java | 87 -
.../runtime/core/protocol/RetryContext.java | 87 +-
.../protocol/consumer/HandleMessageContext.java | 11 +-
.../protocol/grpc/consumer/ConsumerManager.java | 31 +-
.../protocol/grpc/consumer/EventMeshConsumer.java | 33 +-
.../consumer/consumergroup/StreamTopicConfig.java | 7 +-
.../processor/BatchPublishCloudEventProcessor.java | 6 +-
.../processor/PublishCloudEventsProcessor.java | 6 +-
.../grpc/processor/ReplyMessageProcessor.java | 6 +-
.../grpc/processor/RequestCloudEventProcessor.java | 6 +-
.../grpc/processor/SubscribeProcessor.java | 17 +-
.../protocol/grpc/producer/ProducerManager.java | 90 -
.../protocol/grpc/push/AbstractPushRequest.java | 14 +-
.../core/protocol/grpc/retry/GrpcRetryer.java | 29 +-
.../protocol/http/consumer/EventMeshConsumer.java | 13 +-
.../protocol/http/consumer/HandleMsgContext.java | 3 +-
.../http/consumer/HttpClientGroupMapping.java | 82 +-
.../http/processor/BatchSendMessageProcessor.java | 21 +-
.../processor/BatchSendMessageV2Processor.java | 13 +-
.../http/processor/CreateTopicProcessor.java | 5 +-
.../http/processor/DeleteTopicProcessor.java | 5 +-
.../protocol/http/processor/HandlerService.java | 9 +-
.../http/processor/HeartBeatProcessor.java | 23 +-
.../processor/LocalSubscribeEventProcessor.java | 33 +-
.../processor/LocalUnSubscribeEventProcessor.java | 32 +-
.../http/processor/QuerySubscriptionProcessor.java | 5 +-
.../http/processor/ReplyMessageProcessor.java | 13 +-
.../http/processor/SendAsyncEventProcessor.java | 51 +-
.../http/processor/SendAsyncMessageProcessor.java | 19 +-
.../processor/SendAsyncRemoteEventProcessor.java | 47 +-
.../http/processor/SendSyncMessageProcessor.java | 67 +-
.../http/processor/SubscribeProcessor.java | 32 +-
.../http/processor/UnSubscribeProcessor.java | 32 +-
.../protocol/http/producer/EventMeshProducer.java | 130 -
.../protocol/http/producer/SendMessageContext.java | 151 -
.../http/push/AbstractHTTPPushRequest.java | 17 +-
.../protocol/http/push/AsyncHTTPPushRequest.java | 42 +-
.../protocol/http/push/HTTPMessageHandler.java | 4 +-
.../core/protocol/http/retry/HttpRetryer.java | 36 +-
.../{grpc => }/producer/EventMeshProducer.java | 25 +-
.../{http => }/producer/ProducerManager.java | 20 +-
.../{grpc => }/producer/SendMessageContext.java | 16 +-
.../tcp/client/group/ClientGroupWrapper.java | 50 +-
.../client/group/ClientSessionGroupMapping.java | 5 +-
.../dispatch/FreePriorityDispatchStrategy.java | 15 +-
.../tcp/client/processor/HelloProcessor.java | 2 +-
.../client/processor/MessageTransferProcessor.java | 5 +-
.../tcp/client/processor/SubscribeProcessor.java | 7 +-
.../client/recommend/EventMeshRecommendImpl.java | 85 +-
.../client/session/push/DownStreamMsgContext.java | 5 +-
.../tcp/client/session/push/SessionPusher.java | 5 +-
.../{EventMeshTcpRetryer.java => TcpRetryer.java} | 40 +-
.../client/session/send/UpStreamMsgContext.java | 12 +-
.../runtime/metrics/grpc/EventMeshGrpcMonitor.java | 2 +-
.../runtime/metrics/http/HTTPMetricsServer.java | 116 +-
.../runtime/metrics/tcp/EventMeshTcpMonitor.java | 4 +-
.../eventmesh/runtime/util/EventMeshUtil.java | 14 +-
.../apache/eventmesh/runtime/util/WebhookUtil.java | 11 +-
.../runtime/client/common/RequestContext.java | 5 +-
.../runtime/client/impl/PubClientImpl.java | 27 +-
.../runtime/client/impl/SubClientImpl.java | 19 +-
.../eventmesh/runtime/demo/AsyncPubClient.java | 5 +-
.../eventmesh/runtime/demo/AsyncSubClient.java | 5 +-
.../eventmesh/runtime/demo/BroadCastSubClient.java | 5 +-
.../apache/eventmesh/runtime/demo/CCSubClient.java | 5 +-
.../apache/eventmesh/runtime/demo/CClientDemo.java | 5 +-
.../eventmesh/runtime/demo/SyncPubClient.java | 7 +-
.../eventmesh/runtime/demo/SyncSubClient.java | 5 +-
eventmesh-sdks/eventmesh-sdk-c/README.md | 20 +
eventmesh-sdks/eventmesh-sdk-c/configs/rmb.conf | 61 +
eventmesh-sdks/eventmesh-sdk-c/examples/demo.c | 1715 ++++++
.../eventmesh-sdk-c/include/message_log_api.h | 55 +
.../eventmesh-sdk-c/include/rmb_access_config.h | 45 +
eventmesh-sdks/eventmesh-sdk-c/include/rmb_cfg.h | 60 +
.../eventmesh-sdk-c/include/rmb_common.h | 269 +
.../eventmesh-sdk-c/include/rmb_context.h | 66 +
.../eventmesh-sdk-c/include/rmb_define.h | 1264 +++++
eventmesh-sdks/eventmesh-sdk-c/include/rmb_errno.h | 137 +
.../eventmesh-sdk-c/include/rmb_http_client.h | 38 +
eventmesh-sdks/eventmesh-sdk-c/include/rmb_list.h | 564 ++
eventmesh-sdks/eventmesh-sdk-c/include/rmb_log.h | 121 +
eventmesh-sdks/eventmesh-sdk-c/include/rmb_mq.h | 282 +
eventmesh-sdks/eventmesh-sdk-c/include/rmb_msg.h | 163 +
eventmesh-sdks/eventmesh-sdk-c/include/rmb_pub.h | 157 +
eventmesh-sdks/eventmesh-sdk-c/include/rmb_sub.h | 335 ++
eventmesh-sdks/eventmesh-sdk-c/include/rmb_udp.h | 78 +
.../eventmesh-sdk-c/include/rmb_vector.h | 43 +
eventmesh-sdks/eventmesh-sdk-c/include/wemq_fifo.h | 639 +++
.../eventmesh-sdk-c/include/wemq_proto.h | 562 ++
eventmesh-sdks/eventmesh-sdk-c/include/wemq_tcp.h | 39 +
.../eventmesh-sdk-c/include/wemq_thread.h | 113 +
.../eventmesh-sdk-c/include/wemq_topic_list.h | 53 +
eventmesh-sdks/eventmesh-sdk-c/makefile | 99 +
eventmesh-sdks/eventmesh-sdk-c/src/common.h | 39 +
.../eventmesh-sdk-c/src/message_log_api.c | 397 ++
.../eventmesh-sdk-c/src/rmb_access_config.c | 827 +++
eventmesh-sdks/eventmesh-sdk-c/src/rmb_cfg.c | 594 +++
eventmesh-sdks/eventmesh-sdk-c/src/rmb_context.c | 907 ++++
eventmesh-sdks/eventmesh-sdk-c/src/rmb_errno.c | 155 +
.../eventmesh-sdk-c/src/rmb_http_client.c | 211 +
eventmesh-sdks/eventmesh-sdk-c/src/rmb_log.c | 1273 +++++
eventmesh-sdks/eventmesh-sdk-c/src/rmb_mq.c | 1357 +++++
eventmesh-sdks/eventmesh-sdk-c/src/rmb_msg.c | 1686 ++++++
eventmesh-sdks/eventmesh-sdk-c/src/rmb_pub.c | 2453 +++++++++
eventmesh-sdks/eventmesh-sdk-c/src/rmb_sub.c | 1379 +++++
eventmesh-sdks/eventmesh-sdk-c/src/rmb_udp.c | 383 ++
eventmesh-sdks/eventmesh-sdk-c/src/rmb_vector.c | 84 +
eventmesh-sdks/eventmesh-sdk-c/src/wemq_fifo.c | 350 ++
eventmesh-sdks/eventmesh-sdk-c/src/wemq_proto.c | 748 +++
eventmesh-sdks/eventmesh-sdk-c/src/wemq_tcp.c | 773 +++
eventmesh-sdks/eventmesh-sdk-c/src/wemq_thread.c | 5467 ++++++++++++++++++++
.../eventmesh-sdk-c/src/wemq_topic_list.c | 237 +
eventmesh-sdks/eventmesh-sdk-c/third_party/curl | 1 +
eventmesh-sdks/eventmesh-sdk-c/third_party/json-c | 1 +
.../client/catalog/EventMeshCatalogClient.java | 5 +-
.../grpc/consumer/EventMeshGrpcConsumer.java | 37 +-
.../client/grpc/consumer/SubStreamHandler.java | 39 +-
.../client/grpc/producer/CloudEventProducer.java | 38 +-
.../grpc/producer/EventMeshGrpcProducer.java | 9 +-
.../grpc/producer/EventMeshMessageProducer.java | 25 +-
.../http/consumer/EventMeshHttpConsumer.java | 12 +-
.../eventmesh/client/http/util/HttpUtils.java | 9 +-
.../client/tcp/common/RequestContext.java | 5 +-
.../eventmesh/client/tcp/common/TcpClient.java | 29 +-
.../EventMeshMessageTCPPubClient.java | 5 +-
.../client/workflow/EventMeshWorkflowClient.java | 5 +-
.../client/http/demo/SyncRequestInstance.java | 7 +-
eventmesh-sdks/eventmesh-sdk-rust/Cargo.toml | 24 +-
.../examples/grpc/producer_example.rs | 101 +-
.../eventmesh-sdk-rust/rust-toolchain.toml | 21 +
eventmesh-sdks/eventmesh-sdk-rust/src/common.rs | 2 +-
...ge_utils.rs => grpc_eventmesh_message_utils.rs} | 222 +-
.../eventmesh-sdk-rust/src/common/protocol_key.rs | 4 +
eventmesh-sdks/eventmesh-sdk-rust/src/grpc.rs | 6 +-
.../eventmesh-sdk-rust/src/grpc/grpc_consumer.rs | 6 +-
.../eventmesh-sdk-rust/src/grpc/grpc_producer.rs | 15 +-
.../src/grpc/{eventmesh_message.rs => impl.rs} | 4 +-
.../grpc_producer_impl.rs} | 67 +-
eventmesh-sdks/eventmesh-sdk-rust/src/lib.rs | 18 +-
eventmesh-sdks/eventmesh-sdk-rust/src/model.rs | 1 +
.../eventmesh-sdk-rust/src/model/event_clouds.rs | 21 +-
.../eventmesh-sdk-rust/src/model/message.rs | 16 +-
.../tests/eventmesh_message_utils_test.rs | 2 +-
.../eventmesh/spi/EventMeshExtensionType.java | 1 +
.../org/apache/eventmesh/api/TopicNameHelper.java | 18 +-
.../rocketmq/common/TopicNameHelperImpl.java | 25 +-
.../org.apache.eventmesh.api.TopicNameHelper | 16 +
.../standalone/broker/model/TopicMetadata.java | 4 +-
.../build.gradle | 6 +-
.../eventmesh/transformer/ConstantTransformer.java | 17 +-
.../eventmesh/transformer/JsonPathParser.java | 86 +
.../eventmesh/transformer/OriginalTransformer.java | 13 +-
.../org/apache/eventmesh/transformer/Template.java | 52 +
.../eventmesh/transformer/TemplateTransformer.java | 34 +-
.../eventmesh/transformer/TransformException.java | 19 +-
.../apache/eventmesh/transformer/Transformer.java | 13 +-
.../eventmesh/transformer/TransformerBuilder.java | 71 +
.../eventmesh/transformer/TransformerType.java | 9 +-
.../org/apache/eventmesh/transformer/Variable.java | 41 +-
.../eventmesh/transformer/TransformTest.java | 139 +
.../admin/AdminWebHookConfigOperationManager.java | 6 +-
.../webhook/admin/FileWebHookConfigOperation.java | 35 +-
.../webhook/admin/NacosWebHookConfigOperation.java | 35 +-
.../webhook/receive/WebHookController.java | 9 +-
settings.gradle | 6 +
tools/dependency-check/known-dependencies.txt | 4 +
302 files changed, 31237 insertions(+), 2310 deletions(-)
create mode 100644 .gitmodules
rename eventmesh-admin/src/main/java/org/apache/eventmesh/admin/{common =>
constant}/ConfigConst.java (96%)
rename eventmesh-admin/src/main/java/org/apache/eventmesh/admin/{common =>
constant}/NacosConst.java (97%)
rename
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/enums/{Errors.java =>
Status.java} (65%)
copy
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/{utils/ExceptionUtils.java
=> util/ExceptionUtil.java} (94%)
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/JsonPathUtils.java
copy
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/utils/ExceptionUtils.java
=>
eventmesh-connectors/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/AbstractRedisServer.java
(59%)
create mode 100644
eventmesh-connectors/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/sink/connector/RedisSinkConnectorTest.java
create mode 100644
eventmesh-connectors/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/source/connector/RedisSourceConnectorTest.java
copy eventmesh-connectors/eventmesh-connector-redis/src/{main =>
test}/resources/sink-config.yml (100%)
copy eventmesh-connectors/eventmesh-connector-redis/src/{main =>
test}/resources/source-config.yml (100%)
create mode 100644
eventmesh-connectors/eventmesh-connector-rocketmq/src/test/java/org/apache/eventmesh/connector/rocketmq/sink/connector/RocketMQSinkConnectorTest.java
create mode 100644
eventmesh-connectors/eventmesh-connector-rocketmq/src/test/java/org/apache/eventmesh/connector/rocketmq/source/connector/RocketMQSourceConnectorTest.java
copy eventmesh-connectors/eventmesh-connector-rocketmq/src/{main =>
test}/resources/sink-config.yml (100%)
copy eventmesh-connectors/eventmesh-connector-rocketmq/src/{main =>
test}/resources/source-config.yml (100%)
create mode 100644
eventmesh-connectors/eventmesh-connector-spring/src/test/java/org/apache/eventmesh/connector/spring/sink/connector/SpringSinkConnectorTest.java
create mode 100644
eventmesh-connectors/eventmesh-connector-spring/src/test/java/org/apache/eventmesh/connector/spring/source/connector/SpringSourceConnectorTest.java
copy
eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/source/MessageSendingOperations.java
=>
eventmesh-examples/src/main/java/org/apache/eventmesh/spring/SpringBootDemoApplication.java
(70%)
create mode 100644
eventmesh-examples/src/main/java/org/apache/eventmesh/spring/pub/SpringPubController.java
copy
eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/source/MessageSendingOperations.java
=>
eventmesh-examples/src/main/java/org/apache/eventmesh/spring/sub/SpringSubHandler.java
(67%)
copy {eventmesh-connectors/eventmesh-connector-jdbc =>
eventmesh-examples}/src/main/resources/server-config.yml (100%)
create mode 100644 eventmesh-examples/src/main/resources/sink-config.yml
create mode 100644 eventmesh-examples/src/main/resources/source-config.yml
copy eventmesh-sdks/eventmesh-sdk-rust/src/grpc/eventmesh_message.rs =>
eventmesh-filter/build.gradle (89%)
create mode 100644
eventmesh-filter/src/main/java/org/apache/eventmesh/filter/PatternEntry.java
create mode 100644
eventmesh-filter/src/main/java/org/apache/eventmesh/filter/condition/AnythingButCondition.java
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/DelayRetryable.java
=>
eventmesh-filter/src/main/java/org/apache/eventmesh/filter/condition/Condition.java
(81%)
create mode 100644
eventmesh-filter/src/main/java/org/apache/eventmesh/filter/condition/ConditionsBuilder.java
copy
eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/source/MessageSendingOperations.java
=>
eventmesh-filter/src/main/java/org/apache/eventmesh/filter/condition/ExistsCondition.java
(67%)
create mode 100644
eventmesh-filter/src/main/java/org/apache/eventmesh/filter/condition/NumericCondition.java
copy
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/utils/ExceptionUtils.java
=>
eventmesh-filter/src/main/java/org/apache/eventmesh/filter/condition/PrefixCondition.java
(67%)
copy
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/utils/ExceptionUtils.java
=>
eventmesh-filter/src/main/java/org/apache/eventmesh/filter/condition/SpecifiedCondition.java
(67%)
copy
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/utils/ExceptionUtils.java
=>
eventmesh-filter/src/main/java/org/apache/eventmesh/filter/condition/SuffixCondition.java
(67%)
create mode 100644
eventmesh-filter/src/main/java/org/apache/eventmesh/filter/pattern/Pattern.java
create mode 100644
eventmesh-filter/src/main/java/org/apache/eventmesh/filter/patternbuild/PatternBuilder.java
create mode 100644
eventmesh-filter/src/test/java/org/apache/eventmesh/filter/PatternTest.java
copy
eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/source/MessageSendingOperations.java
=>
eventmesh-metrics-plugin/eventmesh-metrics-api/src/main/java/org/apache/eventmesh/metrics/api/model/RetrySummaryMetrics.java
(80%)
copy
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/exception/MetaException.java
=>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/callback/SendExcepionContext.java
(56%)
copy
eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/source/MessageSendingOperations.java
=>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/callback/SendMessageCallback.java
(77%)
copy
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/exception/MetaException.java
=>
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/callback/SendResult.java
(58%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/RetryContext.java
=>
eventmesh-protocol-plugin/eventmesh-protocol-api/src/test/java/org/apache/eventmesh/protocol/api/MockProtocolAdaptorImpl.java
(52%)
create mode 100644
eventmesh-protocol-plugin/eventmesh-protocol-api/src/test/java/org/apache/eventmesh/protocol/api/ProtocolPluginFactoryTest.java
create mode 100644
eventmesh-protocol-plugin/eventmesh-protocol-api/src/test/resources/META-INF/eventmesh/org.apache.eventmesh.protocol.api.ProtocolAdaptor
copy {eventmesh-connectors/eventmesh-connector-redis =>
eventmesh-retry/eventmesh-retry-api}/build.gradle (72%)
create mode 100644
eventmesh-retry/eventmesh-retry-api/src/main/java/org/apache/eventmesh/retry/api/AbstractRetryer.java
copy
eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/source/MessageSendingOperations.java
=>
eventmesh-retry/eventmesh-retry-api/src/main/java/org/apache/eventmesh/retry/api/Retryer.java
(69%)
copy
eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/source/MessageSendingOperations.java
=>
eventmesh-retry/eventmesh-retry-api/src/main/java/org/apache/eventmesh/retry/api/conf/RetryConfiguration.java
(63%)
copy
eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/source/MessageSendingOperations.java
=>
eventmesh-retry/eventmesh-retry-api/src/main/java/org/apache/eventmesh/retry/api/strategy/RetryStrategy.java
(66%)
create mode 100644
eventmesh-retry/eventmesh-retry-api/src/main/java/org/apache/eventmesh/retry/api/timer/HashedWheelTimer.java
create mode 100644
eventmesh-retry/eventmesh-retry-api/src/main/java/org/apache/eventmesh/retry/api/timer/Timeout.java
create mode 100644
eventmesh-retry/eventmesh-retry-api/src/main/java/org/apache/eventmesh/retry/api/timer/Timer.java
copy
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/exception/EventMeshAdminException.java
=>
eventmesh-retry/eventmesh-retry-api/src/main/java/org/apache/eventmesh/retry/api/timer/TimerTask.java
(60%)
copy {eventmesh-connectors/eventmesh-connector-rocketmq =>
eventmesh-retry/eventmesh-retry-rocketmq}/build.gradle (79%)
create mode 100644 eventmesh-retry/eventmesh-retry-rocketmq/gradle.properties
create mode 100644
eventmesh-retry/eventmesh-retry-rocketmq/src/main/java/org/apache/eventmesh/retry/rocketmq/RocketMQRetryStrategyImpl.java
create mode 100644
eventmesh-retry/eventmesh-retry-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.retry.api.strategy.RetryStrategy
copy
eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/source/MessageSendingOperations.java
=>
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/RemotingServer.java
(76%)
delete mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/AbstractRetryer.java
copy
eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/source/MessageSendingOperations.java
=>
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/consumer/HandleMessageContext.java
(80%)
delete mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/producer/ProducerManager.java
delete mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/producer/EventMeshProducer.java
delete mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/producer/SendMessageContext.java
rename
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/{grpc
=> }/producer/EventMeshProducer.java (82%)
rename
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/{http
=> }/producer/ProducerManager.java (85%)
rename
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/{grpc
=> }/producer/SendMessageContext.java (91%)
rename
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/retry/{EventMeshTcpRetryer.java
=> TcpRetryer.java} (63%)
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/README.md
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/configs/rmb.conf
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/examples/demo.c
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/include/message_log_api.h
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/include/rmb_access_config.h
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/include/rmb_cfg.h
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/include/rmb_common.h
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/include/rmb_context.h
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/include/rmb_define.h
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/include/rmb_errno.h
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/include/rmb_http_client.h
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/include/rmb_list.h
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/include/rmb_log.h
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/include/rmb_mq.h
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/include/rmb_msg.h
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/include/rmb_pub.h
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/include/rmb_sub.h
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/include/rmb_udp.h
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/include/rmb_vector.h
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/include/wemq_fifo.h
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/include/wemq_proto.h
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/include/wemq_tcp.h
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/include/wemq_thread.h
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/include/wemq_topic_list.h
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/makefile
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/src/common.h
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/src/message_log_api.c
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/src/rmb_access_config.c
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/src/rmb_cfg.c
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/src/rmb_context.c
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/src/rmb_errno.c
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/src/rmb_http_client.c
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/src/rmb_log.c
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/src/rmb_mq.c
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/src/rmb_msg.c
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/src/rmb_pub.c
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/src/rmb_sub.c
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/src/rmb_udp.c
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/src/rmb_vector.c
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/src/wemq_fifo.c
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/src/wemq_proto.c
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/src/wemq_tcp.c
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/src/wemq_thread.c
create mode 100644 eventmesh-sdks/eventmesh-sdk-c/src/wemq_topic_list.c
create mode 160000 eventmesh-sdks/eventmesh-sdk-c/third_party/curl
create mode 160000 eventmesh-sdks/eventmesh-sdk-c/third_party/json-c
create mode 100644 eventmesh-sdks/eventmesh-sdk-rust/rust-toolchain.toml
rename
eventmesh-sdks/eventmesh-sdk-rust/src/common/{eventmesh_message_utils.rs =>
grpc_eventmesh_message_utils.rs} (69%)
copy eventmesh-sdks/eventmesh-sdk-rust/src/grpc/{eventmesh_message.rs =>
impl.rs} (89%)
rename
eventmesh-sdks/eventmesh-sdk-rust/src/grpc/{eventmesh_message/eventmesh_message_producer.rs
=> impl/grpc_producer_impl.rs} (77%)
copy
eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/source/MessageSendingOperations.java
=> eventmesh-sdks/eventmesh-sdk-rust/src/model/event_clouds.rs (70%)
copy
eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/source/MessageSendingOperations.java
=>
eventmesh-storage-plugin/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/TopicNameHelper.java
(63%)
copy
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/utils/ExceptionUtils.java
=>
eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/common/TopicNameHelperImpl.java
(63%)
create mode 100644
eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.TopicNameHelper
copy eventmesh-sdks/eventmesh-sdk-rust/src/grpc/eventmesh_message.rs =>
eventmesh-transformer/build.gradle (89%)
copy
eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/source/MessageSendingOperations.java
=>
eventmesh-transformer/src/main/java/org/apache/eventmesh/transformer/ConstantTransformer.java
(70%)
create mode 100644
eventmesh-transformer/src/main/java/org/apache/eventmesh/transformer/JsonPathParser.java
copy
eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/source/MessageSendingOperations.java
=>
eventmesh-transformer/src/main/java/org/apache/eventmesh/transformer/OriginalTransformer.java
(82%)
create mode 100644
eventmesh-transformer/src/main/java/org/apache/eventmesh/transformer/Template.java
copy
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/exception/MetaException.java
=>
eventmesh-transformer/src/main/java/org/apache/eventmesh/transformer/TemplateTransformer.java
(52%)
rename
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/DelayRetryable.java
=>
eventmesh-transformer/src/main/java/org/apache/eventmesh/transformer/TransformException.java
(68%)
copy
eventmesh-connectors/eventmesh-connector-spring/src/main/java/org/apache/eventmesh/connector/spring/source/MessageSendingOperations.java
=>
eventmesh-transformer/src/main/java/org/apache/eventmesh/transformer/Transformer.java
(71%)
create mode 100644
eventmesh-transformer/src/main/java/org/apache/eventmesh/transformer/TransformerBuilder.java
rename eventmesh-sdks/eventmesh-sdk-rust/src/grpc/eventmesh_message.rs =>
eventmesh-transformer/src/main/java/org/apache/eventmesh/transformer/TransformerType.java
(87%)
rename
eventmesh-admin/src/main/java/org/apache/eventmesh/admin/utils/ExceptionUtils.java
=>
eventmesh-transformer/src/main/java/org/apache/eventmesh/transformer/Variable.java
(61%)
create mode 100644
eventmesh-transformer/src/test/java/org/apache/eventmesh/transformer/TransformTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
