@ SpringBootApplication
открытый класс ReactiveCouchbaseExample1Application {
@Bean
CommandLineRunner employees(ApplicationContext context) {
EmployeeRepository repository = context.getBean(EmployeeRepository.class);
return args -> {
repository
.deleteAll()
.subscribe(null,null,()->{
Stream.of(new Employees(UUID.randomUUID().toString(), "Nikhil", 23, 3000L),
new Employees(UUID.randomUUID().toString(), "Shubham", 23, 3000L),
new Employees(UUID.randomUUID().toString(), "Anshul", 23, 3000L))
.forEach(employee->{
repository.save(employee)
.subscribe(System.out::println);
});
});
};
}
public static void main(String[] args) {
SpringApplication.run(ReactiveCouchbaseExample1Application.class, args);
}
Я хочу запустить этот фрагмент логики, как только мой прикладной контекст загрузится, но когда я запустил свое приложение, он показывает эту ошибку.
Method employees in com.reactive.reactivecouchbaseexample1.ReactiveCouchbaseExample1Application required a bean of type 'com.reactive.repository.EmployeeRepository' that could not be found.
Может кто-нибудь сказать мне, как я могу создать компонент репозитория внутри CommandLineRunner.
Я тоже погуглил, но не смог найти ответов.
Это мой репозиторий
@Repository
public interface EmployeeRepository extends
ReactiveCouchbaseRepository<Employees, String>{
}