-
Notifications
You must be signed in to change notification settings - Fork 635
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
[Issue #417] Grpc Transport Protocol support #701
Conversation
… into develop � Conflicts: � README.md
* 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 <[email protected]>
…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 <[email protected]>
…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 <[email protected]> Co-authored-by: Wenjun Ruan <[email protected]> Co-authored-by: Nicholas Zhan <[email protected]> Co-authored-by: hagsyn <[email protected]>
…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 <[email protected]> Co-authored-by: Wenjun Ruan <[email protected]> Co-authored-by: Nicholas Zhan <[email protected]> Co-authored-by: hagsyn <[email protected]>
* 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 <[email protected]> Co-authored-by: Wenjun Ruan <[email protected]> Co-authored-by: Nicholas Zhan <[email protected]> Co-authored-by: hagsyn <[email protected]>
* 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
* 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
1.fix the standalone connector 2.fix eventmeshmessage protocol adaptor for tcp
…apache#619) 1.fix eventmeshmessage protocol adaptor for http with standalone connector
* gradle * Anonymous new Runnable() can be replaced with lambda * Anonymous new Runnable() can be replaced with lambda * add logger print exception
…ache#678) * translate English to Chinese close apache#677
[Minor apache#405] update cloudevents examples
Bump gradle version to 7.3.3 to Support Java17 build
…#695) * Change the default merge strategy to squash close apache#692
… en & cn (apache#698) * update eventmesh-runtime-quickstart-with-docker.md en & cn close apache#673
# Conflicts: # eventmesh-examples/src/main/java/org/apache/eventmesh/http/demo/pub/eventmeshmessage/SyncRequestInstance.java # eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/CloudEventsProtocolAdaptor.java
Due to too many merge conflicts between grpc branch and Master branch. I am not able to merge my own grpc-dev directly. I suggest abandon current grpc branch, recreate a new grpc branch from Master. Then my grpc-dev branch can merge in. Thanks. |
I will close this pull request now, and reopen it soon until a new grpc branch check out from the master. |
It seems ok now. |
Fixes ISSUE #417
Motivation
Support GRPC transport protocol in Eventmensh Runtime and Java SDK.
Modifications
Adding the following GRPC API support:
GRPC Request and Reply
GRPC Batch Publish
GRPC Subscribe and Unsubscribe
GRPC heartbeat
GRPC CloudEvents support
Documentation