|
8 年之前 | |
---|---|---|
.. | ||
hsweb-message-api | 8 年之前 | |
hsweb-message-jms | 8 年之前 | |
hsweb-message-memory | 8 年之前 | |
hsweb-message-redis | 8 年之前 | |
hsweb-message-websocket | 8 年之前 | |
README.md | 8 年之前 | |
pom.xml | 8 年之前 |
##API
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.<TextMessage>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.<TextMessage>subscribe(queue("test_topic"))
.onMessage(textMsg->System.out.println(textMsg.getMessage()));
}