0

SFTP アダプターを使用してファイルを ftp にプッシュしようとしていますが、メッセージをチャネルに送信できませんでした。

私の構成は

<int:publish-subscribe-channel id="publishToSFTPChannel" ></int:publish-subscribe-channel>


<file:inbound-channel-adapter
directory="file:#{configurationService.configuration.getProperty('csv.export.file.location')}"
id="fileInbound" channel="publishToSFTPChannel" filename-pattern="*.csv" >
<int:poller fixed-rate="11000"  max-messages-per-poll="100"/>
</file:inbound-channel-adapter>


<int-sftp:outbound-channel-adapter id="sftpOutboundAdapter"
session-factory="sftpSessionFactory"
channel="publishToSFTPChannel"
charset="UTF-8"
remote-directory="#{csvRemoteDirectory}" 
remote-file-separator="/" order="1" />


<file:outbound-channel-adapter id="moveProcessedFile"
    channel="publishToSFTPChannel"
    directory="file:#{configurationService.configuration.getProperty('auspost.csv.export.file.location')}/${tenantId}/processed"
    delete-source-files="true" order="2" />

私が見ているエラーは

ERROR [task-scheduler-2] [ErrorHandler] unexpected exception caught
org.springframework.integration.MessageDeliveryException: failed to send message to channel 'publishToSFTPChannel' within timeout: -1
    at org.springframework.integration.core.MessagingTemplate.doSend(MessagingTemplate.java:292)
    at org.springframework.integration.core.MessagingTemplate.send(MessagingTemplate.java:149)
    at org.springframework.integration.endpoint.SourcePollingChannelAdapter.doPoll(SourcePollingChannelAdapter.java:97)
    at org.springframework.integration.endpoint.AbstractPollingEndpoint$1.call(AbstractPollingEndpoint.java:146)
    at org.springframework.integration.endpoint.AbstractPollingEndpoint$1.call(AbstractPollingEndpoint.java:144)
    at org.springframework.integration.endpoint.AbstractPollingEndpoint$Poller$1.run(AbstractPollingEndpoint.java:207)
    at org.springframework.integration.util.ErrorHandlingTaskExecutor$1.run(ErrorHandlingTaskExecutor.java:52)
    at org.springframework.core.task.SyncTaskExecutor.execute(SyncTaskExecutor.java:48)
    at org.springframework.integration.util.ErrorHandlingTaskExecutor.execute(ErrorHandlingTaskExecutor.java:49)
    at org.springframework.integration.endpoint.AbstractPollingEndpoint$Poller.run(AbstractPollingEndpoint.java:202)
    at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:53)
    at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:81)

入力してください。

4

1 に答える 1

0

この問題は、ID が重複しているためです。ID が他のアダプターと競合しています。

IDを変更し、問題を解決しました。

于 2013-09-27T07:02:52.947 に答える