Class EventSourcedBehaviorImpl<Command,​Event,​State>

    • Method Detail

      • $lessinit$greater$default$6

        public static <Command,​Event,​State> scala.Option<java.lang.String> $lessinit$greater$default$6()
        Used by EventSourcedBehaviorTestKit to retrieve the state. Can't be a Signal because those are not stashed.
      • $lessinit$greater$default$7

        public static <Command,​Event,​State> scala.Option<java.lang.String> $lessinit$greater$default$7()
      • $lessinit$greater$default$8

        public static <Command,​Event,​State> scala.Function1<Event,​scala.collection.immutable.Set<java.lang.String>> $lessinit$greater$default$8()
      • $lessinit$greater$default$9

        public static <Command,​Event,​State> NoOpEventAdapter<Event> $lessinit$greater$default$9()
      • $lessinit$greater$default$10

        public static <Command,​Event,​State> SnapshotAdapter<State> $lessinit$greater$default$10()
      • $lessinit$greater$default$11

        public static <Command,​Event,​State> scala.Function3<java.lang.Object,​java.lang.Object,​java.lang.Object,​java.lang.Object> $lessinit$greater$default$11()
      • $lessinit$greater$default$12

        public static <Command,​Event,​State> Recovery $lessinit$greater$default$12()
      • $lessinit$greater$default$13

        public static <Command,​Event,​State> RetentionCriteria $lessinit$greater$default$13()
      • $lessinit$greater$default$14

        public static <Command,​Event,​State> SupervisorStrategy $lessinit$greater$default$14()
      • $lessinit$greater$default$15

        public static <Command,​Event,​State> scala.PartialFunction<java.lang.Object,​scala.runtime.Nothing$> $lessinit$greater$default$15()
      • apply$default$10

        public static <Command,​Event,​State> SnapshotAdapter<State> apply$default$10()
      • apply$default$11

        public static <Command,​Event,​State> scala.Function3<java.lang.Object,​java.lang.Object,​java.lang.Object,​java.lang.Object> apply$default$11()
      • apply$default$12

        public static <Command,​Event,​State> Recovery apply$default$12()
      • apply$default$13

        public static <Command,​Event,​State> RetentionCriteria apply$default$13()
      • apply$default$14

        public static <Command,​Event,​State> SupervisorStrategy apply$default$14()
      • apply$default$15

        public static <Command,​Event,​State> scala.PartialFunction<java.lang.Object,​scala.runtime.Nothing$> apply$default$15()
      • apply$default$6

        public static <Command,​Event,​State> scala.Option<java.lang.String> apply$default$6()
      • apply$default$7

        public static <Command,​Event,​State> scala.Option<java.lang.String> apply$default$7()
      • apply$default$8

        public static <Command,​Event,​State> scala.Function1<Event,​scala.collection.immutable.Set<java.lang.String>> apply$default$8()
      • apply$default$9

        public static <Command,​Event,​State> NoOpEventAdapter<Event> apply$default$9()
      • unapply

        public static <Command,​Event,​State> scala.Option<scala.Tuple15<PersistenceId,​State,​scala.Function2<State,​Command,​Effect<Event,​State>>,​scala.Function2<State,​Event,​State>,​java.lang.Class<?>,​scala.Option<java.lang.String>,​scala.Option<java.lang.String>,​scala.Function1<Event,​scala.collection.immutable.Set<java.lang.String>>,​EventAdapter<Event,​java.lang.Object>,​SnapshotAdapter<State>,​scala.Function3<State,​Event,​java.lang.Object,​java.lang.Object>,​Recovery,​RetentionCriteria,​SupervisorStrategy,​scala.PartialFunction<scala.Tuple2<State,​Signal>,​scala.runtime.BoxedUnit>>> unapply​(EventSourcedBehaviorImpl<Command,​Event,​State> x$0)
      • emptyState

        public State emptyState()
      • eventHandler

        public scala.Function2<State,​Event,​State> eventHandler()
      • loggerClass

        public java.lang.Class<?> loggerClass()
      • journalPluginId

        public scala.Option<java.lang.String> journalPluginId()
      • snapshotPluginId

        public scala.Option<java.lang.String> snapshotPluginId()
      • tagger

        public scala.Function1<Event,​scala.collection.immutable.Set<java.lang.String>> tagger()
      • snapshotWhen

        public scala.Function3<State,​Event,​java.lang.Object,​java.lang.Object> snapshotWhen()
      • signalHandler

        public scala.PartialFunction<scala.Tuple2<State,​Signal>,​scala.runtime.BoxedUnit> signalHandler()
        Specified by:
        signalHandler in interface EventSourcedBehavior<Command,​Event,​State>
        Returns:
        The currently defined signal handler or an empty handler if no custom handler previously defined
      • initialize

        public void initialize​(ActorContext<?> context)
      • snapshotWhen

        public EventSourcedBehavior<Command,​Event,​State> snapshotWhen​(scala.Function3<State,​Event,​java.lang.Object,​java.lang.Object> predicate)
        Description copied from interface: EventSourcedBehavior
        Initiates a snapshot if the given predicate evaluates to true.

        Decide to store a snapshot based on the State, Event and sequenceNr when the event has been successfully persisted.

        When persisting multiple events at once the snapshot is triggered after all the events have been persisted.

        Snapshots triggered by snapshotWhen will not trigger deletes of old snapshots and events if EventSourcedBehavior.withRetention with RetentionCriteria.snapshotEvery is used together with snapshotWhen. Such deletes are only triggered by snapshots matching the numberOfEvents in the RetentionCriteria.

        Specified by:
        snapshotWhen in interface EventSourcedBehavior<Command,​Event,​State>
      • copy

        public <Command,​Event,​State> EventSourcedBehaviorImpl<Command,​Event,​State> copy​(PersistenceId persistenceId,
                                                                                                                State emptyState,
                                                                                                                scala.Function2<State,​Command,​Effect<Event,​State>> commandHandler,
                                                                                                                scala.Function2<State,​Event,​State> eventHandler,
                                                                                                                java.lang.Class<?> loggerClass,
                                                                                                                scala.Option<java.lang.String> journalPluginId,
                                                                                                                scala.Option<java.lang.String> snapshotPluginId,
                                                                                                                scala.Function1<Event,​scala.collection.immutable.Set<java.lang.String>> tagger,
                                                                                                                EventAdapter<Event,​java.lang.Object> eventAdapter,
                                                                                                                SnapshotAdapter<State> snapshotAdapter,
                                                                                                                scala.Function3<State,​Event,​java.lang.Object,​java.lang.Object> snapshotWhen,
                                                                                                                Recovery recovery,
                                                                                                                RetentionCriteria retention,
                                                                                                                SupervisorStrategy supervisionStrategy,
                                                                                                                scala.PartialFunction<scala.Tuple2<State,​Signal>,​scala.runtime.BoxedUnit> signalHandler)
      • copy$default$1

        public <Command,​Event,​State> PersistenceId copy$default$1()
      • copy$default$10

        public <Command,​Event,​State> SnapshotAdapter<State> copy$default$10()
      • copy$default$11

        public <Command,​Event,​State> scala.Function3<State,​Event,​java.lang.Object,​java.lang.Object> copy$default$11()
      • copy$default$12

        public <Command,​Event,​State> Recovery copy$default$12()
      • copy$default$13

        public <Command,​Event,​State> RetentionCriteria copy$default$13()
      • copy$default$14

        public <Command,​Event,​State> SupervisorStrategy copy$default$14()
      • copy$default$15

        public <Command,​Event,​State> scala.PartialFunction<scala.Tuple2<State,​Signal>,​scala.runtime.BoxedUnit> copy$default$15()
      • copy$default$2

        public <Command,​Event,​State> State copy$default$2()
      • copy$default$3

        public <Command,​Event,​State> scala.Function2<State,​Command,​Effect<Event,​State>> copy$default$3()
      • copy$default$4

        public <Command,​Event,​State> scala.Function2<State,​Event,​State> copy$default$4()
      • copy$default$5

        public <Command,​Event,​State> java.lang.Class<?> copy$default$5()
      • copy$default$6

        public <Command,​Event,​State> scala.Option<java.lang.String> copy$default$6()
      • copy$default$7

        public <Command,​Event,​State> scala.Option<java.lang.String> copy$default$7()
      • copy$default$8

        public <Command,​Event,​State> scala.Function1<Event,​scala.collection.immutable.Set<java.lang.String>> copy$default$8()
      • copy$default$9

        public <Command,​Event,​State> EventAdapter<Event,​java.lang.Object> copy$default$9()
      • productPrefix

        public java.lang.String productPrefix()
        Specified by:
        productPrefix in interface scala.Product
      • productArity

        public int productArity()
        Specified by:
        productArity in interface scala.Product
      • productElement

        public java.lang.Object productElement​(int x$1)
        Specified by:
        productElement in interface scala.Product
      • productIterator

        public scala.collection.Iterator<java.lang.Object> productIterator()
        Specified by:
        productIterator in interface scala.Product
      • canEqual

        public boolean canEqual​(java.lang.Object x$1)
        Specified by:
        canEqual in interface scala.Equals
      • productElementName

        public java.lang.String productElementName​(int x$1)
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
      • equals

        public boolean equals​(java.lang.Object x$1)
        Specified by:
        equals in interface scala.Equals
        Overrides:
        equals in class java.lang.Object