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 07:34:19 UTC
[rocketmq-spring.wiki] branch master updated: Updated Request reply
message exchange pattern (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 f0a5cbb Updated Request reply message exchange pattern (markdown)
f0a5cbb is described below
commit f0a5cbb8891626b3623242f3eeb15a301b9e41a9
Author: rongtong <ji...@163.com>
AuthorDate: Fri Feb 21 15:34:09 2020 +0800
Updated Request reply message exchange pattern (markdown)
---
Request-reply-message-exchange-pattern.md | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/Request-reply-message-exchange-pattern.md b/Request-reply-message-exchange-pattern.md
index a8bcab4..e950eaa 100644
--- a/Request-reply-message-exchange-pattern.md
+++ b/Request-reply-message-exchange-pattern.md
@@ -74,7 +74,7 @@ public class ConsumerApplication{
* The consumer that replying Object
*/
@Service
- @RocketMQMessageListener(topic = "objectRequestTopic", consumerGroup = "objectRequestConsumer")
+ @RocketMQMessageListener(topic = "objectRequestTopic", consumerGroup = "objectRequestConsumer")
public class ObjectConsumerWithReplyUser implements RocketMQReplyListener<User, User>{
public void onMessage(User user) {
System.out.printf("------- ObjectConsumerWithReplyUser received: %s \n", user);
@@ -83,7 +83,7 @@ public class ConsumerApplication{
}
}
- @Data
+ @Data
@AllArgsConstructor
public class User implements Serializable{
private String userName;