apache-camel

0热度

1回答

JMS连接在发送消息给未授权的路由时不抛出JMSSecurityException

我使用Apache Camel和Spring从我的Java服务发送消息。如果在交换时发生任何错误，我需要处理/触发某些事件。我正在使用下面的代码来实现我的目标。 try { producerTemplate.sendBody(endPoint, bytes); } catch (final RuntimeCamelException exception)

0热度

1回答

骆驼Netty的客户端：连接，然后等待/监听服务器TCP

我试图创建一个骆驼/ TCP的Netty客户端的工作原理如下：连接到remoteserver:1234 发送握手消息（假装这是一个字符串“握手”）离开这个连接打开等待/监听来自服务器的TCP报文和回复他们这是一个简单的hello-world服务器。 from("netty:tcp://localhost:8001?textline=true&sync=true") // .p

0热度

1回答

Apache的骆驼使用以下路段在年底以JSON格式导出数据在一（太）大线

我导出数据（Java的DTO的）转换成文本文件JSON格式很多数据，输出很大。这不是问题。问题在于它全部写在一行中。要测试数据，我必须打开这些文件。我喜欢使用Notepad ++，因为使用该编辑器，我可以使用“JSON查看器”插件对其进行格式化。当这些文件比特定大小（大约100 KB或100百万字符）大时，无法用Notepad ++打开文件。但不仅如此。由于那么长的路线，处理文件很困难。

0热度

1回答

在多线程apache骆驼应用程序中维护排序

我们使用Tibco EMS作为我们的消息系统，并使用apache camel来编写我们的应用程序。在我们的应用程序中，消息被写入队列。一个组件，concurrentConsumers设置为8，从队列中读取，处理消息，然后写入另一个队列。另一个组件，concurrentConsumers再次设置为8，然后从这个新的队列中读取，等等。到目前为止，维护消息顺序并不重要，但新的要求意味着它现在是。查看骆驼

0热度

1回答

春季处理关机信号

我有一个使用骆驼来设置从队列中消耗的路由的spring应用程序。我使用rabbitmq作为消息代理。现在的问题是，如果rabbitmq代理跌落连接不自动恢复。我试过启用automaticRecoveryEnabled。但我得到noSuchMethodError。我将显示用于创建连接的代码。 <camelContext xmlns="http://camel.apache.org/schem

0热度

1回答

使用两个Web服务通信来了，春天开机

您好我是新来的骆驼，我想有两个Web服务通信我的要求是：数组对象传递给一个Web服务阵列[0 ]有学校的详细信息，所以它会保存在数据库使用春天休息电话（“/注册”） array [1]有管理员详细信息，所以需要保存在管理数据库使用其他春天休息服务（“/注册管理员” ）并生成用户名和密码并返回我试图做到这一点，通过使用（“休息：职务：注册”），但骆驼和春季启动已开始在不同的端口，因此404获得

0热度

1回答

如何在Camel中将rejectExecution值更改为True

我正在查看Apache Camel中的Throttler，在http://camel.apache.org/throttler.html上阅读它说rejectExecution的值默认设置为false。我的问题是如何将此值更改为true？例如在下面的路线中，我会在哪里更改默认值？ from("direct:start") .throttle(5).timePeriodMillis(2000)

0热度

1回答

添加认证头骆驼的Restlet组件

我一直在使用的Restlet骆驼组件现在与终端精细几个星期的沟通，但我需要一个授权头添加到我的请求后，这时候我不断收到此警告：警告：不允许添加标准标头“授权”。请使用Restlet API中的等效属性。这阻止将头添加到传出消息。我已经看到了使用restlet的解决方案，但是在使用它作为骆驼组件时我没有奢望。我试过使用org.restlet.http.headers属性，但仍然得到相同的消息

5热度

2回答

Apache的骆驼和IntelliJ IDEA的代码格式

的IntelliJ IDEA格式代码般地击溃这样的： from("direct:loop") .log("Loop: ${header[loopCount]}") .choice() .when(simple("header[loopCount] < 10")) .process(exchange -> { Message in = exchan

0热度

1回答

从骆驼ActiveMQ路线恢复Activiti任务

我试图从一个Activiti骆驼任务发送一个消息到一个ActiveMQ队列，它应该在它被骆驼收到时恢复活动。据我了解，当从队列中收到消息时，缺少使骆驼能够识别它的属性，以便将其路由到正确的活动任务。作为这样的Business key is Null引发异常并且路由失败。 from("activiti:SampleProcess:myCamelTask") .to("activemq:queue