public abstract class AbstractRemoteFileStreamingMessageSource<F> extends AbstractFetchLimitingMessageSource<InputStreamSE> implements ManageableLifecycle
InputStream
SE ペイロードを含むメッセージを生成するメッセージソース。IntegrationManagement.ManagementOverrides
EXPRESSION_PARSER, logger
METER_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, setMaxFetchSize
buildMessage, destroy, getBeanName, getComponentName, getManagedName, getManagedType, getOverrides, isLoggingEnabled, receive, registerMetricsCaptor, setBeanName, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedType
afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, setBeanFactory, setConversionService
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
getIntegrationPatternType
getThisAs
getComponentType
protected 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)
AbstractFetchLimitingMessageSource
AbstractFetchLimitingMessageSource<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)