apache-camel

0热度

1回答

我正在尝试构建一个基于文件的集成，其中文件被转储到主目录的一个子目录中进行处理。我需要获取子目录的名称，以知道该文件适用于哪个客户端。所以，如果我有： /uploads/foo/bar.txt 我需要处理该文件，并知道它的客户端“富”。我不知道如何获得该部分并将其设置为处理bar.txt文件的处理器的标题。我有它拿起文件和处理，现在我需要添加在这一块。任何人有我的想法吗？

0热度

1回答

骆驼中的依赖项字段验证？

Apache骆驼豆验证：我有一个领域依赖于另一个可以帮助我如何验证如何如果制造商的现场数据是，则请指定然后licensePlate字段为必填字段。 <?xml version="1.0" encoding="UTF-8"?> <constraint-mappings xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:s

0热度

1回答

Java - Camel中的PreparedStatements

我一直在玩骆驼，目的是为了了解它几个星期。到目前为止，我已经使用填充了DataSource的SimpleRegistry指向我的SQLite DB来告诉CamelContext关于数据库。我使用一个bean将我的SQL语句放在一起，然后我只是将它发送到一个消息中的JDBC端点。使用Java DSL的一切。这工作正常。现在我的同事想知道，为什么我不使用PreparedStatements。我对准备

0热度

1回答

无法将application.prop添加到骆驼测试中

我无法在测试环境中使我的测试使用application.propperies，而在main上正常工作。写它不能找到这样的属性。我试图使用@TestPropertySource（locations =“classpath：application.properties”），但没有帮助。还将test.propperies添加到测试文件夹中的资源。 My project structure 我的测试类：

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获得