You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ji...@apache.org on 2020/02/21 08:26:08 UTC
[rocketmq-spring.wiki] branch master updated: Updated 请求 应答语义支持 (markdown)
This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-spring.wiki.git
The following commit(s) were added to refs/heads/master by this push:
new f997484 Updated 请求 应答语义支持 (markdown)
f997484 is described below
commit f9974843a47cdc6c5b9c214fe2f6360e5e5156f6
Author: rongtong <ji...@163.com>
AuthorDate: Fri Feb 21 16:26:06 2020 +0800
Updated 请求 应答语义支持 (markdown)
---
...224\347\255\224\350\257\255\344\271\211\346\224\257\346\214\201.md" | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git "a/\350\257\267\346\261\202-\345\272\224\347\255\224\350\257\255\344\271\211\346\224\257\346\214\201.md" "b/\350\257\267\346\261\202-\345\272\224\347\255\224\350\257\255\344\271\211\346\224\257\346\214\201.md"
index e185bb7..55d384c 100644
--- "a/\350\257\267\346\261\202-\345\272\224\347\255\224\350\257\255\344\271\211\346\224\257\346\214\201.md"
+++ "b/\350\257\267\346\261\202-\345\272\224\347\255\224\350\257\255\344\271\211\346\224\257\346\214\201.md"
@@ -23,7 +23,8 @@ public class ProducerApplication implements CommandLineRunner{
public void run(String... args) throws Exception {
// 同步发送request并且等待String类型的返回值
String replyString = rocketMQTemplate.sendAndReceive("stringRequestTopic", "request string", String.class);
-
+ System.out.printf("send %s and receive %s %n", "request string", replyString);
+
// 异步发送request并且等待User类型的返回值
rocketMQTemplate.sendAndReceive("objectRequestTopic", new User("requestUserName",(byte) 9), new RocketMQLocalRequestCallback<User>() {
@Override public void onSuccess(User message) {