public abstract class AbstractRemoteFileStreamingMessageSource<F> extends AbstractFetchLimitingMessageSource<InputStreamSE> implements ManageableLifecycle
InputStreamSE ペイロードを含むメッセージを生成するメッセージソース。IntegrationManagement.ManagementOverridesEXPRESSION_PARSER, loggerMETER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME| 修飾子 | コンストラクターと説明 |
|---|---|
protected | AbstractRemoteFileStreamingMessageSource(RemoteFileTemplate<F> template, ComparatorSE<F> comparator) |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected abstract ListSE<AbstractFileInfo<F>> | asFileInfoList(CollectionSE<F> files) |
protected void | doInit() サブクラスは、 InitializingBean.afterPropertiesSet() から呼び出される初期化を実行するためにオーバーライドできます。 |
protected ObjectSE | doReceive(int maxFetchSize) サブクラスはこのメソッドを実装する必要があります。 |
protected void | doSetFilter(FileListFilter<F> filterToSet) |
protected RemoteFileTemplate<F> | getRemoteFileTemplate() |
protected abstract boolean | isDirectory(F file) |
boolean | isRunning() |
void | onInit() |
protected AbstractFileInfo<F> | poll() |
protected StringSE | remotePath(AbstractFileInfo<F> file) |
protected void | rollbackFromFileToListEnd(ListSE<F> filteredFiles, F file) |
void | setFileInfoJson(boolean fileInfoJson)FileHeaders.REMOTE_FILE_INFO ヘッダーを未加工の FileInfo に追加するには、false に設定します。 |
void | setFilter(FileListFilter<F> filter) 転送する前に、リモートファイルに適用されるフィルターを設定します。 |
void | setRemoteDirectory(StringSE remoteDirectory) リモートディレクトリへの絶対パスを指定します。 |
void | setRemoteDirectoryExpression(Expression remoteDirectoryExpression) リモートディレクトリへの絶対パスに評価される式を指定します。 |
void | setRemoteFileSeparator(StringSE remoteFileSeparator) リモートファイル区切りを設定します。デフォルト '/' |
void | start() |
void | stop() |
doReceive, getMaxFetchSize, setMaxFetchSizebuildMessage, destroy, getBeanName, getComponentName, getManagedName, getManagedType, getOverrides, isLoggingEnabled, receive, registerMetricsCaptor, setBeanName, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedTypeafterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, setBeanFactory, setConversionServicecloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEgetIntegrationPatternTypegetThisAsgetComponentTypeprotected AbstractRemoteFileStreamingMessageSource(RemoteFileTemplate<F> template, @Nullable ComparatorSE<F> comparator)
public void setRemoteDirectory(StringSE remoteDirectory)
remoteDirectory - リモートディレクトリ。public void setRemoteDirectoryExpression(Expression remoteDirectoryExpression)
remoteDirectoryExpression - リモートディレクトリ式。public void setRemoteFileSeparator(StringSE remoteFileSeparator)
remoteFileSeparator - リモートファイル区切り。public void setFilter(FileListFilter<F> filter)
filter - ファイルリストフィルター。protected final void doSetFilter(FileListFilter<F> filterToSet)
public void setFileInfoJson(boolean fileInfoJson)
FileHeaders.REMOTE_FILE_INFO ヘッダーを未加工の FileInfo に追加するには、false に設定します。デフォルトは true です。これは、共通のファイル情報プロパティが JSON としてそのヘッダーで提供されることを意味します。fileInfoJson - 生オブジェクトを設定する場合は false。protected RemoteFileTemplate<F> getRemoteFileTemplate()
public final void onInit()
AbstractExpressionEvaluator の onInit protected void doInit()
InitializingBean.afterPropertiesSet() から呼び出される初期化を実行するためにオーバーライドできます。public void start()
Lifecycle 内の start ManageableLifecycle 内の start public void stop()
Lifecycle 内の stop ManageableLifecycle 内の stop public boolean isRunning()
Lifecycle 内の isRunning ManageableLifecycle 内の isRunning protected ObjectSE doReceive(int maxFetchSize)
AbstractFetchLimitingMessageSourceAbstractFetchLimitingMessageSource<InputStreamSE> の doReceive maxFetchSize - フェッチが必要な場合にフェッチするメッセージの最大数。protected AbstractFileInfo<F> poll()
protected StringSE remotePath(AbstractFileInfo<F> file)
protected abstract ListSE<AbstractFileInfo<F>> asFileInfoList(CollectionSE<F> files)
protected abstract boolean isDirectory(F file)