クラス AbstractRemoteFileStreamingMessageSource<F>

java.lang.ObjectSE
org.springframework.integration.util.AbstractExpressionEvaluator
org.springframework.integration.endpoint.AbstractMessageSource<InputStreamSE>
org.springframework.integration.endpoint.AbstractFetchLimitingMessageSource<InputStreamSE>
org.springframework.integration.file.remote.AbstractRemoteFileStreamingMessageSource<F>
型パラメーター:
F - ターゲットプロトコルファイル型。
実装されているすべてのインターフェース:
Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、Lifecycle、MessageSource<InputStreamSE>、IntegrationPattern、NamedComponent、IntegrationInboundManagement、IntegrationManagement、ManageableLifecycle、MessageSourceManagement
既知の直属サブクラス
FtpStreamingMessageSource、SftpStreamingMessageSource、SmbStreamingMessageSource
public abstract class AbstractRemoteFileStreamingMessageSource<F> extends AbstractFetchLimitingMessageSource<InputStreamSE> implements ManageableLifecycle
リモートファイルを参照する InputStreamSE ペイロードを含むメッセージを生成するメッセージソース。
導入:
4.3
作成者:
Gary Russell, Artem Bilan, Lukas Gemela, Trung Pham

  • コンストラクターの詳細

    • AbstractRemoteFileStreamingMessageSource

      protected AbstractRemoteFileStreamingMessageSource(RemoteFileTemplate<? extends F> template, @Nullable ComparatorSE<? extends F> comparator)

  • メソッドの詳細

    • setRemoteDirectory

      public void setRemoteDirectory(StringSE remoteDirectory)
      リモートディレクトリへの絶対パスを指定します。
      パラメーター:
      remoteDirectory - リモートディレクトリ。

    • setRemoteDirectoryExpression

      public void setRemoteDirectoryExpression(Expression remoteDirectoryExpression)
      リモートディレクトリへの絶対パスに評価される式を指定します。
      パラメーター:
      remoteDirectoryExpression - リモートディレクトリ式。

    • setRemoteFileSeparator

      public void setRemoteFileSeparator(StringSE remoteFileSeparator)
      リモートファイル区切り文字を設定します。ディフォルト '/'。
      パラメーター:
      remoteFileSeparator - リモートファイル区切り。

    • setFilter

      public void setFilter(FileListFilter<F> filter)
      転送する前に、リモートファイルに適用されるフィルターを設定します。
      パラメーター:
      filter - ファイルリストフィルター。

    • doSetFilter

      protected final void doSetFilter(FileListFilter<F> filterToSet)

    • setFileInfoJson

      public void setFileInfoJson(boolean fileInfoJson)
      生の FileInfo に FileHeaders.REMOTE_FILE_INFO ヘッダーを追加するには、false に設定します。デフォルトは true で、共通のファイル情報プロパティがそのヘッダーで JSON として提供されることを意味します。
      パラメーター:
      fileInfoJson - 生オブジェクトを設定する場合は false。
      導入:
      5.0

    • setStrictOrder

      public void setStrictOrder(boolean strictOrder)
      次の AbstractMessageSource.receive() 試行で リモートファイルの処理順序を保持するために失敗した場合、ローカルキャッシュを完全にクリアする必要があるかどうかを示すフラグ。デフォルトでは、失敗したファイルのみが リモートディレクトリから再フェッチされますが、ローカルキャッシュがすでに空である場合に限り、順序が正しくありません。
      パラメーター:
      strictOrder - 失敗時にキャッシュされたファイルをクリアする必要がある場合。
      導入:
      5.5.17

    • getRemoteFileTemplate

      protected RemoteFileTemplate<? extends F> getRemoteFileTemplate()

    • onInit

      public final void onInit()
      オーバーライド:
      クラス AbstractExpressionEvaluator の onInit 

    • doInit

      protected void doInit()
      サブクラスは、InitializingBean.afterPropertiesSet() から呼び出される初期化を実行するためにオーバーライドできます。

    • start

      public void start()
      次で指定:
      インターフェース Lifecycle の start 
      次で指定:
      インターフェース ManageableLifecycle の start 

    • stop

      public void stop()
      次で指定:
      インターフェース Lifecycle の stop 
      次で指定:
      インターフェース ManageableLifecycle の stop 

    • clearFetchedCache

      public void clearFetchedCache()
      フェッチされた リモートファイルの内部キューをクリアします。この機能は、ローテーション間でフェッチされたすべてのファイルが処理されない場合に、RotatingServerAdvice と組み合わせて使用すると便利です。
      導入:
      6.4

    • isRunning

      public boolean isRunning()
      次で指定:
      インターフェース Lifecycle の isRunning 
      次で指定:
      インターフェース ManageableLifecycle の isRunning 

    • doReceive

      protected @Nullable ObjectSE doReceive(int maxFetchSize)
      クラスからコピーされた説明: AbstractFetchLimitingMessageSource
      サブクラスはこのメソッドを実装する必要があります。通常、返される値は T 型のペイロードになりますが、返される値はペイロードが T 型の Message インスタンスになることもあります。
      次で指定:
      クラス AbstractFetchLimitingMessageSource<InputStreamSE> の doReceive 
      パラメーター:
      maxFetchSize - フェッチが必要な場合にフェッチするメッセージの最大数。
      戻り値:
      返された値。

    • poll

      protected @Nullable AbstractFileInfo<F> poll()

    • remotePath

      protected StringSE remotePath(AbstractFileInfo<F> file)

    • rollbackFromFileToListEnd

      protected void rollbackFromFileToListEnd(ListSE<F> filteredFiles, F file)

    • asFileInfoList

      protected abstract ListSE<AbstractFileInfo<F>> asFileInfoList(CollectionSE<F> files)

    • isDirectory

      protected abstract boolean isDirectory(F file)