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(); }