クラス DefaultEventPublicationRegistry
java.lang.ObjectSE
org.springframework.modulith.events.core.DefaultEventPublicationRegistry
- 実装されたすべてのインターフェース:
DisposableBean、CompletedEventPublications、EventPublicationRegistry
public class DefaultEventPublicationRegistry
extends ObjectSE
implements DisposableBean, EventPublicationRegistry, CompletedEventPublications
ApplicationListener へのイベントパブリケーションをキャプチャーするためのレジストリ。これらの出版物を登録し、完了済みとしてマークし、不完全な出版物を検索できます。- 作成者:
- Oliver Drotbohm, Bj ö rn Kieling, Dmitry Belyaev
コンストラクターのサマリー
コンストラクターコンストラクター説明DefaultEventPublicationRegistry(EventPublicationRepository events, ClockSE clock) 指定されたEventPublicationRepositoryの新しいDefaultEventPublicationRegistryを作成します。メソッドのサマリー
修飾子と型メソッド説明void指定されたDurationSE より前に完了した、完了したTargetEventPublicationをすべて削除します。void指定されたPredicateSE に一致するすべてのEventPublicationを削除します。voiddeletePublicationsOlderThan(DurationSE duration) 完了日が指定されたDurationSE よりも古いすべてのEventPublicationを削除します。voiddestroy()CollectionSE<? extends TargetEventPublication>findAll()すでに完了しているすべてのEventPublicationを返します。まだ完了していないすべてのTargetEventPublicationを返します。まだ完了しておらず、「現在」に関して指定された期間より前に公開されたすべてのTargetEventPublicationを返します。voidmarkCompleted(ObjectSE event, PublicationTargetIdentifier targetIdentifier) 指定されたイベントとPublicationTargetIdentifierのパブリケーションを完了としてマークします。store(ObjectSE event, StreamSE<PublicationTargetIdentifier> listeners) 指定されたイベントのTargetEventPublicationとApplicationListenerを格納します。
コンストラクターの詳細
DefaultEventPublicationRegistry
指定されたEventPublicationRepositoryの新しいDefaultEventPublicationRegistryを作成します。- パラメーター:
events- null であってはなりません。clock- null であってはなりません。
メソッドの詳細
store
public CollectionSE<TargetEventPublication> store(ObjectSE event, StreamSE<PublicationTargetIdentifier> listeners) インターフェースからコピーされた説明:EventPublicationRegistry指定されたイベントのTargetEventPublicationとApplicationListenerを格納します。- 次で指定:
- インターフェース
EventPublicationRegistryのstore - パラメーター:
event- null であってはなりません。listeners- null であってはなりません。
findIncompletePublications
インターフェースからコピーされた説明:EventPublicationRegistryまだ完了していないすべてのTargetEventPublicationを返します。- 次で指定:
- インターフェース
EventPublicationRegistryのfindIncompletePublications - 戻り値:
- null になることはありません。
findIncompletePublicationsOlderThan
public CollectionSE<TargetEventPublication> findIncompletePublicationsOlderThan(DurationSE duration) インターフェースからコピーされた説明:EventPublicationRegistryまだ完了しておらず、「現在」に関して指定された期間より前に公開されたすべてのTargetEventPublicationを返します。- 次で指定:
- インターフェース
EventPublicationRegistryのfindIncompletePublicationsOlderThan - パラメーター:
duration- null であってはなりません。- 戻り値:
- null になることはありません。
markCompleted
@Transactional(propagation=REQUIRES_NEW) public void markCompleted(ObjectSE event, PublicationTargetIdentifier targetIdentifier) インターフェースからコピーされた説明:EventPublicationRegistry指定されたイベントとPublicationTargetIdentifierのパブリケーションを完了としてマークします。- 次で指定:
- インターフェース
EventPublicationRegistryのmarkCompleted - パラメーター:
event- null であってはなりません。targetIdentifier- null であってはなりません。
deleteCompletedPublicationsOlderThan
インターフェースからコピーされた説明:EventPublicationRegistry指定されたDurationSE より前に完了した、完了したTargetEventPublicationをすべて削除します。- 次で指定:
- インターフェース
EventPublicationRegistryのdeleteCompletedPublicationsOlderThan - パラメーター:
duration- null であってはなりません。
findAll
インターフェースからコピーされた説明:CompletedEventPublicationsすでに完了しているすべてのEventPublicationを返します。- 次で指定:
- インターフェース
CompletedEventPublicationsのfindAll - 戻り値:
- null になることはありません。
deletePublications
インターフェースからコピーされた説明:CompletedEventPublications指定されたPredicateSE に一致するすべてのEventPublicationを削除します。実装では、完了したすべてのEventPublicationが反復され、メモリ内の述語が適用されることに注意してください。- 次で指定:
- インターフェース
CompletedEventPublicationsのdeletePublications - パラメーター:
filter- null であってはなりません。
deletePublicationsOlderThan
インターフェースからコピーされた説明:CompletedEventPublications完了日が指定されたDurationSE よりも古いすべてのEventPublicationを削除します。- 次で指定:
- インターフェース
CompletedEventPublicationsのdeletePublicationsOlderThan - パラメーター:
duration- null であってはなりません。
destroy
public void destroy()- 次で指定:
- インターフェース
DisposableBeanのdestroy