java - Java SFTP :: Apache Camel RemoteFileProducer 忽略异常

Question

我有一个 Java 应用程序，在 WildFly 服务器上运行，该服务器使用 Apache Camel 3.7.3 连接到远程 SFTP 服务器。此应用程序将文件发送到 SFTP 服务器。当我手动测试我的应用程序并向远程服务器发送 50 个文件时，有时会丢失 1 个文件。

我做了一些调试，发现了以下方法，该方法由camel-ftp库中的RemoteFileProducer使用。

@Override
    public void handleFailedWrite(Exchange exchange, Exception exception) throws Exception {
        loggedIn = false;
        if (isStopping() || isStopped()) {
            // if we are stopping then ignore any exception during a poll
            LOG.debug("Exception occurred during stopping: {}", exception.getMessage());
        } else {
            LOG.warn("Writing file failed with: {}", exception.getMessage());
            try {
                disconnect();
            } catch (Exception e) {
                // ignore exception
                LOG.debug("Ignored exception during disconnect: {}", e.getMessage());
            }
            // rethrow the original exception*/
            throw exception;
        }
    }

我的文件不会到达 SFTP 服务器生成了一个异常，它具有以下堆栈跟踪：

org.apache.camel.component.file.GenericFileOperationFailedException:
    at deployment.testapplication.ear//org.apache.camel.component.file.remote.SftpOperations.existsFile(SftpOperations.java:1083)
    at deployment.testapplication.ear//org.apache.camel.component.file.remote.SftpOperations.doStoreFile(SftpOperations.java:968)
    at deployment.testapplication.ear//org.apache.camel.component.file.remote.SftpOperations.storeFile(SftpOperations.java:951)
    at deployment.testapplication.ear//org.apache.camel.component.file.GenericFileProducer.writeFile(GenericFileProducer.java:290)
    at deployment.testapplication.ear//org.apache.camel.component.file.GenericFileProducer.processExchange(GenericFileProducer.java:173)
    at deployment.testapplication.ear//org.apache.camel.component.file.remote.RemoteFileProducer.process(RemoteFileProducer.java:59)
    at deployment.testapplication.ear//org.apache.camel.support.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:66)
    at deployment.testapplication.ear//org.apache.camel.processor.SendProcessor.lambda$process$2(SendProcessor.java:188)
    at deployment.testapplication.ear//org.apache.camel.support.cache.DefaultProducerCache.doInAsyncProducer(DefaultProducerCache.java:317)
    at deployment.testapplication.ear//org.apache.camel.processor.SendProcessor.process(SendProcessor.java:187)
    at deployment.testapplication.ear//org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:395)
    at deployment.testapplication.ear//org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)
    at deployment.testapplication.ear//org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60)
    at deployment.testapplication.ear//org.apache.camel.processor.Pipeline.process(Pipeline.java:147)
    at deployment.testapplication.ear//org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:312)
    at deployment.testapplication.ear//org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:84)
    at deployment.testapplication.ear//org.apache.camel.impl.engine.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:218)
    at deployment.testapplication.ear//org.apache.camel.impl.engine.SharedCamelInternalProcessor$1.process(SharedCamelInternalProcessor.java:112)
    at deployment.testapplication.ear//org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
    at deployment.testapplication.ear//org.apache.camel.impl.engine.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:109)
    at deployment.testapplication.ear//org.apache.camel.support.cache.DefaultProducerCache.send(DefaultProducerCache.java:189)
    at deployment.testapplication.ear//org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:176)
    at deployment.testapplication.ear//org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:172)
    at deployment.testapplication.ear//org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:137)
    at deployment.testapplication.ear//com.testapplication.message.camel.CamelManager.sendExchange(CamelManager.java:341)
    at deployment.testapplication.ear//com.testapplication.message.camel.IntegrationChannel.transmit(IntegrationChannel.java:290)
    at deployment.testapplication.ear//com.testapplication.workflow.TransmissionController.processOutgoing(TransmissionController.java:288)
    at deployment.testapplication.ear//com.testapplication.message.rules.ProcessWaitingTransmissions.handleObject(ProcessWaitingTransmissions.java:21)
    at deployment.testapplication.ear//com.testapplication.core.engine.rules.AbstractProcessingRule.executeRule(AbstractProcessingRule.java:178)
    at deployment.testapplication.ear//com.testapplication.system.rules.RuleLibrary.startRule(RuleLibrary.java:151)
    at deployment.testapplication.ear//com.testapplication.system.rules.RuleLibrary.executeRuleSequence(RuleLibrary.java:75)
    at deployment.testapplication.ear.bean-rule-server.jar//com.testapplication.core.engine.remote.EngineBLMgrBean.execRSImpl(EngineBLMgrBean.java:213)
    at deployment.testapplication.ear.bean-rule-server.jar//com.testapplication.core.engine.remote.EngineBLMgrBean.execRSTrans(EngineBLMgrBean.java:205)
    at jdk.internal.reflect.GeneratedMethodAccessor1088.invoke(Unknown Source)
    at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.base/java.lang.reflect.Method.invoke(Method.java:566)
    at [e-mail]//org.jboss.as.ee.component.ManagedReferenceMethodInterceptor.processInvocation(ManagedReferenceMethodInterceptor.java:52)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.component.invocationmetrics.ExecutionTimeInterceptor.processInvocation(ExecutionTimeInterceptor.java:43)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.jpa.interceptor.SBInvocationInterceptor.processInvocation(SBInvocationInterceptor.java:47)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ee.concurrent.ConcurrentContextInterceptor.processInvocation(ConcurrentContextInterceptor.java:45)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.invocation.InitialInterceptor.processInvocation(InitialInterceptor.java:40)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.invocation.ChainedInterceptor.processInvocation(ChainedInterceptor.java:53)
    at [e-mail]//org.jboss.as.ee.component.interceptors.ComponentDispatcherInterceptor.processInvocation(ComponentDispatcherInterceptor.java:52)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.component.pool.PooledInstanceInterceptor.processInvocation(PooledInstanceInterceptor.java:51)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.component.interceptors.AdditionalSetupInterceptor.processInvocation(AdditionalSetupInterceptor.java:54)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.tx.CMTTxInterceptor.invokeInCallerTx(CMTTxInterceptor.java:185)
    at [e-mail]//org.jboss.as.ejb3.tx.CMTTxInterceptor.required(CMTTxInterceptor.java:364)
    at [e-mail]//org.jboss.as.ejb3.tx.CMTTxInterceptor.processInvocation(CMTTxInterceptor.java:144)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.component.interceptors.CurrentInvocationContextInterceptor.processInvocation(CurrentInvocationContextInterceptor.java:41)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.component.invocationmetrics.WaitTimeInterceptor.processInvocation(WaitTimeInterceptor.java:47)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.security.SecurityContextInterceptor.processInvocation(SecurityContextInterceptor.java:100)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.deployment.processors.StartupAwaitInterceptor.processInvocation(StartupAwaitInterceptor.java:22)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.component.interceptors.ShutDownInterceptorFactory$1.processInvocation(ShutDownInterceptorFactory.java:64)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.component.interceptors.LoggingInterceptor.processInvocation(LoggingInterceptor.java:67)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ee.component.NamespaceContextInterceptor.processInvocation(NamespaceContextInterceptor.java:50)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.invocation.ContextClassLoaderInterceptor.processInvocation(ContextClassLoaderInterceptor.java:60)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.invocation.InterceptorContext.run(InterceptorContext.java:438)
    at [e-mail]//org.wildfly.security.manager.WildFlySecurityManager.doChecked(WildFlySecurityManager.java:627)
    at [e-mail]//org.jboss.invocation.AccessCheckingInterceptor.processInvocation(AccessCheckingInterceptor.java:57)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.invocation.ChainedInterceptor.processInvocation(ChainedInterceptor.java:53)
    at [e-mail]//org.jboss.as.ee.component.ViewService$View.invoke(ViewService.java:198)
    at [e-mail]//org.jboss.as.ee.component.ViewDescription$1.processInvocation(ViewDescription.java:185)
    at [e-mail]//org.jboss.as.ee.component.ProxyInvocationHandler.invoke(ProxyInvocationHandler.java:81)
    at deployment.testapplication.ear.bean-rule-server.jar//com.testapplication.core.engine.remote.LocalEngineBLMgr$$$view10.execRSTrans(Unknown Source)
    at deployment.testapplication.ear.bean-rule-server.jar//com.testapplication.core.engine.remote.EngineBLMgrBean.execute(EngineBLMgrBean.java:176)
    at deployment.testapplication.ear.bean-rule-server.jar//com.testapplication.core.engine.remote.EngineBLMgrBean.executeRuleSequence(EngineBLMgrBean.java:122)
    at jdk.internal.reflect.GeneratedMethodAccessor1087.invoke(Unknown Source)
    at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.base/java.lang.reflect.Method.invoke(Method.java:566)
    at [e-mail]//org.jboss.as.ee.component.ManagedReferenceMethodInterceptor.processInvocation(ManagedReferenceMethodInterceptor.java:52)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.component.invocationmetrics.ExecutionTimeInterceptor.processInvocation(ExecutionTimeInterceptor.java:43)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.jpa.interceptor.SBInvocationInterceptor.processInvocation(SBInvocationInterceptor.java:47)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ee.concurrent.ConcurrentContextInterceptor.processInvocation(ConcurrentContextInterceptor.java:45)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.invocation.InitialInterceptor.processInvocation(InitialInterceptor.java:40)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.invocation.ChainedInterceptor.processInvocation(ChainedInterceptor.java:53)
    at [e-mail]//org.jboss.as.ee.component.interceptors.ComponentDispatcherInterceptor.processInvocation(ComponentDispatcherInterceptor.java:52)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.component.pool.PooledInstanceInterceptor.processInvocation(PooledInstanceInterceptor.java:51)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.component.interceptors.AdditionalSetupInterceptor.processInvocation(AdditionalSetupInterceptor.java:54)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.tx.CMTTxInterceptor.invokeInCallerTx(CMTTxInterceptor.java:185)
    at [e-mail]//org.jboss.as.ejb3.tx.CMTTxInterceptor.supports(CMTTxInterceptor.java:420)
    at [e-mail]//org.jboss.as.ejb3.tx.CMTTxInterceptor.processInvocation(CMTTxInterceptor.java:148)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.component.interceptors.CurrentInvocationContextInterceptor.processInvocation(CurrentInvocationContextInterceptor.java:41)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.component.invocationmetrics.WaitTimeInterceptor.processInvocation(WaitTimeInterceptor.java:47)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.security.SecurityContextInterceptor.processInvocation(SecurityContextInterceptor.java:100)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.deployment.processors.StartupAwaitInterceptor.processInvocation(StartupAwaitInterceptor.java:22)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.component.interceptors.ShutDownInterceptorFactory$1.processInvocation(ShutDownInterceptorFactory.java:64)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.component.interceptors.LoggingInterceptor.processInvocation(LoggingInterceptor.java:67)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ee.component.NamespaceContextInterceptor.processInvocation(NamespaceContextInterceptor.java:50)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.invocation.ContextClassLoaderInterceptor.processInvocation(ContextClassLoaderInterceptor.java:60)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.invocation.InterceptorContext.run(InterceptorContext.java:438)
    at [e-mail]//org.wildfly.security.manager.WildFlySecurityManager.doChecked(WildFlySecurityManager.java:627)
    at [e-mail]//org.jboss.invocation.AccessCheckingInterceptor.processInvocation(AccessCheckingInterceptor.java:57)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.invocation.ChainedInterceptor.processInvocation(ChainedInterceptor.java:53)
    at [e-mail]//org.jboss.as.ee.component.ViewService$View.invoke(ViewService.java:198)
    at [e-mail]//org.jboss.as.ee.component.ViewDescription$1.processInvocation(ViewDescription.java:185)
    at [e-mail]//org.jboss.as.ee.component.ProxyInvocationHandler.invoke(ProxyInvocationHandler.java:81)
    at deployment.testapplication.ear.bean-rule-server.jar//com.testapplication.core.engine.remote.LocalEngineBLMgr$$$view10.executeRuleSequence(Unknown Source)
    at deployment.testapplication.ear//com.testapplication.core.engine.remote.EngineBLMgrDecorator.executeRuleSequence(EngineBLMgrDecorator.java:27)
    at deployment.testapplication.ear.bean-worker-server.jar//com.testapplication.worker.WorkItemHandler.executeRuleSequenceForItem(WorkItemHandler.java:317)
    at deployment.testapplication.ear.bean-worker-server.jar//com.testapplication.worker.WorkItemHandler.process(WorkItemHandler.java:227)
    at deployment.testapplication.ear.bean-worker-server.jar//com.testapplication.worker.WorkItemHandler.processItem(WorkItemHandler.java:89)
    at deployment.testapplication.ear.bean-worker-server.jar//com.testapplication.worker.WorkerBean.onMessage(WorkerBean.java:40)
    at jdk.internal.reflect.GeneratedMethodAccessor2983.invoke(Unknown Source)
    at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.base/java.lang.reflect.Method.invoke(Method.java:566)
    at [e-mail]//org.jboss.as.ee.component.ManagedReferenceMethodInterceptor.processInvocation(ManagedReferenceMethodInterceptor.java:52)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.component.invocationmetrics.ExecutionTimeInterceptor.processInvocation(ExecutionTimeInterceptor.java:43)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ee.concurrent.ConcurrentContextInterceptor.processInvocation(ConcurrentContextInterceptor.java:45)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.invocation.InitialInterceptor.processInvocation(InitialInterceptor.java:40)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.invocation.ChainedInterceptor.processInvocation(ChainedInterceptor.java:53)
    at [e-mail]//org.jboss.as.ee.component.interceptors.ComponentDispatcherInterceptor.processInvocation(ComponentDispatcherInterceptor.java:52)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.component.pool.PooledInstanceInterceptor.processInvocation(PooledInstanceInterceptor.java:51)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.component.interceptors.AdditionalSetupInterceptor.processInvocation(AdditionalSetupInterceptor.java:54)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.tx.CMTTxInterceptor.invokeInCallerTx(CMTTxInterceptor.java:185)
    at [e-mail]//org.jboss.as.ejb3.tx.CMTTxInterceptor.required(CMTTxInterceptor.java:364)
    at [e-mail]//org.jboss.as.ejb3.tx.CMTTxInterceptor.processInvocation(CMTTxInterceptor.java:144)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.component.interceptors.CurrentInvocationContextInterceptor.processInvocation(CurrentInvocationContextInterceptor.java:41)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.component.invocationmetrics.WaitTimeInterceptor.processInvocation(WaitTimeInterceptor.java:47)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.security.SecurityContextInterceptor.processInvocation(SecurityContextInterceptor.java:100)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.deployment.processors.StartupAwaitInterceptor.processInvocation(StartupAwaitInterceptor.java:22)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.component.interceptors.ShutDownInterceptorFactory$1.processInvocation(ShutDownInterceptorFactory.java:64)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.deployment.processors.EjbSuspendInterceptor.processInvocation(EjbSuspendInterceptor.java:57)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.component.interceptors.LoggingInterceptor.processInvocation(LoggingInterceptor.java:67)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ee.component.NamespaceContextInterceptor.processInvocation(NamespaceContextInterceptor.java:50)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.as.ejb3.component.messagedriven.MessageDrivenComponentDescription$5$1.processInvocation(MessageDrivenComponentDescription.java:252)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.invocation.ContextClassLoaderInterceptor.processInvocation(ContextClassLoaderInterceptor.java:60)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.invocation.InterceptorContext.run(InterceptorContext.java:438)
    at [e-mail]//org.wildfly.security.manager.WildFlySecurityManager.doChecked(WildFlySecurityManager.java:627)
    at [e-mail]//org.jboss.invocation.AccessCheckingInterceptor.processInvocation(AccessCheckingInterceptor.java:57)
    at [e-mail]//org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:422)
    at [e-mail]//org.jboss.invocation.ChainedInterceptor.processInvocation(ChainedInterceptor.java:53)
    at [e-mail]//org.jboss.as.ee.component.ViewService$View.invoke(ViewService.java:198)
    at [e-mail]//org.jboss.as.ee.component.ViewDescription$1.processInvocation(ViewDescription.java:185)
    at [e-mail]//org.jboss.as.ee.component.ProxyInvocationHandler.invoke(ProxyInvocationHandler.java:81)
    at deployment.testapplication.ear.bean-worker-server.jar//com.testapplication.worker.WorkerBean$$$view24.onMessage(Unknown Source)
    at jdk.internal.reflect.GeneratedMethodAccessor2983.invoke(Unknown Source)
    at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.base/java.lang.reflect.Method.invoke(Method.java:566)
    at [e-mail]//org.jboss.as.ejb3.inflow.MessageEndpointInvocationHandler.doInvoke(MessageEndpointInvocationHandler.java:139)
    at [e-mail]//org.jboss.as.ejb3.inflow.AbstractInvocationHandler.invoke(AbstractInvocationHandler.java:73)
    at deployment.testapplication.ear.bean-worker-server.jar//com.testapplication.worker.WorkerBean$$$endpoint4.onMessage(Unknown Source)
    at org.apache.activemq.artemis.ra@2.10.1//org.apache.activemq.artemis.ra.inflow.ActiveMQMessageHandler.onMessage(ActiveMQMessageHandler.java:319)
    at org.apache.activemq.artemis@2.10.1//org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.callOnMessage(ClientConsumerImpl.java:1031)
    at org.apache.activemq.artemis@2.10.1//org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.access$400(ClientConsumerImpl.java:50)
    at org.apache.activemq.artemis@2.10.1//org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl$Runner.run(ClientConsumerImpl.java:1154)
    at org.apache.activemq.artemis.journal//org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42)
    at org.apache.activemq.artemis.journal//org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31)
    at org.apache.activemq.artemis.journal//org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:66)
    at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
    at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
    at org.apache.activemq.artemis.journal//org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118)
Caused by: 4:
    at deployment.testapplication.ear//com.jcraft.jsch.ChannelSftp.ls(ChannelSftp.java:1747)
    at deployment.testapplication.ear//com.jcraft.jsch.ChannelSftp.ls(ChannelSftp.java:1553)
    at deployment.testapplication.ear//org.apache.camel.component.file.remote.SftpOperations.existsFile(SftpOperations.java:1061)
    ... 206 more
Caused by: java.io.IOException: Pipe closed
    at java.base/java.io.PipedInputStream.read(PipedInputStream.java:307)
    at deployment.testapplication.ear//com.jcraft.jsch.Channel$MyPipedInputStream.updateReadSide(Channel.java:362)
    at deployment.testapplication.ear//com.jcraft.jsch.ChannelSftp.ls(ChannelSftp.java:1570)
    ... 208 more

由于某种原因，文件传输的管道在ls()目录上的方法期间关闭。问题是isStopped()RemoteFileProducer 的方法返回 true，它只记录异常消息但不抛出它。我不知道这是怎么来的。因此，我的应用程序认为文件已成功传输，但事实并非如此。所以我希望如果我可以做类似重试机制的事情来尝试在管道损坏时再次发送文件，并且在 x 次重试之后，我想抛出异常。

标签： javaapache-camelsftp