代码之家  ›  专栏  ›  技术社区  ›  Fede E.

无反馈的Camel文件使用者错误

apache-camel
  •  0
  • Fede E.  · 技术社区  · 6 年前

    我正在运行一个使用apachecamel进行文件处理的应用程序。这个应用程序在我的Windows和CentOS上运行得很好。

    然而,当运行在一个RHEL上时,我得到一个奇怪的行为,显示不多的信息。以下是日志摘要: 

    Configured property: initialDelay on bean: org.apache.camel.impl.DefaultScheduledPollConsumerScheduler@ad834fbd with value: 1000
2019-02-28 16:09:46,037 main                                                     TRACE org.apache.camel.util.IntrospectionSupport                   Configured property: delay on bean: org.apache.camel.impl.DefaultScheduledPollConsumerScheduler@ad834fbd with value: 500
2019-02-28 16:09:46,037 main                                                     TRACE org.apache.camel.util.IntrospectionSupport                   Configured property: useFixedDelay on bean: org.apache.camel.impl.DefaultScheduledPollConsumerScheduler@ad834fbd with value: true
2019-02-28 16:09:46,037 main                                                     TRACE org.apache.camel.util.IntrospectionSupport                   Configured property: scheduledExecutorService on bean: org.apache.camel.impl.DefaultScheduledPollConsumerScheduler@ad834fbd with value: 
2019-02-28 16:09:46,037 main                                                     TRACE org.apache.camel.util.IntrospectionSupport                   Configured property: timeUnit on bean: org.apache.camel.impl.DefaultScheduledPollConsumerScheduler@ad834fbd with value: MILLISECONDS
2019-02-28 16:09:46,037 main                                                     TRACE org.apache.camel.support.ServiceSupport                      Starting service
2019-02-28 16:09:46,037 main                                                     DEBUG org.apache.camel.impl.DefaultExecutorServiceManager          Created new ScheduledThreadPool for source: Consumer[file:///opt/IBM/WebSphere90/tmp/FILES/OUT/PROCESSED/BASEII_FRIDA_OUTGOING_PROC/CORPORATION_8/TO_PROCESS_STX?charset=UTF-8&doneFileName=%24%7Bfile%3Aname%7D.stx&move=.done&moveFailed=.error&readLock=changed&readLockCheckInterval=1500] with name: file:///opt/IBM/WebSphere90/tmp/FILES/OUT/PROCESSED/BASEII_FRIDA_OUTGOING_PROC/CORPORATION_8/TO_PROCESS_STX?charset=UTF-8&doneFileName=%24%7Bfile%3Aname%7D.stx&move=.done&moveFailed=.error&readLock=changed&readLockCheckInterval=1500 -> org.apache.camel.util.concurrent.SizedScheduledExecutorService@bac57329[file:///opt/IBM/WebSphere90/tmp/FILES/OUT/PROCESSED/BASEII_FRIDA_OUTGOING_PROC/CORPORATION_8/TO_PROCESS_STX?charset=UTF-8&doneFileName=%24%7Bfile%3Aname%7D.stx&move=.done&moveFailed=.error&readLock=changed&readLockCheckInterval=1500]
2019-02-28 16:09:46,037 main                                                     DEBUG o.a.camel.impl.DefaultScheduledPollConsumerScheduler         Scheduling poll (fixed delay) with initialDelay: 1000, delay: 500 (milliseconds) for: file:///opt/IBM/WebSphere90/tmp/FILES/OUT/PROCESSED/BASEII_FRIDA_OUTGOING_PROC/CORPORATION_8/TO_PROCESS_STX?charset=UTF-8&doneFileName=%24%7Bfile%3Aname%7D.stx&move=.done&moveFailed=.error&readLock=changed&readLockCheckInterval=1500
2019-02-28 16:09:46,037 main                                                     TRACE o.a.c.util.concurrent.SizedScheduledExecutorService          canScheduleOrExecute 0 < 1000 -> true
2019-02-28 16:09:46,038 main                                                     TRACE org.apache.camel.util.concurrent.CamelThreadFactory          Created thread[Camel (CamelContext) thread #58 - file:///opt/IBM/WebSphere90/tmp/FILES/OUT/PROCESSED/BASEII_FRIDA_OUTGOING_PROC/CORPORATION_8/TO_PROCESS_STX] -> Thread[Camel (CamelContext) thread #58 - file:///opt/IBM/WebSphere90/tmp/FILES/OUT/PROCESSED/BASEII_FRIDA_OUTGOING_PROC/CORPORATION_8/TO_PROCESS_STX,5,main]
2019-02-28 16:09:46,038 main                                                     INFO  org.apache.camel.spring.SpringCamelContext                   Route: FRIDABaseIIFileOutgoingTransport started and consuming from: file:///opt/IBM/WebSphere90/tmp/FILES/OUT/PROCESSED/BASEII_FRIDA_OUTGOING_PROC/CORPORATION_8/TO_PROCESS_STX?charset=UTF-8&doneFileName=%24%7Bfile%3Aname%7D.stx&move=.done&moveFailed=.error&readLock=changed&readLockCheckInterval=1500
2019-02-28 16:09:46,038 main                                                     TRACE org.apache.camel.support.ServiceSupport                      Starting service
2019-02-28 16:09:46,038 main                                                     INFO  org.apache.camel.spring.SpringCamelContext                   Apache Camel 2.21.1 (CamelContext: CamelContext) is shutting down
2019-02-28 16:09:46,038 main                                                     TRACE org.apache.camel.util.ServiceHelper                          Stopping service org.a down service org.apache.camel.impl.DefaultRouteController@36b5248f
2019-02-28 16:09:46,038 main                                                     TRACE org.apache.camel.support.ServiceSupport                      Servpache.camel.impl.DefaultRouteController@36b5248f
2019-02-28 16:09:46,038 main                                                     TRACE org.apache.camel.util.ServiceHelper                          Shuttingice already stopped
2019-02-28 16:09:46,039 main                                                     INFO  org.apache.camel.impl.DefaultShutdownStrategy                Starting to graceful shutdown 26 routes (timeout 300 seconds)
2019-02-28 16:09:46,039 main                                                     DEBUG org.apache.camel.impl.DefaultExecutorServiceManager          Created new ThreadPool for source: org.apache.camel.impl.DefaultShutdownStrategy@1950c033 with name: ShutdownTask. -> org.apache.camel.util.concurrent.RejectableThreadPoolExecutor@33d3ff79[Running, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0][ShutdownTask]
2019-02-28 16:09:46,040 main                                                     TRACE org.apache.camel.util.concurrent.CamelThreadFactory          Created thread[Camel (CamelContext) thread #59 - ShutdownTask] -> Thread[Camel (CamelContext) thread #59 - ShutdownTask,5,main]
2019-02-28 16:09:46,040 Camel (CamelContext) thread #59 - ShutdownTask           DEBUG org.apache.camel.impl.DefaultShutdownStrategy                There are 26 routes to shutdown
2019-02-28 16:09:46,041 Camel (CamelContext) thread #59 - ShutdownTask           TRACE org.apache.camel.impl.DefaultShutdownStrategy                Shutting down route: FRIDABaseIIFileOutgoingTransport with options [Default,CompleteCurrentTaskOnly]
2019-02-28 16:09:46,041 Camel (CamelContext) thread #59 - ShutdownTask           TRACE org.apache.camel.impl.DefaultShutdownStrategy                Suspending: Consumer[file:///opt/IBM/WebSphere90/tmp/FILES/OUT/PROCESSED/BASEII_FRIDA_OUTGOING_PROC/CORPORATION_8/TO_PROCESS_STX?charset=UTF-8&doneFileName=%24%7Bfile%3Aname%7D.stx&move=.done&moveFailed=.error&readLock=changed&readLockCheckInterval=1500]
2019-02-28 16:09:46,041 Camel (CamelContext) thread #59 - ShutdownTask           TRACE org.apache.camel.util.ServiceHelper                          Suspending service Consumer[file:///opt/IBM/WebSphere90/tmp/FILES/OUT/PROCESSED/BASEII_FRIDA_OUTGOING_PROC/CORPORATION_8/TO_PROCESS_STX?charset=UTF-8&doneFileName=%24%7Bfile%3Aname%7D.stx&move=.done&moveFailed=.error&readLock=changed&readLockCheckInterval=1500]
2019-02-28 16:09:46,041 Camel (CamelContext) thread #59 - ShutdownTask           TRACE org.apache.camel.impl.DefaultShutdownStrategy                Suspend complete for: Consumer[file:///opt/IBM/WebSphere90/tmp/FILES/OUT/PROCESSED/BASEII_FRIDA_OUTGOING_PROC/CORPORATION_8/TO_PROCESS_STX?charset=UTF-8&doneFileName=%24%7Bfile%3Aname%7D.stx&move=.done&moveFailed=.error&readLock=changed&readLockCheckInterval=1500]
2019-02-28 16:09:46,041 Camel (CamelContext) thread #59 - ShutdownTask           DEBUG org.apache.camel.impl.DefaultShutdownStrategy                Route: FRIDABaseIIFileOutgoingTransport suspended and shutdown deferred, was consuming from: file:///opt/IBM/WebSphere90/tmp/FILES/OUT/PROCESSED/BASEII_FRIDA_OUTGOING_PROC/CORPORATION_8/TO_PROCESS_STX?charset=UTF-8&doneFileName=%24%7Bfile%3Aname%7D.stx&move=.done&moveFailed=.error&readLock=changed&readLockCheckInterval=1500
2019-02-28 16:09:46,041 Camel (CamelContext) thread #59 - ShutdownTask           TRACE org.apache.camel.impl.DefaultShutdownStrategy                Shutting down route: FileErrorsReportToDB with options [Default,CompleteCurrentTaskOnly]
2019-02-28 16:09:46,041 Camel (CamelContext) thread #59 - ShutdownTask           DEBUG org.apache.camel.impl.DefaultShutdownStrategy

    在第一行之前,对每个文件使用者路由重复日志基本相同。

    背景永远不会停止。。。它会保持不动,文件使用者会不断记录: 

    2019-02-28 16:09:46,996 Camel (CamelContext) thread #37 - file:///opt/IBM/WebSphere90/tmp/FILES/OUT/PROCESSED/LOGISTIC/CORPORATION_8/TO_PROCESS_STX/temp4 TRACE org.apache.camel.impl.ScheduledPollConsumer                  Cannot start to poll: file:///opt/IBM/WebSphere90/tmp/FILES/OUT/PROCESSED/LOGISTIC/CORPORATION_8/TO_PROCESS_STX/temp4?charset=UTF-8&exclude=TEMP_.*&move=.done&moveFailed=.error&readLock=rename as its suspended

    0 回复  |  直到 6 年前
        1
  •  1
  •   Darius X.    6 年前

    似乎你的“主要”并没有保持运转。所以,当应用程序启动时,Camel会初始化并配置路由。但是,“主”只是立即结束。 不能解释为什么if可以在一个操作系统上工作而不能在另一个操作系统上工作,但也许在这两个环境中,其他的东西是不同的?

    http://camel.apache.org/running-camel-standalone-and-have-it-keep-running.html

    推荐文章
    DummyGuy  ·  将JSON数组转换为对象数组-Apache camel
    3 年前
    silenzzz  ·  找不到骆驼码头终结点
    3 年前
    jbabu  ·  ApacheCamel——返回值的组件
    3 年前
    Mawillec  ·  在一个消费者隐藏多个用户的情况下,在队列中保留和锁定消息的策略
    7 年前
    Giulio Pulina  ·  ActiveMQ 5.9-由于未释放锁,代理上的线程被阻止
    7 年前
    Sparkler-blush  ·  驼峰http获取调用状态代码406
    7 年前
    user6640997  ·  原因:java。lang.NoSuchMethodError:org。冬眠SessionFactory。getCurrentSession()长/休眠/经典/会话;
    7 年前
    dharam  ·  Spring Boot+Apache Camel+Freemarker自定义模板加载程序
    7 年前
    phoenixSid  ·  在apache Camel中,无需将整个文件加载到内存中即可对大型文件进行压缩和解压缩
    7 年前
    Chin Liang  ·  驼峰模拟-模拟端点。whenAnyExchangeReceived进程方法未执行
    7 年前
    关于   移动版
    代码之家 - 一站式码农服务社区
    沪ICP备11025650号