F - リモートファイルを表す Type。public abstract class AbstractInboundFileSynchronizer<F> extends ObjectSE implements InboundFileSynchronizer, BeanFactoryAware, BeanNameAware, InitializingBean, CloseableSE
実装は、構成された FileListFilter を実行して、ファイルエントリが受け入れられることを確認する必要があります。
| 修飾子と型 | フィールドと説明 |
|---|---|
protected static ExpressionParser | EXPRESSION_PARSER |
protected Log | logger |
| コンストラクターと説明 |
|---|
AbstractInboundFileSynchronizer(SessionFactory<F> sessionFactory)Session インスタンスの取得に使用される SessionFactory でシンクロナイザーを作成します。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
void | afterPropertiesSet() |
void | close() |
protected boolean | copyFileToLocalDirectory(StringSE remoteDirectoryPath, F remoteFile, FileSE localDirectory, Session<F> session) |
protected void | doInit() サブクラスは、 InitializingBean.afterPropertiesSet() から呼び出される初期化を実行するためにオーバーライドできます。 |
protected void | doSetFilter(FileListFilter<F> filterToSet) |
protected void | doSetRemoteDirectoryExpression(Expression expression) |
protected void | evaluateRemoteDirectory() |
protected ListSE<F> | filterFiles(F[] files) |
protected ComparatorSE<F> | getComparator() |
protected abstract StringSE | getFilename(F file) |
protected abstract long | getModified(F file) |
StringSE | getRemoteFileMetadata(FileSE localFile) 指定されたローカルファイルに関連付けられたリモートファイルのメタデータを取得します。 |
protected StringSE | getTemporaryFileSuffix() |
protected abstract boolean | isFile(F file) |
protected abstract StringSE | protocol() このシンクロナイザーが動作するプロトコルを返します。 |
void | removeRemoteFileMetadata(FileSE localFile) 指定されたローカルファイルに関連付けられているリモートファイルのメタデータを削除します。 |
protected void | rollbackFromFileToListEnd(ListSE<F> filteredFiles, F file) |
void | setBeanFactory(BeanFactory beanFactory) |
void | setBeanName(StringSE name) |
void | setComparator(ComparatorSE<F> comparator) フィルターと最大フェッチサイズを適用する前に、 F (リモートファイルを表す型)の取得リストをソートするコンパレーターを設定します。 |
void | setDeleteRemoteFiles(boolean deleteRemoteFiles) 転送に成功した後、リモートファイルの削除を有効にするには、true に設定します。 |
void | setFilter(FileListFilter<F> filter) 転送する前に、リモートファイルに適用されるフィルターを設定します。 |
void | setLocalFilenameGeneratorExpression(Expression localFilenameGeneratorExpression) ローカルファイル名を決定するために使用される式を設定します。 |
void | setLocalFilenameGeneratorExpressionString(StringSE localFilenameGeneratorExpression) ローカルファイル名を決定するために使用される式を設定します。 |
void | setMetadataStorePrefix(StringSE metadataStorePrefix) 共有ストア内の他のキーと衝突しないメタデータストア内のキーのプレフィックスを指定します。 |
void | setPreserveTimestamp(boolean preserveTimestamp)true に設定すると、転送時にリモートファイルのタイムスタンプの保存が有効になります。 |
void | setRemoteDirectory(StringSE remoteDirectory) リモートディレクトリへの絶対パスを指定します。 |
void | setRemoteDirectoryExpression(Expression remoteDirectoryExpression) リモートディレクトリへの絶対パスに評価される式を指定します。 |
void | setRemoteDirectoryExpressionString(StringSE remoteDirectoryExpression) リモートディレクトリへの絶対パスに評価される式を指定します。 |
void | setRemoteFileMetadataStore(MetadataStore remoteFileMetadataStore)MetadataStore がリモートファイル情報(ホスト、ポート、リモートディレクトリ)を保持するように構成し、ローカルファイルがプルされたときにメッセージヘッダーでダウンストリームを転送します。 |
void | setRemoteFileSeparator(StringSE remoteFileSeparator) |
void | setTemporaryFileSuffix(StringSE temporaryFileSuffix) ファイルの転送中に使用される一時ファイルのサフィックスを設定します。 |
void | synchronizeToLocalDirectory(FileSE localDirectory) 利用可能なすべてのファイルをローカルディレクトリに同期します。 |
void | synchronizeToLocalDirectory(FileSE localDirectory, int maxFetchSize) 最大 maxFetchSize のファイルをローカルディレクトリに同期します。 |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEprotected static final ExpressionParser EXPRESSION_PARSER
protected final Log logger
public AbstractInboundFileSynchronizer(SessionFactory<F> sessionFactory)
Session インスタンスの取得に使用される SessionFactory でシンクロナイザーを作成します。sessionFactory - セッションファクトリ。@Nullable protected ComparatorSE<F> getComparator()
public void setComparator(@Nullable ComparatorSE<F> comparator)
F (リモートファイルを表す型)の取得リストをソートするコンパレーターを設定します。comparator - コンパレータ。public void setRemoteFileSeparator(StringSE remoteFileSeparator)
remoteFileSeparator - リモートファイル区切り。RemoteFileTemplate.setRemoteFileSeparator(String)public void setLocalFilenameGeneratorExpression(Expression localFilenameGeneratorExpression)
localFilenameGeneratorExpression - 表現。public void setLocalFilenameGeneratorExpressionString(StringSE localFilenameGeneratorExpression)
localFilenameGeneratorExpression - 表現。setRemoteDirectoryExpression(Expression)public void setTemporaryFileSuffix(StringSE temporaryFileSuffix)
temporaryFileSuffix - ファイルのサフィックス。public void setRemoteDirectory(StringSE remoteDirectory)
remoteDirectory - リモートディレクトリ。public void setRemoteDirectoryExpression(Expression remoteDirectoryExpression)
remoteDirectoryExpression - リモートディレクトリ式。public void setRemoteDirectoryExpressionString(StringSE remoteDirectoryExpression)
remoteDirectoryExpression - リモートディレクトリ式。setRemoteDirectoryExpression(Expression)protected final void doSetRemoteDirectoryExpression(Expression expression)
public void setFilter(@Nullable FileListFilter<F> filter)
filter - ファイルリストフィルター。protected final void doSetFilter(@Nullable FileListFilter<F> filterToSet)
public void setDeleteRemoteFiles(boolean deleteRemoteFiles)
deleteRemoteFiles - 削除する場合は true。public void setPreserveTimestamp(boolean preserveTimestamp)
preserveTimestamp - 保存するために本当。public void setRemoteFileMetadataStore(MetadataStore remoteFileMetadataStore)
MetadataStore がリモートファイル情報(ホスト、ポート、リモートディレクトリ)を保持するように構成し、ローカルファイルがプルされたときにメッセージヘッダーでダウンストリームを転送します。remoteFileMetadataStore - 使用する MetadataStore。public void setMetadataStorePrefix(StringSE metadataStorePrefix)
metadataStorePrefix - 使用する接頭辞。setRemoteFileMetadataStore(MetadataStore)public void setBeanFactory(BeanFactory beanFactory) throws BeansException
BeanFactoryAware の setBeanFactory BeansExceptionpublic void setBeanName(StringSE name)
BeanNameAware の setBeanName public final void afterPropertiesSet()
InitializingBean の afterPropertiesSet protected void doInit()
InitializingBean.afterPropertiesSet() から呼び出される初期化を実行するためにオーバーライドできます。protected StringSE getTemporaryFileSuffix()
public void close()
throws IOExceptionSECloseableSE の closeSE AutoCloseableSE の closeSE IOExceptionSEpublic void synchronizeToLocalDirectory(FileSE localDirectory)
InboundFileSynchronizerInboundFileSynchronizer の synchronizeToLocalDirectory localDirectory - ディレクトリ。public void synchronizeToLocalDirectory(FileSE localDirectory, int maxFetchSize)
InboundFileSynchronizerInboundFileSynchronizer の synchronizeToLocalDirectory localDirectory - ディレクトリ。maxFetchSize - 取得するファイルの最大数 protected boolean copyFileToLocalDirectory(StringSE remoteDirectoryPath, F remoteFile, FileSE localDirectory, Session<F> session) throws IOExceptionSE
protected void evaluateRemoteDirectory()
@Nullable public StringSE getRemoteFileMetadata(FileSE localFile)
localFile - メタデータを取得するローカルファイル。protocol://host:port/remoteDirectory#remoteFileNamepublic void removeRemoteFileMetadata(FileSE localFile)
localFile - メタデータを削除するローカルファイル。protected abstract boolean isFile(F file)
protected abstract long getModified(F file)
protected abstract StringSE protocol()