- package cn.hhj.channel;
- import org.springframework.cloud.stream.annotation.Input;
- import org.springframework.messaging.SubscribableChannel;
- public interface InputProcess {
- public static final String INPUT = "QingSe_input"; // 输入通道名称
- @Input(InputProcess.INPUT)
- public SubscribableChannel input();
- }
|