You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by go...@apache.org on 2021/05/10 03:17:18 UTC
[incubator-inlong-website] branch master updated: Update
producer_example page. (#71)
This is an automated email from the ASF dual-hosted git repository.
gosonzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong-website.git
The following commit(s) were added to refs/heads/master by this push:
new 66a5a92 Update producer_example page. (#71)
66a5a92 is described below
commit 66a5a92265606b77409f9152ee8c6b453b4dcbc5
Author: Roc Marshal <64...@users.noreply.github.com>
AuthorDate: Mon May 10 11:17:10 2021 +0800
Update producer_example page. (#71)
---
docs/zh-cn/producer_example.md | 22 ++++++++++------------
1 file changed, 10 insertions(+), 12 deletions(-)
diff --git a/docs/zh-cn/producer_example.md b/docs/zh-cn/producer_example.md
index 9d29451..e71f37d 100644
--- a/docs/zh-cn/producer_example.md
+++ b/docs/zh-cn/producer_example.md
@@ -7,8 +7,8 @@ TubeMQ提供了两种方式来初始化 session factory: TubeSingleSessionFactor
- TubeSingleSessionFactory 在整个生命周期只会创建一个 session
- TubeMultiSessionFactory 每次调用都会创建一个session
-### TubeSingleSessionFactory
- #### Send Message Synchronously
+1. TubeSingleSessionFactory
+ - Send Message Synchronously
```java
public final class SyncProducerExample {
@@ -28,10 +28,10 @@ TubeMQ提供了两种方式来初始化 session factory: TubeSingleSessionFactor
}
messageProducer.shutdown();
}
- }
- ```
+ }
+ ```
- #### Send Message Asynchronously
+ - Send Message Asynchronously
```java
public final class AsyncProducerExample {
@@ -62,10 +62,10 @@ TubeMQ提供了两种方式来初始化 session factory: TubeSingleSessionFactor
messageProducer.shutdown();
}
- }
- ```
+ }
+ ```
- #### Send Message With Attributes
+ - Send Message With Attributes
```java
public final class ProducerWithAttributeExample {
@@ -87,11 +87,9 @@ TubeMQ提供了两种方式来初始化 session factory: TubeSingleSessionFactor
messageProducer.sendMessage(message);
messageProducer.shutdown();
}
-
- }
- ```
+ }```
-### TubeMultiSessionFactory
+- TubeMultiSessionFactory
```java
public class MultiSessionProducerExample {