org.apache.camel.FailedToStartRouteException: 由于空值原因，无法启动route1路由。

huangapple
go评论193阅读模式
英文:

org.apache.camel.FailedToStartRouteException: Failed to start route route1 because of null

问题

  1. @Component
  2. public class HRFeedRoute extends RouteBuilder {
  4.     @Override
  5.     public final void configure() {
  6.         System.out.println("fetching employee details from employee api");
  7.         try {
  8.             from("http://localhost:8083/getEmployee").startupOrder(1).to("direct:employee")
  9.                 .log("${body}");
  11.             from("direct:employee")
  12.                 .unmarshal().json(JsonLibrary.Jackson, Employee.class)
  13.                 .process(
  14.                     ex -> {
  15.                         System.out.println(ex);
  16.                     });
  18.         } catch (Error e) {
  19.             System.out.println("Error occurred while processing employee data: " + e.getMessage());
  20.         }
  21.     }
  22. }
  1. org.apache.camel.FailedToStartRouteException: Failed to start route route1 because of null
  2.     at org.apache.camel.impl.engine.RouteService.warmUp(RouteService.java:125)
  3.     at org.apache.camel.impl.engine.InternalRouteStartupManager.doWarmUpRoutes(InternalRouteStartupManager.java:263)
  4.     at org.apache.camel.impl.engine.InternalRouteStartupManager.safelyStartRouteServices(InternalRouteStartupManager.java:156)
  5.     at org.apache.camel.impl.engine.InternalRouteStartupManager.doStartOrResumeRoutes(InternalRouteStartupManager.java:114)
  6.     at org.apache.camel.impl.engine.AbstractCamelContext.doStartCamel(AbstractCamelContext.java:2809)
  7.     at org.apache.camel.impl.engine.AbstractCamelContext.doStartContext(AbstractCamelContext.java:2657)
  8.     at org.apache.camel.impl.engine.AbstractCamelContext.doStart(AbstractCamelContext.java:2620)
  9.     at org.apache.camel.spring.boot.SpringBootCamelContext.doStart(SpringBootCamelContext.java:43)
  10.     at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
  11.     at org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2452)
  12.     at org.apache.camel.spring.SpringCamelContext.start(SpringCamelContext.java:121)
  13.     at org.apache.camel.spring.SpringCamelContext.onApplicationEvent(SpringCamelContext.java:157)
  14.     at org.springframework.context.event.SimpleApplicationEventMulticaster.doInvokeListener(SimpleApplicationEventMulticaster.java:172)
  15.     at org.springframework.context.event.SimpleApplicationEventMulticaster.invokeListener(SimpleApplicationEventMulticaster.java:165)
  16.     at org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:139)
  17.     at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:404)
  18.     at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:361)
  19.     at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:898)
  20.     at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:554)
  21.     at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:143)
  22.     at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:758)
  23.     at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:750)
  24.     at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:397)
  25.     at org.springframework.boot.SpringApplication.run(SpringApplication.java:315)
  26.     at org.springframework.boot.SpringApplication.run(SpringApplication.java:1237)
  27.     at org.springframework.boot.SpringApplication.run(SpringApplication.java:1226)
  28.     at au.com.macquarie.hr.application.EmployeePackageBootApp.main(EmployeePackageBootApp.java:13)
  29. Caused by: java.lang.UnsupportedOperationException: Cannot consume from http endpoint
英文:

I am new to apache camel. I am trying to consume json, convert it into java object and write it in CSV file with pipe delimiter. However I am getting error while trying to consume the json from another api's endpoint. I am using spring boot to achieve this task.

Attached the sample code which I am trying.

  1. @Component
  2. public class HRFeedRoute extends RouteBuilder {
  4. 	@Override
  5.     public final void configure() {
  6.     	System.out.println("fetching employee details from employee api");
  7.     	try {
  8.     		from("http://localhost:8083/getEmployee").startupOrder(1).to("direct:employee")
  9.     		.log("${body}");
  10.     				
  11.     		from("direct:employee")
  12.             .unmarshal().json(JsonLibrary.Jackson, Employee.class)
  13.             .process(
  14. 					ex -> {
  15. 	                    System.out.println(ex);
  16. 	                });
  17.             
  18.     	} catch(Error e) {
  19.     		System.out.println("Error occurred while processing employee data: "+e.getMessage());
  20.     	}
  21.     }
  22. }
  1. org.apache.camel.FailedToStartRouteException: Failed to start route route1 because of null
  2. 	at org.apache.camel.impl.engine.RouteService.warmUp(RouteService.java:125)
  3. 	at org.apache.camel.impl.engine.InternalRouteStartupManager.doWarmUpRoutes(InternalRouteStartupManager.java:263)
  4. 	at org.apache.camel.impl.engine.InternalRouteStartupManager.safelyStartRouteServices(InternalRouteStartupManager.java:156)
  5. 	at org.apache.camel.impl.engine.InternalRouteStartupManager.doStartOrResumeRoutes(InternalRouteStartupManager.java:114)
  6. 	at org.apache.camel.impl.engine.AbstractCamelContext.doStartCamel(AbstractCamelContext.java:2809)
  7. 	at org.apache.camel.impl.engine.AbstractCamelContext.doStartContext(AbstractCamelContext.java:2657)
  8. 	at org.apache.camel.impl.engine.AbstractCamelContext.doStart(AbstractCamelContext.java:2620)
  9. 	at org.apache.camel.spring.boot.SpringBootCamelContext.doStart(SpringBootCamelContext.java:43)
  10. 	at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
  11. 	at org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2452)
  12. 	at org.apache.camel.spring.SpringCamelContext.start(SpringCamelContext.java:121)
  13. 	at org.apache.camel.spring.SpringCamelContext.onApplicationEvent(SpringCamelContext.java:157)
  14. 	at org.springframework.context.event.SimpleApplicationEventMulticaster.doInvokeListener(SimpleApplicationEventMulticaster.java:172)
  15. 	at org.springframework.context.event.SimpleApplicationEventMulticaster.invokeListener(SimpleApplicationEventMulticaster.java:165)
  16. 	at org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:139)
  17. 	at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:404)
  18. 	at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:361)
  19. 	at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:898)
  20. 	at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:554)
  21. 	at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:143)
  22. 	at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:758)
  23. 	at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:750)
  24. 	at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:397)
  25. 	at org.springframework.boot.SpringApplication.run(SpringApplication.java:315)
  26. 	at org.springframework.boot.SpringApplication.run(SpringApplication.java:1237)
  27. 	at org.springframework.boot.SpringApplication.run(SpringApplication.java:1226)
  28. 	at au.com.macquarie.hr.application.EmployeePackageBootApp.main(EmployeePackageBootApp.java:13)
  29. Caused by: java.lang.UnsupportedOperationException: Cannot consume from http endpoint

答案1

得分: 2

错误信息的最后一行是关键：

  1. Caused by: java.lang.UnsupportedOperationException: 无法从 http 端点消费

[camel-http] 1 和 [camel-http4] 2（适用于 Camel 2.x）只能用作生产者，而不能用作消费者。

你需要使用例如 [camel-jetty] 3，它可以消费 http 请求。

英文:

The last line of the error message is the key:

  1. Caused by: java.lang.UnsupportedOperationException: Cannot consume from http endpoint

camel-http and camel-http4 (for Camel 2.x) are only usable as producer, but not as consumer.

You need to use for example camel-jetty that can consume http requests.

答案2

得分: 0

以下是翻译好的内容：

我找到了答案。
Jetty将公开一个端点URL，生产者将使用该URL发送JSON/消息。因此，在生产者中添加Jetty公开的端点URL。
在pom.xml中添加camel-jetty-starter依赖项。
生产者：
假设您已经知道REST API将如何将消息发布到另一个API。因此，我只会分享来自控制器的postEntity代码。

  1. ResponseEntity responseEntity = restTemplate.postForEntity(new URI("http://localhost:8084/employee-package/getEmployee"), request, Employee.class);

消费者API路由：

  1. @Component
  2. public class HRFeedRoute extends RouteBuilder {
  4.     @Override
  5.     public final void configure() {
  6.         System.out.println("从员工API获取员工详细信息");
  7.         try {
  9.             from("jetty://http://localhost:8084/employee-package/getEmployee")
  10.             .log("${body}")
  11.             .unmarshal().json(JsonLibrary.Jackson, Employee.class)
  12.             .process(
  13.                 ex -> {
  14.                     Employee employee = (Employee) ex.getIn().getBody();
  15.                     System.out.println("|" + employee.getEmpId() + " | " + employee.getName() + " | " + employee.getDesignation() + " | " + employee.getSalary());
  16.                 });
  18.         } catch (Error e) {
  19.             System.out.println("处理员工数据时出错：" + e.getMessage());
  20.         }
  21.     }
  22. }
英文:

I found the answer.
Jetty will expose an end point URL which will be used by the producer to send the json/message. So add the end poin url exposed by jetty in the producer.
Add camel-jetty-starter dependency in the pom.xml
Producer:
Assuming that you are aware of how the rest api will post the message to another api. Hence, I am just sharing the postEntity code from the controller.

ResponseEntity responseEntity = restTemplate.postForEntity(new URI("http://localhost:8084/employee-package/getEmployee"), request, Employee.class);

Consumer API Router:

@Component
public class HRFeedRoute extends RouteBuilder {

  1. @Override
  2. public final void configure() {
  3. System.out.println("fetching employee details from employee api");
  4. try {
  5. from("jetty://http://localhost:8084/employee-package/getEmployee")
  6. .log("${body}")
  7. .unmarshal().json(JsonLibrary.Jackson, Employee.class)
  8. .process(
  9. ex -> {
  10. Employee employee = (Employee) ex.getIn().getBody();
  11. System.out.println("|"+employee.getEmpId()+" | "+employee.getName()+" | "+employee.getDesignation()+" | "+employee.getSalary());
  12. });
  13. } catch(Error e) {
  14. System.out.println("Error occurred while processing employee data: "+e.getMessage());
  15. }
  16. }

}

huangapple
  • 本文由 发表于 2020年9月9日 19:55:14
  • 转载请务必保留本文链接：https://go.coder-hub.com/63811152.html
  • apache-camel
  • java
  • spring-boot
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定