非自动解码

使用spring扫描实例，实现Listener接口, 添加@MessageListener注解。订阅信息位于@MessageListener注解中。

主题匹配

@Slf4j
@MessageListener(topic = "loki")
@Component
public class TestMessageListener implements Listener<String> {
    @Override
    public void onMessage(MessageContent<String> entity) {
        log.info("entity:{}", entity);
    }
}

主题正则匹配

@Slf4j
@MessageListener(topicPattern = "lo*")
@Component
public class TestMessageListener implements Listener<String> {
    @Override
    public void onMessage(MessageContent<String> entity) {
        log.info("entity:{}", entity);
    }
}

@MessageListener

查看注解说明