Skip to content

Commit

Permalink
[Issue apache#718] Fix readme file and protobuf file based on review …
Browse files Browse the repository at this point in the history
…comments
  • Loading branch information
jinrongluo committed Jan 25, 2022
1 parent f0d1b8a commit dad432e
Show file tree
Hide file tree
Showing 3 changed files with 9 additions and 4 deletions.
4 changes: 2 additions & 2 deletions docs/cn/instructions/eventmesh-sdk-java-quickstart.md
Original file line number Diff line number Diff line change
Expand Up @@ -72,8 +72,8 @@ TCP, HTTP 和 GRPC 示例都在**eventmesh-example**模块下

### 3. GRPC 演示

> 对于 GRPC, eventmesh-sdk-java 实现了 Google gRPC 和 Google Protocol Buffers 协议. 它能异步和同步发送事件到 eventmesh-runtime.
> 它可以通过webhook和事件流方式订阅消费事件, 同时也支持Apache CloudEvents 协议.
> eventmesh-sdk-java 实现了 gRPC 协议. 它能异步和同步发送事件到 eventmesh-runtime.
> 它可以通过webhook和事件流方式订阅消费事件, 同时也支持 CNCF CloudEvents 协议.
<h4> 异步事件发送 和 webhook订阅 </h4>

Expand Down
4 changes: 2 additions & 2 deletions docs/en/instructions/eventmesh-sdk-java-quickstart.md
Original file line number Diff line number Diff line change
Expand Up @@ -72,9 +72,9 @@ Run the main method of org.apache.eventmesh.http.demo.pub.eventmeshmessage.Async

### 3. GRPC DEMO

> As to GRPC, eventmesh-sdk-java implements the Google gRPC and Google Protocol Buffers. It can send events to eventmesh-runtime asynchronously
> eventmesh-sdk-java implements the gRPC transport protocol. It can send events to eventmesh-runtime asynchronously
> and synchronously (using request-reply). It can also subscribe to the events using webhook subscriber and stream subscriber.
> Apache CloudEvents protocol is also supported in the demo.
> CNCF CloudEvents protocol is also supported in the demo.
#### Async event publisher and webhook subscriber

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -117,16 +117,21 @@ message Heartbeat {
}

service PublisherService {
// Async event publish
rpc publish(SimpleMessage) returns (Response);

// Sync event publish
rpc requestReply(SimpleMessage) returns (Response);

// Async batch event publish
rpc batchPublish(BatchMessage) returns (Response);
}

service ConsumerService {
// The subscribed event will be delivered by invoking the webhook url in the Subscription
rpc subscribe(Subscription) returns (Response);

// The subscribed event will be delivered through stream of Message
rpc subscribeStream(Subscription) returns (stream SimpleMessage);

rpc unsubscribe(Subscription) returns (Response);
Expand Down

0 comments on commit dad432e

Please sign in to comment.