クラス AbstractRemoteFileStreamingMessageSource<F>
java.lang.ObjectSE
org.springframework.integration.util.AbstractExpressionEvaluator
org.springframework.integration.endpoint.AbstractMessageSource<T>
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
public abstract class AbstractRemoteFileStreamingMessageSource<F>
extends AbstractFetchLimitingMessageSource<InputStreamSE>
implements ManageableLifecycle
リモートファイルを参照する
InputStream
SE ペイロードを含むメッセージを生成するメッセージソース。- 導入:
- 4.3
- 作成者:
- Gary Russell, Artem Bilan, Lukas Gemela, Trung Pham
ネストされたクラスのサマリー
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース
IntegrationManagement.ManagementOverrides
フィールドサマリー
クラス org.springframework.integration.util.AbstractExpressionEvaluator から継承されたフィールド
EXPRESSION_PARSER, logger
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
コンストラクターのサマリー
修飾子コンストラクター説明protected
AbstractRemoteFileStreamingMessageSource
(RemoteFileTemplate<? extends F> template, ComparatorSE<? extends F> comparator) メソッドのサマリー
修飾子と型メソッド説明protected abstract ListSE<AbstractFileInfo<F>>
asFileInfoList
(CollectionSE<F> files) protected void
doInit()
サブクラスは、InitializingBean.afterPropertiesSet()
から呼び出される初期化を実行するためにオーバーライドできます。protected ObjectSE
doReceive
(int maxFetchSize) サブクラスはこのメソッドを実装する必要があります。protected final void
doSetFilter
(FileListFilter<F> filterToSet) protected RemoteFileTemplate<? extends F>
protected abstract boolean
isDirectory
(F file) boolean
final void
onInit()
protected AbstractFileInfo<F>
poll()
protected StringSE
remotePath
(AbstractFileInfo<F> file) protected void
rollbackFromFileToListEnd
(ListSE<F> filteredFiles, F file) void
setFileInfoJson
(boolean fileInfoJson) void
setFilter
(FileListFilter<F> filter) 転送する前に、リモートファイルに適用されるフィルターを設定します。void
setRemoteDirectory
(StringSE remoteDirectory) リモートディレクトリへの絶対パスを指定します。void
setRemoteDirectoryExpression
(Expression remoteDirectoryExpression) リモートディレクトリへの絶対パスに評価される式を指定します。void
setRemoteFileSeparator
(StringSE remoteFileSeparator) リモートファイル区切り文字を設定します。ディフォルト '/'。void
setStrictOrder
(boolean strictOrder) 次のAbstractMessageSource.receive()
試行で リモートファイルの処理順序を保持するために失敗した場合、ローカルキャッシュを完全にクリアする必要があるかどうかを示すフラグ。void
start()
void
stop()
クラス org.springframework.integration.endpoint.AbstractFetchLimitingMessageSource から継承されたメソッド
doReceive, getMaxFetchSize, setMaxFetchSize
クラス org.springframework.integration.endpoint.AbstractMessageSource から継承されたメソッド
buildMessage, destroy, getBeanName, getComponentName, getManagedName, getManagedType, getOverrides, isLoggingEnabled, receive, registerMetricsCaptor, setBeanName, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedType
クラス org.springframework.integration.util.AbstractExpressionEvaluator から継承されたメソッド
afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, setBeanFactory, setConversionService
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド
getThisAs, isObserved, registerObservationRegistry
インターフェース org.springframework.integration.core.MessageSource から継承されたメソッド
getIntegrationPatternType
インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド
getComponentType
コンストラクターの詳細
AbstractRemoteFileStreamingMessageSource
protected AbstractRemoteFileStreamingMessageSource(RemoteFileTemplate<? extends F> template, @Nullable ComparatorSE<? extends F> comparator)
メソッドの詳細
setRemoteDirectory
リモートディレクトリへの絶対パスを指定します。- パラメーター:
remoteDirectory
- リモートディレクトリ。
setRemoteDirectoryExpression
リモートディレクトリへの絶対パスに評価される式を指定します。- パラメーター:
remoteDirectoryExpression
- リモートディレクトリ式。
setRemoteFileSeparator
リモートファイル区切り文字を設定します。ディフォルト '/'。- パラメーター:
remoteFileSeparator
- リモートファイル区切り。
setFilter
転送する前に、リモートファイルに適用されるフィルターを設定します。- パラメーター:
filter
- ファイルリストフィルター。
doSetFilter
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
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
isRunning
public boolean isRunning()- 次で指定:
- インターフェース
Lifecycle
のisRunning
- 次で指定:
- インターフェース
ManageableLifecycle
のisRunning
doReceive
クラスからコピーされた説明:AbstractFetchLimitingMessageSource
サブクラスはこのメソッドを実装する必要があります。通常、戻り値は型 T のペイロードですが、戻り値はペイロードが型 T のメッセージインスタンスでもかまいません。- 次で指定:
- クラス
AbstractFetchLimitingMessageSource<InputStreamSE>
のdoReceive
- パラメーター:
maxFetchSize
- フェッチが必要な場合にフェッチするメッセージの最大数。- 戻り値:
- 返された値。
poll
remotePath
rollbackFromFileToListEnd
asFileInfoList
isDirectory