英文:
org.apache.camel.FailedToStartRouteException: Failed to start route route1 because of null
问题
@Component
public class HRFeedRoute extends RouteBuilder {
@Override
public final void configure() {
System.out.println("fetching employee details from employee api");
try {
from("http://localhost:8083/getEmployee").startupOrder(1).to("direct:employee")
.log("${body}");
from("direct:employee")
.unmarshal().json(JsonLibrary.Jackson, Employee.class)
.process(
ex -> {
System.out.println(ex);
});
} catch (Error e) {
System.out.println("Error occurred while processing employee data: " + e.getMessage());
}
}
}
org.apache.camel.FailedToStartRouteException: Failed to start route route1 because of null
at org.apache.camel.impl.engine.RouteService.warmUp(RouteService.java:125)
at org.apache.camel.impl.engine.InternalRouteStartupManager.doWarmUpRoutes(InternalRouteStartupManager.java:263)
at org.apache.camel.impl.engine.InternalRouteStartupManager.safelyStartRouteServices(InternalRouteStartupManager.java:156)
at org.apache.camel.impl.engine.InternalRouteStartupManager.doStartOrResumeRoutes(InternalRouteStartupManager.java:114)
at org.apache.camel.impl.engine.AbstractCamelContext.doStartCamel(AbstractCamelContext.java:2809)
at org.apache.camel.impl.engine.AbstractCamelContext.doStartContext(AbstractCamelContext.java:2657)
at org.apache.camel.impl.engine.AbstractCamelContext.doStart(AbstractCamelContext.java:2620)
at org.apache.camel.spring.boot.SpringBootCamelContext.doStart(SpringBootCamelContext.java:43)
at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
at org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2452)
at org.apache.camel.spring.SpringCamelContext.start(SpringCamelContext.java:121)
at org.apache.camel.spring.SpringCamelContext.onApplicationEvent(SpringCamelContext.java:157)
at org.springframework.context.event.SimpleApplicationEventMulticaster.doInvokeListener(SimpleApplicationEventMulticaster.java:172)
at org.springframework.context.event.SimpleApplicationEventMulticaster.invokeListener(SimpleApplicationEventMulticaster.java:165)
at org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:139)
at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:404)
at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:361)
at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:898)
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:554)
at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:143)
at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:758)
at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:750)
at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:397)
at org.springframework.boot.SpringApplication.run(SpringApplication.java:315)
at org.springframework.boot.SpringApplication.run(SpringApplication.java:1237)
at org.springframework.boot.SpringApplication.run(SpringApplication.java:1226)
at au.com.macquarie.hr.application.EmployeePackageBootApp.main(EmployeePackageBootApp.java:13)
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.
@Component
public class HRFeedRoute extends RouteBuilder {
@Override
public final void configure() {
System.out.println("fetching employee details from employee api");
try {
from("http://localhost:8083/getEmployee").startupOrder(1).to("direct:employee")
.log("${body}");
from("direct:employee")
.unmarshal().json(JsonLibrary.Jackson, Employee.class)
.process(
ex -> {
System.out.println(ex);
});
} catch(Error e) {
System.out.println("Error occurred while processing employee data: "+e.getMessage());
}
}
}
org.apache.camel.FailedToStartRouteException: Failed to start route route1 because of null
at org.apache.camel.impl.engine.RouteService.warmUp(RouteService.java:125)
at org.apache.camel.impl.engine.InternalRouteStartupManager.doWarmUpRoutes(InternalRouteStartupManager.java:263)
at org.apache.camel.impl.engine.InternalRouteStartupManager.safelyStartRouteServices(InternalRouteStartupManager.java:156)
at org.apache.camel.impl.engine.InternalRouteStartupManager.doStartOrResumeRoutes(InternalRouteStartupManager.java:114)
at org.apache.camel.impl.engine.AbstractCamelContext.doStartCamel(AbstractCamelContext.java:2809)
at org.apache.camel.impl.engine.AbstractCamelContext.doStartContext(AbstractCamelContext.java:2657)
at org.apache.camel.impl.engine.AbstractCamelContext.doStart(AbstractCamelContext.java:2620)
at org.apache.camel.spring.boot.SpringBootCamelContext.doStart(SpringBootCamelContext.java:43)
at org.apache.camel.support.service.BaseService.start(BaseService.java:115)
at org.apache.camel.impl.engine.AbstractCamelContext.start(AbstractCamelContext.java:2452)
at org.apache.camel.spring.SpringCamelContext.start(SpringCamelContext.java:121)
at org.apache.camel.spring.SpringCamelContext.onApplicationEvent(SpringCamelContext.java:157)
at org.springframework.context.event.SimpleApplicationEventMulticaster.doInvokeListener(SimpleApplicationEventMulticaster.java:172)
at org.springframework.context.event.SimpleApplicationEventMulticaster.invokeListener(SimpleApplicationEventMulticaster.java:165)
at org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:139)
at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:404)
at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:361)
at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:898)
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:554)
at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:143)
at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:758)
at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:750)
at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:397)
at org.springframework.boot.SpringApplication.run(SpringApplication.java:315)
at org.springframework.boot.SpringApplication.run(SpringApplication.java:1237)
at org.springframework.boot.SpringApplication.run(SpringApplication.java:1226)
at au.com.macquarie.hr.application.EmployeePackageBootApp.main(EmployeePackageBootApp.java:13)
Caused by: java.lang.UnsupportedOperationException: Cannot consume from http endpoint
答案1
得分: 2
错误信息的最后一行是关键:
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:
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代码。
ResponseEntity responseEntity = restTemplate.postForEntity(new URI("http://localhost:8084/employee-package/getEmployee"), request, Employee.class);
消费者API路由:
@Component
public class HRFeedRoute extends RouteBuilder {
@Override
public final void configure() {
System.out.println("从员工API获取员工详细信息");
try {
from("jetty://http://localhost:8084/employee-package/getEmployee")
.log("${body}")
.unmarshal().json(JsonLibrary.Jackson, Employee.class)
.process(
ex -> {
Employee employee = (Employee) ex.getIn().getBody();
System.out.println("|" + employee.getEmpId() + " | " + employee.getName() + " | " + employee.getDesignation() + " | " + employee.getSalary());
});
} catch (Error e) {
System.out.println("处理员工数据时出错:" + e.getMessage());
}
}
}
英文:
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 {
@Override
public final void configure() {
System.out.println("fetching employee details from employee api");
try {
from("jetty://http://localhost:8084/employee-package/getEmployee")
.log("${body}")
.unmarshal().json(JsonLibrary.Jackson, Employee.class)
.process(
ex -> {
Employee employee = (Employee) ex.getIn().getBody();
System.out.println("|"+employee.getEmpId()+" | "+employee.getName()+" | "+employee.getDesignation()+" | "+employee.getSalary());
});
} catch(Error e) {
System.out.println("Error occurred while processing employee data: "+e.getMessage());
}
}
}
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库,让每个人都能够通过互相帮助和分享经验来进步。
评论