diff --git a/hsweb-message/README.md b/hsweb-message/README.md index a67da5236..fc9ccf35a 100644 --- a/hsweb-message/README.md +++ b/hsweb-message/README.md @@ -1 +1,39 @@ -## 消息模块,整合jms,email,sms等消息收发功能 \ No newline at end of file +## 消息模块,提供简单的消息收发功能 + +1. [hsweb-message-api](hsweb-message-api) API +2. [hsweb-message-jms](hsweb-message-jms) JMS实现 +3. [hsweb-message-memory](hsweb-message-memory) 内存实现 +4. [hsweb-message-redis](hsweb-message-redis) Redis实现(redisson) +5. [hsweb-message-websocket](hsweb-message-websocket) 使用websocket进行消息推送 + + +##API +```java +import static org.hswebframework.web.message.builder.StaticMessageBuilder.object; +import static org.hswebframework.web.message.builder.StaticMessageSubjectBuilder.queue; +import static org.hswebframework.web.message.builder.StaticMessageSubjectBuilder.topic; + +@Autowired +private Messager messager; + +public void sendToQueue(){ + messager.publish(text("hello queue!")) + .to(queue("test_queue")) + .send(); +} + +public void subscribeQueue(){ + messager.subscribe(queue("test_queue")) + .onMessage(textMsg->System.out.println(textMsg.getMessage())); + +public void sendToTopic(){ + messager.publish(text("hello topic!")) + .to(queue("test_topic")) + .send(); +} + +public void subscribeTopic(){ + messager.subscribe(queue("test_topic")) + .onMessage(textMsg->System.out.println(textMsg.getMessage())); +} +``` \ No newline at end of file diff --git a/hsweb-message/hsweb-message-api/src/main/java/org/hswebframework/web/message/Messager.java b/hsweb-message/hsweb-message-api/src/main/java/org/hswebframework/web/message/Messager.java index fec04703d..a40e52a2b 100644 --- a/hsweb-message/hsweb-message-api/src/main/java/org/hswebframework/web/message/Messager.java +++ b/hsweb-message/hsweb-message-api/src/main/java/org/hswebframework/web/message/Messager.java @@ -23,23 +23,13 @@ package org.hswebframework.web.message; *
  *     messager
  *     .publish(text("hello"))
- *     .from(system())
  *     .to(user("admin"))
  *     .send();
  * 
- * service invoke - *
- *    User admin = messager
- *     .publish(service("userService"))
- *     .from(system())
- *     .to(method("getById","admin"))
- *     .send();
- * 
* send object to topic *
  *     messager
  *     .publish(object(user))
- *     .from(system())
  *     .to(topic("user-login"))
  *     .send();
  *