草庐IT

camel_case

全部标签

java - Java 中的开关 : Can I include a condition in a case?

这个问题在这里已经有了答案:Usingswitchstatementwitharangeofvalueineachcase?(20个答案)关闭7年前。这是我的代码:switch(age){case10:System.out.println("Youaretooyoungtodrive.");break;case20:System.out.println("Youcandrive!");break;default:System.out.println("Error");}如果年龄是15岁会怎样?好吧,它给了我一个错误。所以我想知道是否可以在案例中包含一个条件。例如,case(age>=1

java - 当开关不支持 boolean 数据类型时,为什么 boolean 表达式在 case block 中有效?

昨晚看了一些SCJP认证,开始思考switch语句以及表达式是如何求值的,有点疑惑。Java不会让你打开一个boolean值,所以下面的代码不会编译:publicstaticvoidswitchOnBoolean(booleantheBool){System.out.println("\n\nAssessingboolean:"+theBool);//linebelowwon'tcompile,sincebooleansarenotvalidfortheswitchstatementswitch(theBool){casetrue:{System.out.println("Theboo

java - 不同switch case中的变量不能重名?

我正在重构一些代码以使其更易于阅读,但我遇到了一些我觉得很奇怪的事情,我想知道是否有人可以向我解释一下。原代码:if(tokensLeft==3){Stringid=tokens.nextToken();Stringvalue=tokens.nextToken();StringtrailerId=tokens.nextToken();rawListener.binaryInfo(id,Integer.parseInt(value),trailerId,this);}elseif(tokensLeft==2){Stringid=tokens.nextToken();Stringvalue

java - Camel ftp 似乎永远挂起

我有一个Camel路线,就像永远被绞死一样,不确定是Camel还是Ftp客户端问题。ftp组件将soTimeout设置为60000。感谢任何帮助。Versionofcomponents:camel-ftp:2.9.0CommonsNet:(2.2)线程转储:"Camel(some-ftp-route)thread#57-ftp://user@ftphost/folder"Id=338inRUNNABLE(runninginnative)atjava.net.SocketInputStream.socketRead0(NativeMethod)atjava.net.SocketInput

java - Camel Websocket 组件无法安装到 Karaf

我正在使用ApacheKaraf4.0.4和JavaOracle8并尝试安装camel-websocket组件。我尝试通过以下方式安装2.16.0和2.16.2版本:feature:installcamel-websocket...Karaf挂起,再也没有回来。作为解决方法,我尝试运行:sudowget-O/opt/apache-karaf-4.0.4/deploy/camel-websocket-2.16.2.jarhttp://central.maven.org/maven2/org/apache/camel/camel-websocket/2.16.2/camel-websock

java - 如何检测 Apache Camel 中断开/恢复的 JMS 连接?

我们正在使用ApacheCamel(Camel2.10.3,基于JavaDSL)构建一个集成项目。我们有一个从数据库中提取数据的路由(我们称之为IN_DB),每天执行一些逻辑并插入另一个数据库(OUT_DB),另一个订阅XML数据的JMS主题的路由,做一些逻辑并将其全天插入同一个数据库(OUT_DB)。要求是,当JMS主题连接因任何原因中断时,我们会无限期地尝试重新连接,一旦重新连接成功,我们需要返回数据库(IN_DB)并进行另一次加载以填补空缺话题在哪里。我的问题是我们如何在Camel中执行此逻辑(“我已连接,然后断开连接,现在我再次连接”)?当主题下降时,以主题消费者开始的路由会发

java - Camel 和 JMS 以正确的顺序从高级队列中消费消息

我在将ApacheCamel与OracleAdvancedQueues和JMS结合使用时遇到问题。这是关于分发消息的应用程序。在Camel的帮助下,消息在OracleAdvancedQueues中接收和排队。然后它们被Camel消耗并转发到目标系统。对于消息传递失败的情况,在AdvancedQueue中定义了一个重试次数,使消息重新传递。如果Camel现在将消息出列并将其发送到不可用的目标系统,则会抛出HttpOperationFailedException或NoSuchEndpointException。这些被捕获并执行回滚。此时,期望按照重试计数中定义的频率重试消息传递,然后将其移

java - Apache Camel Kafka - 聚合 kafka 消息并定期发布到不同的主题

我有一个用例:我需要定期读取和聚合来自kafka主题的消息,然后发布到不同的主题。本地存储不是一个选项。这就是我计划解决这个问题的方式,欢迎提出任何改进建议为了调度kafka消息的聚合和发布,计划使用AggregatorEIP的completionInterval选项。这是代码。@AutowiredObjectMapperobjectMapper;JacksonDataFormatjacksonDataFormat;@PostConstructpublicvoidinitialize(){//objectMapper.setPropertyNamingStrategy(Property

java - 从 jetty 到绝对 URL 的 Camel 路线

我在ApacheKaraf上部署了一个OSGi包。我有一条简单的Camel路线:wt=xml&rows=1000000&fl=nid,title&fq=sm_vid_Third_parties_with_which_this_organisation_s_content_can_be_shared:%22Indeed%22//int[@name='nid']-->我无法让它工作。当我调用http://localhost:8282/services时,它应该路由到setHeader下方指定的uri。相反,我得到了这个异常(exception):java.lang.

java - 从 Spring 注释配置初始化 Camel

我正在尝试学习Spring并了解它的工作原理。我遵循了一些设置Spring和Camel的教程,并使用默认设置让它工作。我现在正尝试将尽可能多的配置XML文件转换为Java类。到目前为止,我已经成功地在Java类中创建了Camel路线(扩展SpringRouteBuilder并实现了configure()),以及我的spring配置文件中的所有bean(Bean->Functionwith@Bean)。我唯一缺少的部分是开始我的Camel路线的camelContext定义(?)(我认为......):net.krg.kneip.routing等效的非XML是什么?不确定它是否有帮助,但到