Это мой фрагмент кода
@Bean
@ServiceActivator(inputChannel = "topicChannel", outputChannel="responseChannel")
public Employee getEmpDetails() throws Exception {
Expression query = new LiteralExpression("{'name' : '*****'}");
MongoDbMessageSource source = new MongoDbMessageSource(mongoDbFactory(), query);
source.setEntityClass(Employee.class);
source.afterPropertiesSet();
List<Employee> resluts =((List<Employee>)source.receive().getPayload());
return resluts.get(0);
}
Ниже приведена ошибка
Вы также должны определить
как _2_, чтобы он правильно инициализировался фреймворком; вызова _3_ недостаточно.@Bean @ServiceActivator(inputChannel = "topicChannel", outputChannel="responseChannel") public Employee getEmpDetails() throws Exception { Expression query = new LiteralExpression("{'name' : '*****'}"); MongoDbMessageSource source = new MongoDbMessageSource(mongoDbFactory(), query); source.setEntityClass(Employee.class); source.afterPropertiesSet(); List<Employee> resluts =((List<Employee>)source.receive().getPayload()); return resluts.get(0); }
