- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我们有一个基于 Camel v2.16.1 的集成系统,它运行在 Jboss v6 Linux 平台上。有多个接口(interface)同时运行,每个接口(interface)具有不同的轮询率。
我们间歇性地遇到“无法重命名文件”问题,因为 Camel 无法备份到成功处理并从 FTP 源传输文件的“完成”文件夹。重新启动 camel 应用程序可解决此问题。
基本上,在由 quartz 调度程序触发的固定时间间隔内,路由:
如果从源目录中读取多个文件,则在处理之前将所有文件一起附加到一个临时文件中。
Camel FTP 配置使用以下 URL:
ftp://xxxx/export?antInclude=dsciord_*.dat&inProgressRepository=#warehouseIntegrationIdempotentRepository&preMove=in_progress_bpo/$simple{date:now:yyyyMMddHHmm}/$simple{file:name}&move=done&consumer.bridgeErrorHandler=true
/export
目录读取文件 dsciord_*.dat
inprogressRepository
将读取的文件名存储到本地数据库中(这样做是为了防止与第二个集群节点的争用问题,但是,目前只有一个节点是事件的。这个选项是不必要的并且可以删除以加快该过程)。in_progress_bpo/201609061522
目录,其中子目录是根据 date_timestamp 创建的。 in_progress_bpo/201609061522/done
子目录。在绝大多数情况下,路径都没有问题,但是,有时文件无法移动到 done 文件夹(见下面的错误)。即使在这种情况下,路由有时会在下一个轮询周期继续成功,但是,在其他情况下,路由会进入一种状态,即使 quartz 调度程序触发了轮询,路由也无法检测到 source/export 目录中的任何文件即使那里有文件。
org.apache.camel.component.file.GenericFileOperationFailedException: Cannot rename file: RemoteFile[in_progress_bpo/201609060502/dsciord_3605752.dat] to: RemoteFile[in_progress_bpo/201609060502/done/dsciord_3605752.dat]
注意:我们正在使用
ConsumerTemplate
的单个实例来处理我们的接口(interface)。inprogressRepository
来存储读取的文件名。显然,必须有一个系统锁定源文件,这会导致 Camel 路由停止处理更多文件。
任何关于调试/解决此问题的想法/建议将不胜感激。我通过 Camel 用户论坛阅读的问题似乎与 Windows 相关的部署有关,有时 Smooks 无法关闭输入流。我检查过,我们不使用org.milyn.templating.xslt.XslTemplateProcessor#bypass
方法,其中 Smooks 无法关闭底层输入流。
最佳答案
我终于能够重现/识别问题。
假设我们使用相对路径将处理后的文件移动到成功通过 ftp 传输到目标服务器的位置:
../../../u/4gl_upload/warehouse_integration_2/trs-server/export/in_progress_bpo/201609081030/done
但是,出于某种原因,camel 消费者没有遍历正确的路径来移动已处理的文件,而是从当前工作目录开始创建了一个新的子目录树,这可能会很长,如下所示。因此问题。它不知道自己在哪里,也不会自行重置。
/u/4gl_upload/warehouse_integration_2/trs-server/u/4gl_upload/warehouse_integration_2/trs-server/export/in_progress_bpo/201609081030
这是使用选项 stepwise=false 复制的,这意味着它一步而不是逐步遍历子目录。
仍然不知道什么是最好的解决方案。
关于apache-camel - Apache Camel GenericFileOperationFailedException : 'Cannot rename file' locks exchange,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/39361221/
我想知道锁是如何在 Java 中实现的。在一些教程中,我发现它们应该使用 wait() 和 notify()/notifyAll() 以及一些 boolean 标志来实现(它可能比那复杂得多,但基本上
我正在开发一个多线程服务器,用于存储和读取来自数据库的信息。数据库是用 RocksDB 实现的。 我遇到的问题是,当我一次从多个线程访问数据库时,我得到了那个错误。 通常是说db在usign后没有被删
例如,这里有一些 linux 中的代码: void set_leds(int val) { int fd = open ("/dev/console", O_WRONLY); // argumen
关闭。这个问题需要更多focused .它目前不接受答案。 想改进这个问题吗? 更新问题,使其只关注一个问题 editing this post . 关闭 9 年前。 Improve this qu
考虑以下代码。为了防止IndexOutOfBoundsException打电话时 listIterator ,我们使用读取器锁来检索基于索引的 iteartor,并在对 stockCodes 进行写操
这个问题在这里已经有了答案: Java locking structure best pattern (2 个答案) 关闭 6 年前。 有什么区别: private Lock lock = new
是否可以在网页加载时检查 Scroll Lock、Num Lock 和 Caps Lock 的状态?我找到了使用 JavaScript 在按键后进行检查的方法,但这不是我要问的。 最佳答案 2019
是否可以在网页加载时检查 Scroll Lock、Num Lock 和 Caps Lock 的状态?我找到了使用 JavaScript 在按键后进行检查的方法,但这不是我要问的。 最佳答案 2019
在Ubuntu中安装某些东西时出现错误。我尝试了一些命令来杀死正在运行的进程,但仍然遇到相同的错误。 最佳答案 根据文章How to Fix “Waiting for cache lock: Coul
我们有一个gradle构建,它可以动态创建GradleBuild类型的多个任务,以与不同的客户端库版本一起运行以测试其兼容性。在Gradle4上可以正常工作,但是在移至Gradle5后,执行第一项任务
我在尝试运行在 vertica 数据库表上运行查询的客户端应用程序时反复遇到此错误。 有人可以帮助解决这个问题吗? 最佳答案 我想知道您的客户端应用程序向 Vertica 发送了哪种“查询”(以 RE
我有一个创建锁的方法。 ReadWriteLock lock = new ReentrantReadWriteLock(); 然后我使用 Lock Interface 将该对象传递到一个方法中。 m
正如问题所问,我知道这是可能的on Linux ,但我找不到任何适用于 Windows 的最新信息。有可能吗? 最佳答案 您可以使用 ctypes 加载 user32.dll 然后调用 GetKeyS
这是同一个问题 Change keyboard locks in Python或者 How to change caps lock status without key press . 但还是有区别的
与 this question 相同,不知道为什么Java团队没有在Lock中添加一些默认方法界面,类似这样: public default void withLock(Runnable r) {
我有一个带有package-lock.json文件的项目。 现在,我想基于yarn.lock文件或项目的现有package-lock.json生成node_modules文件。 我怎样才能做到这一点?
我正在查看 pthreadtypes.h 文件中的 pthread_mutex_t 结构。 “__lock”代表什么?它就像分配给互斥锁的锁号吗? typedef union { struct _
我正在研究避免死锁的措施,其中一种可能的方法是通过强制线程放弃它在访问另一个锁但无法访问该锁时已经持有的锁来打破循环等待。 以最简单的银行账户转账为例: class Account { priva
我被要求支持一些遗留代码,我看到了一些让我摸不着头脑的事情。在某些代码段中,我看到类实例使用 CMutex 实例来同步方法执行。例如 class CClassA : public CObject {
当我们调用 lock.lock() 或尝试进入一个 synchronized block 时,如果其他线程已经获取了该锁,我们的线程就会阻塞。现在我的问题是,当我们查看 lock.lock() 的实现
我是一名优秀的程序员,十分优秀!