Package org.apache.pekko.persistence.testkit.javadsl

Interface PersistenceProbe<T>

public interface PersistenceProbe<T>
Not for user extension

  • Method Details

    • drain

      List<PersistenceEffect<T>> drain()
      Collect all persistence effects from the probe and empty the probe

    • expectPersisted

      PersistenceProbe<T> expectPersisted(T obj)
      Assert that the given object was persisted in the oldest persistence effect and remove that persistence effect

    • expectPersisted

      PersistenceProbe<T> expectPersisted(T obj, String tag)
      Assert that the given object was persisted with the given tag in the oldest persistence effect and remove that persistence effect. If the persistence effect has multiple tags, only one of them has to match in order for the assertion to succeed.

    • expectPersisted

      PersistenceProbe<T> expectPersisted(T obj, Set<String> tags)
      Assert that the given object was persisted with the given tag in the oldest persistence effect and remove that persistence effect. If the persistence effect has tags which are not given, the assertion fails.

    • expectPersistedClass

      <S extends T> PersistenceEffect<S> expectPersistedClass(Class<S> clazz)
      Get and remove the oldest persistence effect from the probe, failing if the persisted object is not of the requested type

    • extract

      PersistenceEffect<T> extract()
      Get and remove the oldest persistence effect from the probe

    • hasEffects

      boolean hasEffects()
      Are there any persistence effects