File tree Expand file tree Collapse file tree 1 file changed +20
-0
lines changed
api-boot-samples/api-boot-sample-message-pipe-server/src/main/java/org/minbox/framework/api/boot/sample/message/pipe/server Expand file tree Collapse file tree 1 file changed +20
-0
lines changed Original file line number Diff line number Diff line change 1+ package org .minbox .framework .api .boot .sample .message .pipe .server ;
2+
3+ import lombok .extern .slf4j .Slf4j ;
4+ import org .minbox .framework .message .pipe .server .processing .pop .PopMessageEvent ;
5+ import org .springframework .context .ApplicationListener ;
6+ import org .springframework .stereotype .Component ;
7+
8+ /**
9+ * The {@link PopMessageEvent} sample
10+ *
11+ * @author 恒宇少年
12+ */
13+ @ Component
14+ @ Slf4j
15+ public class PopMessageSampleListener implements ApplicationListener <PopMessageEvent > {
16+ @ Override
17+ public void onApplicationEvent (PopMessageEvent event ) {
18+ log .info ("消息管道:{},获取左面第一个消息." , event .getPipeName ());
19+ }
20+ }
You can’t perform that action at this time.
0 commit comments