Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Feature #564] Support CloudEvents protocols for pub/sub in EventMesh #638

Merged
merged 37 commits into from
Dec 9, 2021

Conversation

xwm1992
Copy link
Contributor

@xwm1992 xwm1992 commented Dec 8, 2021

related issue #564

xwm1992 and others added 30 commits October 29, 2021 18:13
* SDK SUPPORT CLOUD EVENT

* SDK SUPPORT CLOUD EVENT

* SDK SUPPORT CLOUD EVENT

* SDK SUPPORT CLOUD EVENT

* SDK SUPPORT CLOUD EVENT

* SDK SUPPORT CLOUD EVENT

* SDK SUPPORT CLOUD EVENT

* SDK SUPPORT CLOUD EVENT

* SDK SUPPORT CLOUD EVENT

Co-authored-by: wangshaojie <wangshaojie@cmss.chinamobile.com>
…pi module (apache#578)

* [Feature apache#564] Support CloudEvents protocols for pub/sub in EventMesh-feature design

* support cloudevents api in eventmesh-connector-api module

* fix checkStyle

* fix checkStyle

* fix checkStyle

* 1.support LifeCycle.java
2.update Consumer and Producer

* fix remove the extra blank line
Co-authored-by: wangshaojie <wangshaojie@cmss.chinamobile.com>
…time (apache#587)

* [Feature apache#564] Support CloudEvents protocols for pub/sub in EventMesh-feature design

* support cloudevents api in eventmesh-connector-api module

* fix checkStyle

* fix checkStyle

* fix checkStyle

* 1.support LifeCycle.java
2.update Consumer and Producer

* fix remove the extra blank line

* support cloudEvents

* support cloudEvents

* support cloudEvents

* support cloudEvents

* support cloudevents

* support cloudEvents

* support cloudEvents

* support cloudEvents
* [Feature apache#564] Support CloudEvents protocols for pub/sub in EventMesh-feature design

* support cloudevents api in eventmesh-connector-api module

* fix checkStyle

* fix checkStyle

* fix checkStyle

* 1.support LifeCycle.java
2.update Consumer and Producer

* fix remove the extra blank line

* support cloudEvents

* Add files via upload

* Update README.md

* support cloudEvents

* support cloudEvents

* [ISSUE apache#580] Add checkstyle gradle plugin (apache#581)

* Add checkstyle gradle plugin, change plugin package

* skip check in ci

* support cloudEvents

* support cloudevents

* update wechat-official qr code

* update mesh-helper qr code

* Add files via upload

* update README.md

* update README.md

* Update .asf.yaml

* support cloudEvents

* support cloudEvents

* [ISSUE apache#588] Fix typo in README.md (apache#589)

close apache#588

* support cloudEvents

* [Bug apache#590] Consumer subscription topic is invalid (apache#590) (apache#592)

* [Bug apache#590] Consumer subscription topic is invalid (apache#590)

* [Bug apache#590] Consumer subscription topic is invalid (apache#590)

close apache#590

* support cloudEvents adaptor

* [Feature apache#562] Implement CloudEvents adaptor

Co-authored-by: Eason Chen <qqeasonchen@gmail.com>
Co-authored-by: Wenjun Ruan <wenjun@apache.org>
Co-authored-by: Nicholas Zhan <zhan_nicholas@outlook.com>
Co-authored-by: hagsyn <44764414+hagsyn@users.noreply.github.com>
…che#597)

* [Feature apache#564] Support CloudEvents protocols for pub/sub in EventMesh-feature design

* support cloudevents api in eventmesh-connector-api module

* fix checkStyle

* fix checkStyle

* fix checkStyle

* 1.support LifeCycle.java
2.update Consumer and Producer

* fix remove the extra blank line

* support cloudEvents

* Add files via upload

* Update README.md

* support cloudEvents

* support cloudEvents

* [ISSUE apache#580] Add checkstyle gradle plugin (apache#581)

* Add checkstyle gradle plugin, change plugin package

* skip check in ci

* support cloudEvents

* support cloudevents

* update wechat-official qr code

* update mesh-helper qr code

* Add files via upload

* update README.md

* update README.md

* Update .asf.yaml

* support cloudEvents

* support cloudEvents

* [ISSUE apache#588] Fix typo in README.md (apache#589)

close apache#588

* support cloudEvents

* [Bug apache#590] Consumer subscription topic is invalid (apache#590) (apache#592)

* [Bug apache#590] Consumer subscription topic is invalid (apache#590)

* [Bug apache#590] Consumer subscription topic is invalid (apache#590)

close apache#590

* support cloudEvents adaptor

* [Feature apache#562] Implement CloudEvents adaptor

* [Feature apache#562] Implement EventMeshMessage protocol adaptor

* supplement apache header

Co-authored-by: Eason Chen <qqeasonchen@gmail.com>
Co-authored-by: Wenjun Ruan <wenjun@apache.org>
Co-authored-by: Nicholas Zhan <zhan_nicholas@outlook.com>
Co-authored-by: hagsyn <44764414+hagsyn@users.noreply.github.com>
* Remove some unused code in sdk module

* Remove some unused code in sdk module
* [Feature apache#564] Support CloudEvents protocols for pub/sub in EventMesh-feature design

* support cloudevents api in eventmesh-connector-api module

* fix checkStyle

* fix checkStyle

* fix checkStyle

* 1.support LifeCycle.java
2.update Consumer and Producer

* fix remove the extra blank line

* support cloudEvents

* Add files via upload

* Update README.md

* support cloudEvents

* support cloudEvents

* [ISSUE apache#580] Add checkstyle gradle plugin (apache#581)

* Add checkstyle gradle plugin, change plugin package

* skip check in ci

* support cloudEvents

* support cloudevents

* update wechat-official qr code

* update mesh-helper qr code

* Add files via upload

* update README.md

* update README.md

* Update .asf.yaml

* support cloudEvents

* support cloudEvents

* [ISSUE apache#588] Fix typo in README.md (apache#589)

close apache#588

* support cloudEvents

* [Bug apache#590] Consumer subscription topic is invalid (apache#590) (apache#592)

* [Bug apache#590] Consumer subscription topic is invalid (apache#590)

* [Bug apache#590] Consumer subscription topic is invalid (apache#590)

close apache#590

* support cloudEvents adaptor

* [Feature apache#562] Implement CloudEvents adaptor

* [Feature apache#562] Implement EventMeshMessage protocol adaptor

* supplement apache header

* 1.update package name
2.support build.gradle and gradle.properties
3.support ProtocolTransportObject

Co-authored-by: Eason Chen <qqeasonchen@gmail.com>
Co-authored-by: Wenjun Ruan <wenjun@apache.org>
Co-authored-by: Nicholas Zhan <zhan_nicholas@outlook.com>
Co-authored-by: hagsyn <44764414+hagsyn@users.noreply.github.com>
* Add protocol producer in sdk

* Refactor callback handler

* Add tcp protocol client
1.update http push request
2.update http in protocol adaptor
* update java sdk

* fix compile error
* update java sdk

* fix compile error

* fix sdk error
* update java sdk

* fix compile error

* fix sdk error

* 1.remove the openmessage from connector-api
2.fix the standalone connector
* update java sdk

* fix compile error

* fix sdk error

1.remove the openmessage from connector-api
2.fix the standalone connector

* 1.fix the standalone connector
2.fix the sdk
1.fix the standalone connector
2.fix eventmeshmessage protocol adaptor for tcp
…apache#619)

1.fix eventmeshmessage protocol adaptor for http with standalone connector
1.cloudevents protocol tcp pub/sub for sdk
1.cloudevents protocol tcp pub/sub for sdk
cloudevents protocol tcp pub/sub for sdk
cloudevents protocol http pub/sub for sdk
 fix cloudevents protocol pub/sub for http sdk
* Add AbstractEventMeshTCPSubHandler
xwm1992 and others added 7 commits December 6, 2021 20:57
…nnector (apache#628)

* fix cloudevents/eventmesh message protocol pub/sub for sdk in rocketmq-connector
…nnector (apache#629)

* fix cloudevents/eventmesh message protocol pub/sub for sdk in rocketmq-connector
fix sync request/response for sdk in rocketmq-connector
… into cloudevents

� Conflicts:
�	README.md
�	eventmesh-common/build.gradle
�	eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/producer/MeshMQProducer.java
�	eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/RocketMQProducerImpl.java
�	eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/producer/StandaloneMeshMQProducerAdaptor.java
�	eventmesh-runtime/build.gradle
�	eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/SubscribeProcessor.java
�	eventmesh-sdk-java/build.gradle
�	eventmesh-spi/build.gradle
�	settings.gradle
�	style/checkStyle.xml
* Add files via upload

* Update README.md

* [ISSUE apache#580] Add checkstyle gradle plugin (apache#581)

* Add checkstyle gradle plugin, change plugin package

* skip check in ci

* update wechat-official qr code

* update mesh-helper qr code

* Add files via upload

* update README.md

* update README.md

* Update .asf.yaml

* [ISSUE apache#588] Fix typo in README.md (apache#589)

close apache#588

* [Bug apache#590] Consumer subscription topic is invalid (apache#590) (apache#592)

* [Bug apache#590] Consumer subscription topic is invalid (apache#590)

* [Bug apache#590] Consumer subscription topic is invalid (apache#590)

close apache#590

* fixed a wrong url in cn-doc (apache#585)

close apache#596

* resolve_exception->Consumer subscription topic is invalid apache#590 (apache#598)

close apache#590

* Update eventmesh-store-quickstart.md

* Update README.md

* Add slack icon (apache#601)

* eventmesh-admin-rocketmq submodule and createTopic REST API (apache#530)

* eventmesh-admin-rocketmq submodule and createTopic draft API

* add license header

* change to /topicmanage

* fix build error

* fix some code check style issues

close apache#435 apache#346

* create topic command (apache#531)

* create topic command

* address review comments

* fix build and add createtopic method to standalone module

* fix build issue

* fix a few remaining code check issues

* fix test

close apache#346

* Update README.md

* Safely delete useless log4j dependencies

* Safely delete outdated metrics dependencies

* Sately delete useless collections4 dependency

* Safely delete useless commons dependencies

* Reback to the collections4, but let it not in api dependency

* Could not remove text for Safe Ramdom implementation

* Fix build error

* Add collection4

* Fix build error

* Revert "Safely delete outdated metrics dependencies"

This reverts commit 92287b0.

* Change to api dependency

* Remove doclint warnings

* Depracated checkstyle check error temporarily, we should remove it when we polish later

* Update .asf.yaml

* Update .asf.yaml

Co-authored-by: Eason Chen <qqeasonchen@gmail.com>
Co-authored-by: Wenjun Ruan <wenjun@apache.org>
Co-authored-by: Nicholas Zhan <zhan_nicholas@outlook.com>
Co-authored-by: hagsyn <44764414+hagsyn@users.noreply.github.com>
Co-authored-by: sarihuangshanrong <280456134@qq.com>
Co-authored-by: yuri <yu.zhao5@huawei.com>
Co-authored-by: vongosling <vongosling@apache.org>
@xwm1992 xwm1992 merged commit 600e255 into apache:develop Dec 9, 2021
xwm1992 added a commit that referenced this pull request Aug 4, 2022
[Feature #564] Support CloudEvents protocols for pub/sub in EventMesh
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants