This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
from 4e26d4100 Merge pull request #2460 from jonyangx/issue2459
new abb8a71f3 fix issue2308
new 74d56c5fe Merge branch 'master' into issue2308
new d24dbd221 add shell
new bd9d18fae refactor SubService
new 7fb438e35 Merge pull request #2418 from jonyangx/issue2308
The 2737 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:
.gitignore | 1 +
.../CloudEventsBatchPublishInstance.java | 53 +++++++++---------
.../cloudevents/CloudEventsPublishInstance.java | 51 +++++++++---------
.../cloudevents/CloudEventsRequestInstance.java | 51 +++++++++---------
.../eventmeshmessage/AsyncPublishBroadcast.java | 47 ++++++++--------
.../pub/eventmeshmessage/AsyncPublishInstance.java | 47 ++++++++--------
.../pub/eventmeshmessage/BatchPublishInstance.java | 49 ++++++++---------
.../pub/eventmeshmessage/RequestReplyInstance.java | 47 ++++++++--------
.../WorkflowAsyncPublishInstance.java | 58 ++++++++++----------
.../grpc/sub/CloudEventsAsyncSubscribe.java | 23 ++++----
.../grpc/sub/CloudEventsSubscribeReply.java | 23 ++++----
.../grpc/sub/EventmeshAsyncSubscribe.java | 23 ++++----
.../grpc/sub/EventmeshSubscribeBroadcast.java | 23 ++++----
.../grpc/sub/EventmeshSubscribeReply.java | 23 ++++----
.../grpc/sub/WorkflowExpressAsyncSubscribe.java | 56 ++++++++++---------
.../grpc/sub/WorkflowOrderAsyncSubscribe.java | 63 +++++++++++-----------
.../grpc/sub/WorkflowPaymentAsyncSubscribe.java | 56 ++++++++++---------
.../eventmesh/grpc/sub/app/service/SubService.java | 29 +++++-----
.../eventmeshmessage/AsyncSyncRequestInstance.java | 20 ++++---
.../http/demo/sub/controller/SubController.java | 5 +-
.../http/demo/sub/service/SubService.java | 54 ++++++++++---------
.../apache/eventmesh/selector/NacosSelector.java | 14 ++---
.../eventmesh/tcp/common/EventMeshTestUtils.java | 14 ++---
.../tcp/demo/pub/cloudevents/SyncRequest.java | 1 +
.../main/java/org/apache/eventmesh/util/Utils.java | 16 +++---
25 files changed, 438 insertions(+), 409 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
