Update code blocks in documents

TeslaCN · Feb 22, 2021 · 961f71b · 961f71b
1 parent 4dd468c
commit 961f71b
Show file tree

Hide file tree

Showing 2 changed files with 23 additions and 23 deletions.
diff --git a/README.md b/README.md
@@ -33,7 +33,7 @@ Elder version's groupId is `vip.wuweijie.camel`, which can be found in:
 
 ### Basic Usage
 
-```
+```java
 from("rocketmq:from_topic?namesrvAddr=localhost:9876&consumerGroup=consumer")
     .to("rocketmq:to_topic?namesrvAddr=localhost:9876&producerGroup=producer");
 ```
@@ -49,7 +49,7 @@ When a message from `ReplyToTpic` contains the key, it means that the reply rece
 
 If `requestTimeout` elapsed and no reply received, an exception will be thrown.
 
-```
+```java
 from("rocketmq:{{inout.rocketmq.topic.from}}?namesrvAddr={{rocketmq.namesrv.addr}}" +
         "&consumerGroup={{inout.rocketmq.consumer.group}}" +
         "&requestTimeout=10000")
@@ -97,7 +97,7 @@ Notice: **In InOut pattern, the message won't be routed until reply received.**
 | `RocketMQConstants.OVERRIDE_TAG` | `rocketmq.OVERRIDE_TAG` | Override the message's Tag |
 | `RocketMQConstants.OVERRIDE_MESSAGE_KEY` | `rocketmq.OVERRIDE_MESSAGE_KEY` | Set the message's Key |
 
-```
+```java
 from("rocketmq:{{override.rocketmq.topic.from}}?namesrvAddr={{rocketmq.namesrv.addr}}&consumerGroup={{override.rocketmq.consumer.group}}")
         .process(exchange -> {
             exchange.getMessage().setHeader(RocketMQConstants.OVERRIDE_TOPIC_NAME, "OVERRIDE_TO");

diff --git a/README_ZH.md b/README_ZH.md
@@ -33,9 +33,9 @@ Maven:
 
 ### 基本使用
 
-```
+```java
 from("rocketmq:from_topic?namesrvAddr=localhost:9876&consumerGroup=consumer")
-    .to("rocketmq:to_topic?namesrvAddr=localhost:9876&producerGroup=producer");
+        .to("rocketmq:to_topic?namesrvAddr=localhost:9876&producerGroup=producer");
 ```
 
 ### InOut 模式
@@ -48,17 +48,17 @@ Producer 消息发送后，启动一个 Consumer 监听 `ReplyToTopic` 参数配
 
 如果超过 `requestTimeout` 毫秒后仍然没有收到 Reply，则抛出异常。
 
-```
-from("rocketmq:{{inout.rocketmq.topic.from}}?namesrvAddr={{rocketmq.namesrv.addr}}" +
-        "&consumerGroup={{inout.rocketmq.consumer.group}}" +
+```java
+from("rocketmq:{{inout.rocketmq.topic.from}}?namesrvAddr={{rocketmq.namesrv.addr}}"+
+        "&consumerGroup={{inout.rocketmq.consumer.group}}"+
         "&requestTimeout=10000")
-
-.inOut("rocketmq:{{inout.rocketmq.topic.to}}?namesrvAddr={{rocketmq.namesrv.addr}}" +
-        "&producerGroup={{inout.rocketmq.producer.group}}" +
-        "&replyToTopic={{inout.rocketmq.reply.to.topic}}" +
-        "&requestTimeout={{inout.request.timeout}}" +
+        
+        .inOut("rocketmq:{{inout.rocketmq.topic.to}}?namesrvAddr={{rocketmq.namesrv.addr}}"+
+        "&producerGroup={{inout.rocketmq.producer.group}}"+
+        "&replyToTopic={{inout.rocketmq.reply.to.topic}}"+
+        "&requestTimeout={{inout.request.timeout}}"+
         "&replyToConsumerGroup={{inout.rocketmq.reply.to.consumer}}"
-)
+        )
 
 .to("log:InOutRoute?showAll=true")
 ```
@@ -96,17 +96,17 @@ from("rocketmq:{{inout.rocketmq.topic.from}}?namesrvAddr={{rocketmq.namesrv.addr
 | `RocketMQConstants.OVERRIDE_TAG` | `rocketmq.OVERRIDE_TAG` | 覆盖路由配置的消息 Tag |
 | `RocketMQConstants.OVERRIDE_MESSAGE_KEY` | `rocketmq.OVERRIDE_MESSAGE_KEY` | 设置消息 Key |
 
-```
+```java
 from("rocketmq:{{override.rocketmq.topic.from}}?namesrvAddr={{rocketmq.namesrv.addr}}&consumerGroup={{override.rocketmq.consumer.group}}")
-        .process(exchange -> {
-            exchange.getMessage().setHeader(RocketMQConstants.OVERRIDE_TOPIC_NAME, "OVERRIDE_TO");
-            exchange.getMessage().setHeader(RocketMQConstants.OVERRIDE_TAG, "OVERRIDE_TAG");
-            exchange.getMessage().setHeader(RocketMQConstants.OVERRIDE_MESSAGE_KEY, "OVERRIDE_MESSAGE_KEY");
+        .process(exchange->{
+        exchange.getMessage().setHeader(RocketMQConstants.OVERRIDE_TOPIC_NAME,"OVERRIDE_TO");
+        exchange.getMessage().setHeader(RocketMQConstants.OVERRIDE_TAG,"OVERRIDE_TAG");
+        exchange.getMessage().setHeader(RocketMQConstants.OVERRIDE_MESSAGE_KEY,"OVERRIDE_MESSAGE_KEY");
         }
-)
-.to("rocketmq:{{override.rocketmq.topic.to}}"
-                + "?namesrvAddr={{rocketmq.namesrv.addr}}"
-                + "&producerGroup={{override.rocketmq.producer.group}}"
+        )
+        .to("rocketmq:{{override.rocketmq.topic.to}}"
+        +"?namesrvAddr={{rocketmq.namesrv.addr}}"
+        +"&producerGroup={{override.rocketmq.producer.group}}"
 )
 .to("log:RocketRoute?showAll=true")
 ```