我正在使用具有OAuth1.0授权的API。我想使用授权Oauth标头对该API进行调用:-我已经使用-(ConsumerKey,密钥别名和密码)从从服务器接收到的令牌/密钥中创建了授权标头,并希望随调用一起发送回令牌或OAuth标头。 我已经在Processor(实现Camel Processor的类)中做了所有这些事情,现在想做: 可以在处理器本身中使用此Oauth标头(字符串类型)调用rest API。否则,作为交换发送该标头,并在骆驼的to()端点中获取此值,然后在其中调用REST API。 我只是想在带有…

2020年11月25日 0条评论 60点热度 阅读全文

我正在使用Apache Camel。使用XML DSL,我的意思是 <rests id="rests" xmlns="http://camel.apache.org/schema/spring"> <rest id="rest-custom"> <get uri="my_method" method=""> <description>...</description> <param name="..." ... /> <route>…

2020年11月22日 0条评论 36点热度 阅读全文

我们接收.csv文件(通过ftp和电子邮件),每个文件都是几种不同格式中的一种(可以通过查看文件的顶行来确定)。我对Apache Camel还是相当陌生,但想实现一个基于内容的路由器,并将其解组到相关的类。 我当前的解决方案是将文件分解为字符串列表,手动使用第一行确定文件的类型,然后使用其余的字符串创建相关的实体实例。 有没有更清洁,更好的方法? 解决方案如下: 您可以以最适合您文件的任何方式使用POJO to implement the type check。 public String checkFileTyp…

2020年11月19日 0条评论 41点热度 阅读全文

我有2条路线: <route id="test1"> <from uri="direct:start" /> <setProperty propertyName="id"> <simple>${header._id}</simple> </setProperty> <setBody> <simple>${in.headers._id}</simple> </setBody> <convert…

2020年11月18日 0条评论 44点热度 阅读全文

这是对该here的后续问题。 因此,可以按照上述网址中的说明进行http-http路由。是否还可以调整输出,以便仅返回特定零件?例如。 Google网页的<title>如果我们坚持上述示例..或使用其他信息来增强输出? 解决方案如下: 您可以添加到路线并进行转换,例如仅包含google页面的标题。 伪路线:来自码头到http到处理器 例如,仅添加一个处理器,然后您就可以在处理器中更改消息正文/标题以包含所需的内容。

2020年11月8日 0条评论 52点热度 阅读全文

我想使用“计时器”组件按移动日期范围轮询(从中选择)数据库表。 我想知道是否有可能(以某种方式)使用“ firedTime”属性来执行此操作... 如使用: exchange.getIn().getHeader("firedTime", String.class) ...以在我的select语句的“ where”子句中建立和设置日期范围值。 是否有可能(或建议)获取“ firedTime”值,执行必要的日期算术并在“ Processor”内部构建select语句。然后,使用我新建的SQL字符串在处理器中设置新的Ex…

2020年11月3日 0条评论 30点热度 阅读全文

我正在努力寻找一个完整的示例,说明如何在Spring Boot框架中使用Apache Camel来实现轮询用户的目的。 我已经看过以下内容:https://camel.apache.org/manual/latest/polling-consumer.html以及以下内容:https://camel.apache.org/components/latest/timer-component.html,但是代码示例不够广泛,不足以让我理解完成Java中的任务所需要执行的操作。 我通常是C#开发人员,因此这些对事物的小引…

2020年11月2日 0条评论 43点热度 阅读全文

我有一个Kafka群集(版本:0.10.1.0),具有9个代理和10个分区。 我尝试使用骆驼kafka 2.14.3从Java应用程序消费消息。这是我的骆驼路线 <route id="ReadFromTopic"> <from uri="kafka:[[broker.list]]?topic=[[topic]]&amp;zookeeperHost=[[zookeeper.host]]&amp;zookeeperPort=[[zookeeper.port]]&amp;grou…

2020年11月2日 0条评论 46点热度 阅读全文

我有一个简单的REST服务。有客户,我可以通过其ID获得客户。如果没有客户端使用请求的ID,则应返回未找到的404。 这是相关的部分: rest("/client") .consumes("application/json").produces("application/json") .get("{id}") .to("direct:getClient"); from("direct:getClient") .bean(clientService, "getClient(${header.id})") .choic…

2020年11月1日 0条评论 43点热度 阅读全文

如何将容器管理的数据源和嵌入式Active MQ资源设置为JTATransactionManager进行全局事务?我正在使用Tomcat 6,并在其中安装了Atomikos以支持JTA。我将Hibernate用于ORM。这是我的配置: <bean id="AtomikosTransactionManager" class="com.atomikos.icatch.jta.UserTransactionManager" init-method="init" destroy-method="close"> …

2020年10月30日 0条评论 30点热度 阅读全文