初始化

xuekang

2024-05-10 edf3b7fde038fcf3e6d86b8b4b88c2ff6f9014cf

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
package org.dromara.stream.mq.consumer;
 
import org.dromara.stream.mq.TestMessaging;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;
 
import java.util.function.Consumer;
 
@Slf4j
@Component
public class TestStreamConsumer {
 
    @Bean
    Consumer<TestMessaging> demo() {
        log.info("初始化订阅");
        return msg -> {
            log.info("通过stream消费到消息 => {}", msg.toString());
        };
    }
 
}