Я изучаю Spring Cloud Streams с нуля.
Я пытался создать приложение Source следующим образом:
import org.springframework.cloud.stream.messaging.Source; //etc
@RestController
@SpringBootApplication
@CrossOrigin
@EnableBinding(Source.class)
public class StreamsProducerApplication {
@Autowired
Source source;
@GetMapping(value="/send/{message}")
public void sendMessage(@PathVariable String message){
if(message != null){
source.output().send(MessageBuilder.withPayload(message).build());}
}
public static void main(String[] args) {
SpringApplication.run(StreamsProducerApplication.class, args);
}
}
Однако я получаю подсказку об ошибкеот Intellij IDEA в "Source source;"говоря: «Не удалось автоматически подключить. Не найдены bean-компоненты типа« Source ».
Я понимаю, что Source - это интерфейс, из которого я импортирую, но на официальном веб-сайте Spring Spring говорится, что Spring Cloud Stream создает реализацию интерфейса.для тебя.Вы можете использовать это в приложении, автоматически подключив его "https://docs.spring.io/spring-cloud-stream/docs/current/reference/htmlsingle/
Так как же я сделал это неправильно? Спасибо.