在java中，从camel导入的" from“在哪里？
在Java中，从Camel导入的"from"位于org.apache.camel包中。Camel是一个开源的集成框架，用于实现企业级的消息路由、转换和中介。"from"是Camel中的一个关键字，用于指定消息的来源。它可以用于从不同的数据源（如文件、数据库、消息队列等）接收消息，并将其传递给Camel路由的下一个步骤进行处理。通过使用"from"关键字，开发人员可以轻松地定义消息的来源和路由规则，实现灵活且可扩展的集成解决方案。
在腾讯云的产品中，与Camel类似的是腾讯云的消息队列产品-消息队列CMQ。消息队列CMQ是一种高可靠、高可用的消息队列服务，可帮助用户实现分布式系统之间的异步通信。用户可以通过消息队列CMQ轻松地将消息从一个应用程序传递到另一个应用程序，实现解耦和异步处理。您可以通过以下链接了解更多关于腾讯云消息队列CMQ的信息：https://cloud.tencent.com/product/cmq
相关·内容
1回答
我使用的是带有blueprint的apache camel v2.12。在我的一个路由中，我公开了一个jetty端点，它通过POST请求使用xml。我想根据xsd文件验证入站xml，该文件位于另一个包的根目录中。我已经在我的pom文件和features.xml中指定的包中包含了该依赖项。
下面是我的路由定义：
<camel:route id="someId">
<camel:from uri="{{jetty.uri}}"/>
<camel:to uri="validator:/sample.
浏览 13提问于2017-02-26得票数 0
1回答
我试图复制下面的中给出的相同示例。
import javax.sql.DataSource;
import org.apache.camel.main.Main;
import org.apache.camel.builder.RouteBuilder;
import org.apache.commons.dbcp.BasicDataSource;
public class JDBCExample {
private Main main;
public static void main(String[] args) throws Exception {
浏览 1提问于2020-02-26得票数 0
回答已采纳
2回答
驼峰路由错误
、、、
我正在尝试用camel创建一个简单的路由，从rest uri接收消息并将消息存储在缓存中，我已经完成了以下操作。
我的路线如下
<camel:endpoint id="fooCache1" uri="cache:TestCache1"/> <camel:from uri="cxfrs://bean://rsServer" />
<camel:to uri="log:output?showAll=true" />
<camel:to uri="bea
浏览 5提问于2013-10-18得票数 0
DistributeOrderXML.java
public static void main(String[] args) throws Exception{
ApplicationContext appContext = new ClassPathXmlApplicationContext("SpringRouteContext.xml");
CamelContext camelContext = SpringCamelContext.springCamelContext(appContext, false);
try {
ca
浏览 3提问于2020-05-15得票数 5
回答已采纳
1回答
我对ServiceMix中的依赖项有一个问题。
我试着做一个捆绑包。此捆绑包有几个导入：
Import-Package =
org.apache.camel;version="[2.16,3)",
org.apache.camel.builder;version="[2.16,3)",
org.apache.camel.osgi;version="[2.16,3)",
org.springframework.cglib.core,
org.springframewor
浏览 18提问于2018-01-11得票数 0
在ServiceMix中是否可以安装驼峰属性组件功能？因为我找不到它，所以我无法加载我的OSGi包。
Caused by: java.lang.ClassNotFoundException:
org.apache.camel.component.properties.PropertiesComponent not found from bundle [my-camel-osgi-bundle]
如何在Apache ServiceMix中安装Camel Properties组件功能？
提前谢谢你！
浏览 0提问于2013-08-20得票数 0
2回答
骆驼下载文件
、、
我可能有一个愚蠢的问题，但我如何可以下载文件从ftp服务器。我用这条路
.from("ftp:/test@localhost:21/?password=test") .to("file:/d:\test")
我有错误:不能存储空体。为什么？我读过几个例子，我的错误在哪里？谢谢
编辑
我用的路线是：
File://d：\inbox“)；(”.from:xx“) .from("") .to
我有个错误：
org.apache.camel.component.file.GenericFileOperationFailedExceptio
浏览 2提问于2017-05-31得票数 0
我正在进行一个项目，在该项目中，我使用骆驼路由( camel -sql)从MariaDB数据库中获取数据。我在蓝图文件中使用作为数据资源。当我使用mvn:camel运行来运行开发中的项目时，它工作得非常好。
当我试图在Karaf上部署这个项目时，问题就开始了。mvn:install生成所需的jar，其中包含正确的蓝图文件和清单文件。我将此复制到Karaf中的deploy文件夹中。
包安装是成功的。但它并没有开始。我得到了一个异常，它说包无法检测到MariaDB java客户机。这对我来说没有意义，因为我已经安装了它(使用bundle:install -s mvn：.)在卡拉夫身上。我这样做是为
浏览 10提问于2022-10-19得票数 0
回答已采纳
我使用apache camel的XMPP组件来使用Openfire服务器发送消息。但是，当生成身份存储证书时，服务的调用将返回一个错误，而当我从明火中删除该证书时，该服务将完美地工作！下面是Openfire中证书商店的屏幕截图：
代码：
package com.example.ChatServiceProject;
import java.io.InputStream;
import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.
浏览 15提问于2021-12-06得票数 0
我创建了一个Karaf档案馆，里面有几个包。在ServiceMix中部署这个归档文件时，我可以确认每个包都已正确安装(它们的状态在Active上)。然而，在使用它时，会引发一个NoClassDefFoundError：
org.apache.camel.CamelExecutionException: Exception occurred during execution on the exchange: Exchange[ID-0363932-55444-1456402276950-1-78][org.apache.camel.component.file.GenericFileMessag
浏览 8提问于2016-02-25得票数 0
回答已采纳
我刚刚在一个现有项目上从2.0迁移到Play Framework2.1-RC1，由于某种原因，当我呈现视图时，我现在必须将Java类中的所有内容都转换为Scala类。(显然，我在Java项目中使用Play，而不是在Scala项目中)
下面是一个示例错误...
render(java.lang.String,scala.collection.immutable.List<models.User>) in views.html.list cannot be applied to (java.lang.String,java.util.List<models.User>)
我
浏览 0提问于2012-12-01得票数 1
回答已采纳
我正在尝试将csv文件导入到xml文件 我看到apache有一些功能要做 from(in)
.to(out)
.split(body().tokenize("\n")).streaming()
.unmarshal().csv(); 但是我有一个"cannot resolve method 'from(java.lang.String)‘错误 当我尝试导入时，我找不到任何camel包 这个可以用： import org.apache.camel.dataformat
浏览 43提问于2019-01-04得票数 1
回答已采纳
问题
我发现了一些奇怪的行为，Spring Jaxb2Marshaller没有扫描我的package-info.java。有人能看看吗？
我有一个Spring /Camel应用程序，它接受用通用包装包装的多个对象，其中XML必须如下所示：
<mlf:message id="22" product="great.event" xmlns:mlf="special mlf URI">
<mlf:header>
<mlf:action value="notify-published"
浏览 1提问于2014-03-21得票数 2
回答已采纳
1回答
我们用Camel 2.21.0运行Karaf 4.1.5
我有一个非常简单的测试路线来做推土机地图。
from("timer:test?repeatCount=1")
.bean(First.class)
.to("dozer:test?targetModel=xyz.Second")
.log("Done");
使用maven- bundle -plugin构建一个包(将其用于其他几个没有问题的路由)并部署如下：
Caused by: java.lang.C
浏览 1提问于2018-07-02得票数 0
回答已采纳
我有一个包(故意创建情景来测试我的配置项设置)，它没有正确配置所有依赖项。当我部署时，部署会失败，并出现一个应该出现的异常：
2014-02-07 09:17:15,738 | ERROR | rint Extender: 3 | BlueprintCamelContext | 103 - org.apache.camel.camel-blueprint - 2.10.7 | Error occurred during starting Camel: CamelContext(ura) due "org.xmlsoap.schemas.soap.envelope&
浏览 0提问于2014-02-07得票数 1
我正在使用activemq组件来发送/接收消息，但是当我拆分() body()时，我得到了下面的异常。我使用的是camel 2.23.0版本。有人能告诉我哪里出了问题吗？ 以下是导致此问题的路由示例： from("activemq:queue:aaa")
.process("myprocessor")
.split().body()
.to("activemq:queue:bbb") 如果我这样使用，我没有任何问题： from("activemq:queue:aaa")
.process("myprocessor"
浏览 27提问于2018-12-22得票数 1
我创建了一个简单的包：
public class Activator implements BundleActivator {
private CamelContext camelContext;
private CsvDataFormat csv = new CsvDataFormat();
public void start(BundleContext bundleContext) throws Exception {
csv.setDelimiter('|');
csv.setQuoteDisabled(true
浏览 75提问于2019-04-01得票数 0
回答已采纳
嗨，伙计们，我现在正在一个基于camel的项目中工作，java.There提出了一个可能将http转换为https的要求。在做了大量研究之后，我能够将我的restlet公开到https中。但是当我试图从restclient点击url时，我没有得到响应，甚至没有错误。当我寻找开放的港口时，我可以在那里找到我的港口。我正在发送我的代码，并与我的代码一起记录。请有人帮我解决这个问题。
日志生成的
Mar 07, 2017 5:35:51 PM org.restlet.engine.connector.NetServerHelper start
INFO: Starting the interna
浏览 1提问于2017-03-07得票数 0
使用Apache Camel的kafka组件(版本2.19.1)时出错，我只是试图在主题中打印传入的消息，我的管道是这样组成的：
...
context.addRoutes(new RouteBuilder() {
public void configure() {
from("kafka://localhost:9092?topic=test&groupId=testing")
.to("stream:out");
context.start();
}
}
浏览 6提问于2017-09-01得票数 4
回答已采纳
1回答
你好
我有一段代码：
<bean id="properties" class="org.apache.camel.component.properties.PropertiesComponent" >
<property name="location" value="classpath:prj.properties"/>
</bean>
在文件../META-INF/spring/my-contexts/foo.xml中，我得到了一个java.lang.ClassNotFoundExce
浏览 4提问于2014-03-07得票数 1
回答已采纳
我们根据存储在数据库中的配置参数动态构建camel路由。我们有构建所有骆驼路由的泛型类。其中一些参数只是以原始的Camel Spring XML表示的。构建驼峰路由的类扩展了RouteBuilder，下面是构建驼峰路由的代码的一部分：
@Override
public void configure() throws Exception {
RouteDefinition route = from(inputFile);
configureSpringXMLActivity(0, route, convertBodyXml);
config
浏览 1提问于2016-12-02得票数 0
我正在执行一个实现来调用SOAP服务并处理响应。
我从下面的post开始，当它连接到web服务端点时我得到了下面的错误。
错误："com.cleverbuilder.bookservice.GetBook不能转换为java.lang.String“在WrapperClassOutInterceptor。
这是什么原因？
请注意，已经启动，并且运行良好。我在SOAP路由器外进行了测试，它在那里工作得很好。
喜欢高亮显示下面的日志
BodyType: com.cleverbuilder.bookservice.GetBook，Body：
Out:空
日志:
06:28:32,381 IN
浏览 4提问于2019-10-02得票数 1
1回答
这是我的路线：
<camel:endpoint id="media.retrieve.jms.inout.queue" uri="myActiveMQ:queue:RetrieveDocument?concurrentConsumers=5&replyTo=RetrieveDocument&requestTimeout=30000&disableTimeToLive=true"/>
<camel:endpoint id="media.retrieve.jms.error.queue"
浏览 3提问于2013-11-10得票数 0
1回答
我已经将camel xml文件分开，如
FileA.xml
<routeContext id="routeA" xmlns="http://camel.apache.org/schema/spring">
<route id="...">
<from uri="..."/>
<to uri="..."/>
</route>
</routeContext>
FileB.xml
<rou
浏览 2提问于2021-01-18得票数 0
回答已采纳
我想要使用ahc组件调用一个外部http服务，camel-ahc依赖被添加到pom.xml中，并且camel-ahc功能也安装在karaf中： feature:install camel-ahc 已添加的捆绑包： camel-ahc和wrap_file__home_ossl_.m2_repository_org_asynchttpclient_async-http-client_2.4.3_async-http-cl... 我的代码是： <camelContext id="jetty-ws-camel-ahc" xmlns="http://camel.a
浏览 36提问于2019-03-18得票数 1
我的目标是在activity流程中成功调用一个WebService。我正在使用Servicemix 5.0.0。我从示例apache-servicemix-5.0.0/examples/activiti/activiti-camel开始，我通过特性:install成功地运行了它。然后我修改了文件OrderProcess.bpmn.xml，其中的主进程现在如下所示：
<process id="OrderProcess" isExecutable="true">
<startEvent id="start"/>
浏览 1提问于2014-04-24得票数 0
我正在尝试在fuse esb上使用apache mina和camel。我正面临一个部署问题。
这是我的路线：
<beans xmlns...
<bean id="myCodec" class="test.net.mina.codec.MyMinaCodec" />
<camelContext xmlns="http://camel.apache.org/schema/spring">
<route>
<from uri="mina:tc
浏览 1提问于2012-03-14得票数 0
回答已采纳
我在测试Springboot + camel JAVADSL +cxf webservice。当spring boot应用程序启动时，我得到了下面提到的异常，并且应用程序上下文没有加载。Springboot将加载camel上下文，因此没有camel-context.xml。Camel路由器在JAVADSL中定义
Sep 03, 2015 5:49:01 PM org.apache.catalina.core.StandardContext loadOnStartup
SEVERE: Servlet [CXFServlet] in web application [] threw load()
浏览 1提问于2015-09-04得票数 1
我们正在将当前的spring项目转换为spring引导，同时将所有spring从xml转换为基于java配置的。
我不得不将camel xml配置转换为基于java的配置。
目前，我们被指定为camel配置、路由和端点，如下所示
<camel:camelContext id="camelClient">
<camel:template id="camelTemplate"/>
</camel:camelContext>
<template id="camelTe
浏览 1提问于2016-12-29得票数 0
我正在使用Apache来读取Oracle AQ的消息。我在骆驼路线上使用Camel version 2.19.0、Spring 4和XML配置。在运行应用程序时，我得到了“类型从类型: org.xml.sax.SAXParseException".转换为所需类型的错误:值为?的org.w3c.dom.Document”。请有人告诉我什么是问题，以及如何在XML camel配置中修复它。
以下是相关的XML内容。
<camelContext id="moveId" shutdownRunningTask="CompleteCurrentTaskOnly
浏览 3提问于2017-06-08得票数 0
回答已采纳
2回答
我正在尝试使用apache camel从基于spring mvc的web应用程序发送电子邮件。但我的tomcat可能是因为配置错误而起不来的。
你能帮帮我吗？
**camel-config.xml**
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSc
浏览 1提问于2013-05-21得票数 0
我有一个简单的camel路由，它获取一个条目列表，将它们拆分，将每个元素发送到mq节点进行处理，然后通过聚合器将它们连接在一起。
非常接近合成消息处理器：
但我们注意到，在拆分之后，camel将创建多个并发消费者？或者交换？由于消息被发送给多个消费者，因此它们永远不会完成。
列表: 1,2,3,4
拆分: amq::process_each_item
聚合：
[Camel (camel-3) thread #41 - Aggregating 1 - Waiting on 3 more items
[Camel (camel-1) thread #16 - Aggregating 2 - Wai
浏览 1提问于2014-08-22得票数 1
我需要从我的spring bean中接收的exchange对象获取SOAP消息。
我有一个驼峰路由，它从服务端点路由到我的java bean。spring中声明的Java Bean和Camel路由如下所示：
<bean id="processor" class="com.groupgti.esb.camel.wrapper.gradireland.userregistration.UserRegistrationProcessor">
<camel:route id="route">
<camel:from
浏览 0提问于2012-07-27得票数 0
回答已采纳
我有一个需求，我必须从两个不同的源读取数据，一个从文件读取，另一个从DB读取，在聚合器中执行一些操作，然后将输出写入文件。
我可以读取文件，但在从数据库读取文件后，我必须将文件转换为bean。但我不能这么做。
下面是我的代码：
路由：
from("file:{{InputFileDir1}}?noop=true")
.routeId("readInputFiles")
.unmarshal()
.bindy(BindyType.Csv,Job9.class)
浏览 4提问于2017-03-24得票数 0
我在项目A中有一个camel上下文：
<camelContext id="camelContext">
<route id="camelRoute1">
<from uri="vm:foo" />
<log message="camelRoute1 completed" />
</route>
</camelContext>
项目B和项目C使用项目A作为Maven依赖项。
项目B和C中的每一个都定义了自己的<
浏览 0提问于2015-12-13得票数 0
2回答
我试图在JBossFuse/karaf上运行Java加载一个属性文件。
文件位于$karaf.home/etc/bean.properties
代码能够很好地加载包中的属性，但是现在我尝试将这些属性从项目本身中排除出来，然后代码抛出一个Null指针异常。
路径在我的开发机器上正确解析为
C:\Users\someone\devstudio\runtimes\jboss-fuse-6.3.0.redhat-135\etc\bean.properties
属性文件可以加载在blueprint中以配置bean，但是要访问bean，我的代码需要CamelContext。由于我有一些没有exchange
浏览 4提问于2017-05-11得票数 0
回答已采纳
1回答
我正在尝试将消息的一部分解析为pojo，这样我就可以在java中处理它。消息包含json，但我只需要它的一部分，所以我尝试使用jsonpath来挑选我需要的那部分json，但是我无法解组，我还找到了一个直接从jsonpath创建pojo的方法，但它返回null。 from(...)
.transform()
.jsonpath("@.data", false, POJO.class)
.process(...)
.end() 这会使我的POJO为空。 from(...)
.transform.jsonpath("@.data")
.unmarshal().js
浏览 30提问于2020-07-09得票数 0
我遇到了一个Python 'ImportError:没有名为.‘的模块试图从驻留在另一个Python包中的模块导入驻留在另一个Python包中的Python模块时出错。以下图像显示了目录结构：
必须注意的是，只有当我从终端运行脚本时才会得到此错误，而在通过PyCharm执行时，该脚本成功地运行。从终端执行时出错如下：
Traceback (most recent call last):
File "social_networks/linked_data.py", line 15, in <module>
from text_analysis
浏览 4提问于2017-02-28得票数 0
回答已采纳
我的quarkus代码中有以下apache camel路由： rest("/")
.get("/v*").to(MY_SERVICE)
.post("/v*").to(MY_SERVICE)
.put("/v*").to(MY_SERVICE)
.delete("/v*").to(MY_SERVICE) 当我使用以下代码发送包含表单数据的POST请求时： given().urlEncodingEnabled(true)
.param(
浏览 29提问于2021-09-08得票数 1
我们使用Camel CXF API与安全服务器进行通信。这是双向SSL，我们通过Netscaler与3个不同的系统对话。2系统公开SOAP WS，我们能够建立双向SSL并交换消息。第三个系统公开了REST API，并在SSL握手时给出了一个非常奇怪的问题。当我们在熔丝中驼峰CXF时出现错误。在自己的JVM中运行的独立Java程序能够成功地与REST服务对话。
我们已经启用了SSL调试标志，并在日志中得到以下错误。
Camel thread #0 - timer://foo, WRITE: TLSv1 Change Cipher Spec, length = 1
Camel thread #0
浏览 0提问于2015-04-23得票数 0
ThingsService是jax-ws生成的一个webservice接口(为了简洁起见，去掉了注释)。有一个没有参数的方法：
public interface ThingsService {
AvailableThingsResponse getAvailableThings();
}
尝试使用CXF从Camel路由调用非参数操作，如下所示：
from("timer:start?fixedRate=true")
.setHeader(CxfConstants.OPERATION_NAME, constant("getAvailableThing
浏览 6提问于2016-12-15得票数 1
回答已采纳
我有两个使用的独立模块。这两份文件均包括：
main.setPropertyPlaceholderLocations( "classpath:application.properties" );
我也试过：
main.setPropertyPlaceholderLocations( "application.properties" );
如果我在Eclipse中运行它们，两者都可以正常工作(将<project>/target添加到运行配置的Classpath中)。
如果我从cmd行运行它们：
...\target> java -jar <
浏览 0提问于2018-08-14得票数 1
回答已采纳
我的camel-cxf.xml文件中包含以下内容：
<bean id="configFile" class="org.apache.camel.spring.spi.BridgePropertyPlaceholderConfigurer">
<property name="location" value="file:${karaf.home}/etc/test.cfg"/>
</bean>
test.cfg就在那里。我的pom.xml包含以下内容，可解析为2.12.0.redha
浏览 1提问于2014-08-29得票数 0
我将Camel组件和代码从2.X.X升级到3.7.3
此外，在Java 11中使用Java 8之前，我重新编译了它们。
路线的例子：
from(direct:xyz)
.to(URL_A)
.transform()
...
这个问题之所以出现是因为在to之后，我得到了null。
我从camel-http4转到了camel-http，检查了库的属性，但仍然不能得到什么问题？
我所犯的错误：
CaughtExceptionType: org.apache.camel.FailedToCreateProducerException CaughtExceptionMessage: Fai
浏览 3提问于2021-03-18得票数 1
回答已采纳
我使用camel框架处理jetty组件。
我有两个问题：
1)我处理大消息(大约1mb)，jetty组件将消息正文读入camel交换头。它会导致以下错误：
WARN header full: java.lang.RuntimeException: Header>6144
那么，如何让jetty组件不将HttpRequest body放入headers中呢？
2)当我试图覆盖默认的HeaderFilterStrategy时，我写了这样一段代码：
SimpleRegistry registry = new SimpleRegistry();
CamelContext context = n
浏览 3提问于2013-07-09得票数 0
回答已采纳
尝试使用此路由: from("activemq:profiles").aggregate(header("cheese")).batchSize(30).bean(ProfilesQueueService，"saveContacts")
失败，出现以下错误：
没有方法的签名: org.apache.camel.model.RouteType.aggregate()适用于参数类型：(org.apache.camel.builder.ValueBuilder)值:header(奶酪)
使用apache camel 1.6.1，我检查了RouteTyp
浏览 0提问于2009-10-28得票数 0
回答已采纳
1回答
我正在使用Apache启动一个项目，并希望添加一种将一些信息存储为属性的方法。大多数示例似乎使用了Spring和XML，但我采用Java的方式，似乎找不到关于如何正确地做到这一点的好例子。
我从camel原型-java原型创建了一个项目，到目前为止只添加了Quartz和一条路径：
package com.commserv.integration;
import org.apache.camel.builder.RouteBuilder;
public class FilemakerCsvToMailroom extends RouteBuilder {
public void con
浏览 5提问于2015-08-27得票数 1
回答已采纳
我正在尝试在Camel2.23.2中设置一个自定义的processStrategy。我尝试了几种从processStrategy uri parameter引用它的方法，但我总是得到这样的异常： Caused by: java.lang.IllegalArgumentException: Could not find a suitable setter for property: processStrategy as there isn't a setter method with same type: java.lang.String nor type conversion pos
浏览 70提问于2021-10-28得票数 0
我将SFTP服务器放在一个docker容器中，位于localhost:2222，用户user/pass尝试通过camel 2.22.0路由在另一个容器中建立连接，例如
from("sftp:user@localhost:2222/sftp/in?password=pass"))
.log("${file:name}");
但由于以下原因无法连接
Error auto creating directory:/sftp/in due Cannot connect to sftp://user@localhost:2222. This exception
浏览 53提问于2018-08-13得票数 0
我们正在使用蓝图+骆驼+卡拉夫，从春天迁移。我是OSgi蓝图的新手。我们使用Blueprint从蓝图xml中定义的bean中定义服务。
在我们在Blueprint中添加了服务之后，至少可以从karaf获得如下所示: fyi: bundle处于活动状态
karaf>service:list | grep custom
[org.apache.camel.Processor, com.rnd.model.impl.PaymentServiceProcessorBase,com.rnd.generic.CustomServiceP rocessor]osgi.service.bluep
浏览 5提问于2017-03-14得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
