クラス JdbcEventPublicationRepository
java.lang.ObjectSE
org.springframework.modulith.events.jdbc.JdbcEventPublicationRepository
- 実装されたすべてのインターフェース:
Aware
、BeanClassLoaderAware
、EventPublicationRepository
class JdbcEventPublicationRepository
extends ObjectSE
implements EventPublicationRepository, BeanClassLoaderAware
TargetEventPublication
を保存するための JDBC ベースのリポジトリ。- 作成者:
- Dmitry Belyaev, Bj ö rn Kieling, Oliver Drotbohm
コンストラクターのサマリー
コンストラクター説明JdbcEventPublicationRepository
(JdbcOperations operations, EventSerializer serializer, DatabaseType databaseType) メソッドのサマリー
修飾子と型メソッド説明create
(TargetEventPublication publication) 指定されたTargetEventPublication
を永続化します。void
すでに完了としてマークされているパブリケーションをすべて削除します。void
完了日が指定された日より前の、すでに完了済みとしてマークされているパブリケーションをすべて削除します。void
deletePublications
(ListSE<UUIDSE> identifiers) 指定された識別子を持つすべてのパブリケーションを削除します。現在システム内で見つかった完了したイベントパブリケーションをすべて返します。まだ完了していないすべてのTargetEventPublication
を返します。findIncompletePublicationsByEventAndTargetIdentifier
(ObjectSE event, PublicationTargetIdentifier targetIdentifier) 指定された直列化されたイベントおよびリスナー ID の不完全なTargetEventPublication
を返します。完了しておらず、指定されたInstant
SE より前に公開されたすべてのTargetEventPublication
を返します。void
markCompleted
(ObjectSE event, PublicationTargetIdentifier identifier, InstantSE completionDate) 指定されたイベントおよびPublicationTargetIdentifier
のパブリケーションが指定されたInstant
SE で完了するようにマークします。void
setBeanClassLoader
(ClassLoaderSE classLoader) クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース org.springframework.modulith.events.core.EventPublicationRepository から継承されたメソッド
markCompleted
コンストラクターの詳細
JdbcEventPublicationRepository
public JdbcEventPublicationRepository(JdbcOperations operations, EventSerializer serializer, DatabaseType databaseType) - パラメーター:
operations
- null であってはなりません。serializer
- null であってはなりません。databaseType
- null であってはなりません。
メソッドの詳細
setBeanClassLoader
- 次で指定:
- インターフェース
BeanClassLoaderAware
のsetBeanClassLoader
create
インターフェースからコピーされた説明:EventPublicationRepository
指定されたTargetEventPublication
を永続化します。- 次で指定:
- インターフェース
EventPublicationRepository
のcreate
- パラメーター:
publication
- null であってはなりません。- 戻り値:
- null になることはありません。
markCompleted
@Transactional public void markCompleted(ObjectSE event, PublicationTargetIdentifier identifier, InstantSE completionDate) インターフェースからコピーされた説明:EventPublicationRepository
指定されたイベントおよびPublicationTargetIdentifier
のパブリケーションが指定されたInstant
SE で完了するようにマークします。- 次で指定:
- インターフェース
EventPublicationRepository
のmarkCompleted
- パラメーター:
event
- null であってはなりません。identifier
- null であってはなりません。completionDate
- null であってはなりません。
findIncompletePublicationsByEventAndTargetIdentifier
@Transactional(readOnly=true) public OptionalSE<TargetEventPublication> findIncompletePublicationsByEventAndTargetIdentifier(ObjectSE event, PublicationTargetIdentifier targetIdentifier) インターフェースからコピーされた説明:EventPublicationRepository
指定された直列化されたイベントおよびリスナー ID の不完全なTargetEventPublication
を返します。- 次で指定:
- インターフェース
EventPublicationRepository
のfindIncompletePublicationsByEventAndTargetIdentifier
- パラメーター:
event
- null であってはなりません。targetIdentifier
- null であってはなりません。- 戻り値:
- null になることはありません。
findCompletedPublications
インターフェースからコピーされた説明:EventPublicationRepository
現在システム内で見つかった完了したイベントパブリケーションをすべて返します。- 次で指定:
- インターフェース
EventPublicationRepository
のfindCompletedPublications
- 戻り値:
- null になることはありません。
findIncompletePublications
インターフェースからコピーされた説明:EventPublicationRepository
まだ完了していないすべてのTargetEventPublication
を返します。- 次で指定:
- インターフェース
EventPublicationRepository
のfindIncompletePublications
- 戻り値:
- null になることはありません。
findIncompletePublicationsPublishedBefore
インターフェースからコピーされた説明:EventPublicationRepository
完了しておらず、指定されたInstant
SE より前に公開されたすべてのTargetEventPublication
を返します。- 次で指定:
- インターフェース
EventPublicationRepository
のfindIncompletePublicationsPublishedBefore
- パラメーター:
instant
- null であってはなりません。- 戻り値:
- null になることはありません。
deletePublications
インターフェースからコピーされた説明:EventPublicationRepository
指定された識別子を持つすべてのパブリケーションを削除します。- 次で指定:
- インターフェース
EventPublicationRepository
のdeletePublications
- パラメーター:
identifiers
- null であってはなりません。
deleteCompletedPublications
public void deleteCompletedPublications()インターフェースからコピーされた説明:EventPublicationRepository
すでに完了としてマークされているパブリケーションをすべて削除します。- 次で指定:
- インターフェース
EventPublicationRepository
のdeleteCompletedPublications
deleteCompletedPublicationsBefore
インターフェースからコピーされた説明:EventPublicationRepository
完了日が指定された日より前の、すでに完了済みとしてマークされているパブリケーションをすべて削除します。- 次で指定:
- インターフェース
EventPublicationRepository
のdeleteCompletedPublicationsBefore
- パラメーター:
instant
- null であってはなりません。