Class JournalSpec

Inheritance

Object

TestKitBase

TestKit

PluginSpec

JournalSpec

Implements

IActorRefFactory

IDisposable

Inherited Members

PluginSpec.ActorInstanceId

PluginSpec.FromConfig(Config)

PluginSpec.Extension

PluginSpec.Pid

PluginSpec.WriterGuid

PluginSpec.Subscribe<T>(IActorRef)

TestKit.Output

TestKit.DefaultConfig

TestKit.FullDebugConfig

TestKit.Assertions

TestKit.AfterAll()

TestKit.InitializeLogger(ActorSystem)

TestKit.InitializeLogger(ActorSystem, String)

TestKit.Dispose(Boolean)

TestKit.Dispose()

TestKitBase.InitializeTest(ActorSystem, ActorSystemSetup, String, String)

TestKitBase.InitializeTest(ActorSystem, Config, String, String)

TestKitBase.Sys

TestKitBase.TestKitSettings

TestKitBase.LastSender

TestKitBase.Now

TestKitBase.Log

TestKitBase.LastMessage

TestKitBase.TestActor

TestKitBase.EventFilter

TestKitBase.CreateEventFilter(ActorSystem)

TestKitBase.HasMessages

TestKitBase.IgnoreMessages(Func<Object, Boolean>)

TestKitBase.IgnoreMessages<TMsg>(Func<TMsg, Boolean>)

TestKitBase.IgnoreMessages<TMsg>()

TestKitBase.IgnoreNoMessages()

TestKitBase.Watch(IActorRef)

TestKitBase.WatchAsync(IActorRef)

TestKitBase.Unwatch(IActorRef)

TestKitBase.UnwatchAsync(IActorRef)

TestKitBase.SetAutoPilot(AutoPilot)

TestKitBase.RemainingOrDefault

TestKitBase.Remaining

TestKitBase.RemainingOr(TimeSpan)

TestKitBase.RemainingOrDilated(Nullable<TimeSpan>)

TestKitBase.Dilated(TimeSpan)

TestKitBase.GetTimeoutOrDefault(Nullable<TimeSpan>)

TestKitBase.Shutdown(Nullable<TimeSpan>, Boolean)

TestKitBase.Shutdown(ActorSystem, Nullable<TimeSpan>, Boolean)

TestKitBase.ChildActorOf(Props, String, SupervisorStrategy, CancellationToken)

TestKitBase.ChildActorOfAsync(Props, String, SupervisorStrategy, CancellationToken)

TestKitBase.ChildActorOf(Props, SupervisorStrategy, CancellationToken)

TestKitBase.ChildActorOfAsync(Props, SupervisorStrategy, CancellationToken)

TestKitBase.ChildActorOf(Props, String, CancellationToken)

TestKitBase.ChildActorOfAsync(Props, String, CancellationToken)

TestKitBase.ChildActorOf(Props, CancellationToken)

TestKitBase.ChildActorOfAsync(Props, CancellationToken)

TestKitBase.CreateTestActor(String)

TestKitBase.CreateTestProbe(String)

TestKitBase.CreateTestProbe(ActorSystem, String)

TestKitBase.CreateTestLatch(Int32)

TestKitBase.CreateTestBarrier(Int32)

TestKitBase.ActorOf(Props)

TestKitBase.ActorOf(Props, String)

TestKitBase.ActorOf<TActor>()

TestKitBase.ActorOf<TActor>(String)

TestKitBase.ActorOf<TActor>(Expression<Func<TActor>>)

TestKitBase.ActorOf<TActor>(Expression<Func<TActor>>, String)

TestKitBase.ActorOf(Action<IActorDsl, IActorContext>, String)

TestKitBase.ActorOf(Action<IActorDsl>, String)

TestKitBase.ActorSelection(ActorPath)

TestKitBase.ActorSelection(String)

TestKitBase.ActorSelection(IActorRef, String)

TestKitBase.ActorOfAsTestActorRef<TActor>(Props, IActorRef, String)

TestKitBase.ActorOfAsTestActorRef<TActor>(Props, String)

TestKitBase.ActorOfAsTestActorRef<TActor>(Expression<Func<TActor>>, IActorRef, String)

TestKitBase.ActorOfAsTestActorRef<TActor>(Expression<Func<TActor>>, String)

TestKitBase.ActorOfAsTestActorRef<TActor>(IActorRef, String)

TestKitBase.ActorOfAsTestActorRef<TActor>(String)

TestKitBase.ActorOfAsTestFSMRef<TFsmActor, TState, TData>(Props, IActorRef, String, Boolean)

TestKitBase.ActorOfAsTestFSMRef<TFsmActor, TState, TData>(Props, String, Boolean)

TestKitBase.ActorOfAsTestFSMRef<TFsmActor, TState, TData>(IActorRef, String, Boolean)

TestKitBase.ActorOfAsTestFSMRef<TFsmActor, TState, TData>(String, Boolean)

TestKitBase.ActorOfAsTestFSMRef<TFsmActor, TState, TData>(Expression<Func<TFsmActor>>, IActorRef, String, Boolean)

TestKitBase.ActorOfAsTestFSMRef<TFsmActor, TState, TData>(Expression<Func<TFsmActor>>, String, Boolean)

TestKitBase.AwaitAssert(Action, Nullable<TimeSpan>, Nullable<TimeSpan>, CancellationToken)

TestKitBase.AwaitAssertAsync(Action, Nullable<TimeSpan>, Nullable<TimeSpan>, CancellationToken)

TestKitBase.AwaitAssertAsync(Func<Task>, Nullable<TimeSpan>, Nullable<TimeSpan>, CancellationToken)

TestKitBase.AwaitCondition(Func<Boolean>, CancellationToken)

TestKitBase.AwaitConditionAsync(Func<Task<Boolean>>, CancellationToken)

TestKitBase.AwaitConditionAsync(Func<Boolean>, CancellationToken)

TestKitBase.AwaitCondition(Func<Boolean>, Nullable<TimeSpan>, CancellationToken)

TestKitBase.AwaitConditionAsync(Func<Task<Boolean>>, Nullable<TimeSpan>, CancellationToken)

TestKitBase.AwaitCondition(Func<Boolean>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.AwaitConditionAsync(Func<Task<Boolean>>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.AwaitConditionAsync(Func<Boolean>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.AwaitCondition(Func<Boolean>, Nullable<TimeSpan>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.AwaitConditionAsync(Func<Task<Boolean>>, Nullable<TimeSpan>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.AwaitConditionAsync(Func<Boolean>, Nullable<TimeSpan>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.AwaitConditionNoThrow(Func<Boolean>, TimeSpan, Nullable<TimeSpan>, CancellationToken)

TestKitBase.AwaitConditionNoThrowAsync(Func<Task<Boolean>>, TimeSpan, Nullable<TimeSpan>, CancellationToken)

TestKitBase.AwaitConditionNoThrowAsync(Func<Boolean>, TimeSpan, Nullable<TimeSpan>, CancellationToken)

TestKitBase.InternalAwaitCondition(Func<Boolean>, TimeSpan, Nullable<TimeSpan>, Action<String, Object[]>, CancellationToken)

TestKitBase.InternalAwaitConditionAsync(Func<Task<Boolean>>, TimeSpan, Nullable<TimeSpan>, Action<String, Object[]>, CancellationToken)

TestKitBase.InternalAwaitCondition(Func<Boolean>, TimeSpan, Nullable<TimeSpan>, Action<String, Object[]>, ILoggingAdapter, CancellationToken)

TestKitBase.InternalAwaitConditionAsync(Func<Task<Boolean>>, TimeSpan, Nullable<TimeSpan>, Action<String, Object[]>, ILoggingAdapter, CancellationToken)

TestKitBase.ExpectMsg<T>(Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectMsgAsync<T>(Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectMsg<T>(T, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectMsgAsync<T>(T, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectMsg<T>(Predicate<T>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectMsgAsync<T>(Predicate<T>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectMsg<T>(Action<T>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectMsgAsync<T>(Action<T>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectMsg<T>(Func<T, IActorRef, Boolean>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectMsgAsync<T>(Func<T, IActorRef, Boolean>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectMsg<T>(Action<T, IActorRef>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectMsgAsync<T>(Action<T, IActorRef>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectMsg<T>(T, Func<T, T, Boolean>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectMsgAsync<T>(T, Func<T, T, Boolean>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectTerminated(IActorRef, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectTerminatedAsync(IActorRef, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectNoMsg(CancellationToken)

TestKitBase.ExpectNoMsgAsync(CancellationToken)

TestKitBase.ExpectNoMsg(TimeSpan, CancellationToken)

TestKitBase.ExpectNoMsgAsync(TimeSpan, CancellationToken)

TestKitBase.ExpectNoMsg(Int32, CancellationToken)

TestKitBase.ExpectNoMsgAsync(Int32, CancellationToken)

TestKitBase.ExpectMsgAnyOf<T>(IEnumerable<T>, CancellationToken)

TestKitBase.ExpectMsgAnyOfAsync<T>(IEnumerable<T>, CancellationToken)

TestKitBase.ExpectMsgAllOf<T>(T[])

TestKitBase.ExpectMsgAllOf<T>(IReadOnlyCollection<T>, CancellationToken)

TestKitBase.ExpectMsgAllOfAsync<T>(IReadOnlyCollection<T>, CancellationToken)

TestKitBase.ExpectMsgAllOf<T>(TimeSpan, T[])

TestKitBase.ExpectMsgAllOf<T>(TimeSpan, IReadOnlyCollection<T>, CancellationToken)

TestKitBase.ExpectMsgAllOfAsync<T>(TimeSpan, IReadOnlyCollection<T>, CancellationToken)

TestKitBase.ExpectMsgAllOfMatchingPredicates(PredicateInfo[])

TestKitBase.ExpectMsgAllOfMatchingPredicates(IReadOnlyCollection<PredicateInfo>, CancellationToken)

TestKitBase.ExpectMsgAllOfMatchingPredicatesAsync(IReadOnlyCollection<PredicateInfo>, CancellationToken)

TestKitBase.ExpectMsgAllOfMatchingPredicates(TimeSpan, PredicateInfo[])

TestKitBase.ExpectMsgAllOfMatchingPredicates(TimeSpan, IReadOnlyCollection<PredicateInfo>, CancellationToken)

TestKitBase.ExpectMsgAllOfMatchingPredicatesAsync(TimeSpan, IReadOnlyCollection<PredicateInfo>, CancellationToken)

TestKitBase.ExpectMsgFrom<T>(IActorRef, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectMsgFromAsync<T>(IActorRef, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectMsgFrom<T>(IActorRef, T, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectMsgFromAsync<T>(IActorRef, T, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectMsgFrom<T>(IActorRef, Predicate<T>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectMsgFromAsync<T>(IActorRef, Predicate<T>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectMsgFrom<T>(Predicate<IActorRef>, Predicate<T>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectMsgFromAsync<T>(Predicate<IActorRef>, Predicate<T>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectMsgFrom<T>(IActorRef, Action<T>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectMsgFromAsync<T>(IActorRef, Action<T>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectMsgFrom<T>(Action<IActorRef>, Action<T>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.ExpectMsgFromAsync<T>(Action<IActorRef>, Action<T>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.FishForMessage(Predicate<Object>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.FishForMessageAsync(Predicate<Object>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.FishForMessage<T>(Predicate<T>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.FishForMessageAsync<T>(Predicate<T>, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.FishForMessage<T>(Predicate<T>, ArrayList, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.FishForMessageAsync<T>(Predicate<T>, ArrayList, Nullable<TimeSpan>, String, CancellationToken)

TestKitBase.FishUntilMessageAsync<T>(Nullable<TimeSpan>, CancellationToken)

TestKitBase.WaitForRadioSilenceAsync(Nullable<TimeSpan>, Nullable<UInt32>, CancellationToken)

TestKitBase.ReceiveOne(Nullable<TimeSpan>, CancellationToken)

TestKitBase.ReceiveOneAsync(Nullable<TimeSpan>, CancellationToken)

TestKitBase.TryReceiveOne(MessageEnvelope, Nullable<TimeSpan>, CancellationToken)

TestKitBase.TryReceiveOneAsync(Nullable<TimeSpan>, CancellationToken)

TestKitBase.PeekOne(Nullable<TimeSpan>, CancellationToken)

TestKitBase.PeekOneAsync(Nullable<TimeSpan>, CancellationToken)

TestKitBase.PeekOne(CancellationToken)

TestKitBase.PeekOneAsync(CancellationToken)

TestKitBase.TryPeekOne(MessageEnvelope, Nullable<TimeSpan>, CancellationToken)

TestKitBase.TryPeekOneAsync(Nullable<TimeSpan>, CancellationToken)

TestKitBase.ReceiveWhile<T>(Nullable<TimeSpan>, Func<Object, T>, Int32, CancellationToken)

TestKitBase.ReceiveWhileAsync<T>(Nullable<TimeSpan>, Func<Object, T>, Int32, CancellationToken)

TestKitBase.ReceiveWhile<T>(Nullable<TimeSpan>, Nullable<TimeSpan>, Func<Object, T>, Int32, CancellationToken)

TestKitBase.ReceiveWhileAsync<T>(Nullable<TimeSpan>, Nullable<TimeSpan>, Func<Object, T>, Int32, CancellationToken)

TestKitBase.ReceiveWhile<T>(Func<Object, T>, Nullable<TimeSpan>, Nullable<TimeSpan>, Int32, CancellationToken)

TestKitBase.ReceiveWhileAsync<T>(Func<Object, T>, Nullable<TimeSpan>, Nullable<TimeSpan>, Int32, CancellationToken)

TestKitBase.ReceiveWhile<T>(Predicate<T>, Nullable<TimeSpan>, Nullable<TimeSpan>, Int32, Boolean, CancellationToken)

TestKitBase.ReceiveWhileAsync<T>(Predicate<T>, Nullable<TimeSpan>, Nullable<TimeSpan>, Int32, Boolean, CancellationToken)

TestKitBase.ReceiveN(Int32, CancellationToken)

TestKitBase.ReceiveNAsync(Int32, CancellationToken)

TestKitBase.ReceiveN(Int32, TimeSpan, CancellationToken)

TestKitBase.ReceiveNAsync(Int32, TimeSpan, CancellationToken)

TestKitBase.Within(TimeSpan, Action, Nullable<TimeSpan>, CancellationToken)

TestKitBase.WithinAsync(TimeSpan, Func<Task>, Nullable<TimeSpan>, CancellationToken)

TestKitBase.Within(TimeSpan, TimeSpan, Action, String, Nullable<TimeSpan>, CancellationToken)

TestKitBase.WithinAsync(TimeSpan, TimeSpan, Func<Task>, String, Nullable<TimeSpan>, CancellationToken)

TestKitBase.Within<T>(TimeSpan, Func<T>, Nullable<TimeSpan>, CancellationToken)

TestKitBase.WithinAsync<T>(TimeSpan, Func<Task<T>>, Nullable<TimeSpan>, CancellationToken)

TestKitBase.Within<T>(TimeSpan, TimeSpan, Func<T>, String, Nullable<TimeSpan>, CancellationToken)

TestKitBase.WithinAsync<T>(TimeSpan, TimeSpan, Func<Task<T>>, String, Nullable<TimeSpan>, CancellationToken)

Object.Equals(Object)

Object.Equals(Object, Object)

Object.GetHashCode()

Object.GetType()

Object.MemberwiseClone()

Object.ReferenceEquals(Object, Object)

Object.ToString()

Namespace: Akka.Persistence.TCK.Journal

Assembly: Akka.Persistence.TCK.dll

Syntax

public abstract class JournalSpec : PluginSpec, IActorRefFactory, IDisposable

Constructors

JournalSpec(ActorSystem, ITestOutputHelper)

Declaration

protected JournalSpec(ActorSystem system = null, ITestOutputHelper output = null)

Parameters

Type	Name	Description
ActorSystem	system
Xunit.Abstractions.ITestOutputHelper	output

JournalSpec(ActorSystemSetup, String, ITestOutputHelper)

Declaration

protected JournalSpec(ActorSystemSetup setup, string actorSystemName = null, ITestOutputHelper output = null)

Parameters

Type	Name	Description
ActorSystemSetup	setup
String	actorSystemName
Xunit.Abstractions.ITestOutputHelper	output

JournalSpec(Config, String, ITestOutputHelper)

Declaration

protected JournalSpec(Config config = null, string actorSystemName = null, ITestOutputHelper output = null)

Parameters

Type	Name	Description
Config	config
String	actorSystemName
Xunit.Abstractions.ITestOutputHelper	output

JournalSpec(Type, String, ITestOutputHelper)

Declaration

protected JournalSpec(Type journalType, string actorSystemName = null, ITestOutputHelper output = null)

Parameters

Type	Name	Description
Type	journalType
String	actorSystemName
Xunit.Abstractions.ITestOutputHelper	output

Fields

Config

Declaration

protected static readonly Config Config

Field Value

Type	Description
Config

Properties

Journal

Declaration

protected IActorRef Journal { get; }

Property Value

Type	Description
IActorRef

SupportsAtomicPersistAllOfSeveralEvents

Implementation may override and return false if it does not support atomic writes of several events, as emitted by PersistAll<TEvent>(IEnumerable<TEvent>, Action<TEvent>).

Declaration

protected virtual bool SupportsAtomicPersistAllOfSeveralEvents { get; }

Property Value

Type	Description
Boolean

SupportsRejectingNonSerializableObjects

When true enables tests which check if the Journal properly rejects writes of objects which are not serializable.

Declaration

protected virtual bool SupportsRejectingNonSerializableObjects { get; }

Property Value

Type	Description
Boolean

SupportsSerialization

Declaration

protected override bool SupportsSerialization { get; }

Property Value

Type	Description
Boolean

Overrides

PluginSpec.SupportsSerialization

Methods

Initialize()

Initializes a journal with set o predefined messages.

Declaration

protected IEnumerable<AtomicWrite> Initialize()

Returns

Type	Description
IEnumerable<AtomicWrite>

IsReplayedMessage(ReplayedMessage, Int64, Boolean)

Declaration

protected bool IsReplayedMessage(ReplayedMessage message, long seqNr, bool isDeleted = false)

Parameters

Type	Name	Description
ReplayedMessage	message
Int64	seqNr
Boolean	isDeleted

Returns

Type	Description
Boolean

Journal_optionally_may_reject_non_serializable_events()

Declaration

[Fact]
public virtual void Journal_optionally_may_reject_non_serializable_events()

Journal_should_not_replay_messages_if_count_limit_equals_zero()

Declaration

[Fact]
public virtual void Journal_should_not_replay_messages_if_count_limit_equals_zero()

Journal_should_not_replay_messages_if_lower_sequence_number_bound_is_greater_than_upper_sequence_number_bound()

Declaration

[Fact]
public virtual void Journal_should_not_replay_messages_if_lower_sequence_number_bound_is_greater_than_upper_sequence_number_bound()

Journal_should_not_replay_messages_if_the_persistent_actor_has_not_yet_written_messages()

Declaration

[Fact]
public virtual void Journal_should_not_replay_messages_if_the_persistent_actor_has_not_yet_written_messages()

Journal_should_not_replay_permanently_deleted_messages_on_range_deletion()

Declaration

[Fact]
public virtual void Journal_should_not_replay_permanently_deleted_messages_on_range_deletion()

Journal_should_not_reset_HighestSequenceNr_after_journal_cleanup()

Declaration

[Fact]
public virtual void Journal_should_not_reset_HighestSequenceNr_after_journal_cleanup()

Journal_should_not_reset_HighestSequenceNr_after_message_deletion()

Declaration

[Fact]
public virtual void Journal_should_not_reset_HighestSequenceNr_after_message_deletion()

Journal_should_replay_a_single_if_lower_sequence_number_bound_equals_upper_sequence_number_bound()

Declaration

[Fact]
public virtual void Journal_should_replay_a_single_if_lower_sequence_number_bound_equals_upper_sequence_number_bound()

Journal_should_replay_a_single_message_if_count_limit_is_equal_one()

Declaration

[Fact]
public virtual void Journal_should_replay_a_single_message_if_count_limit_is_equal_one()

Journal_should_replay_all_messages()

Declaration

[Fact]
public virtual void Journal_should_replay_all_messages()

Journal_should_replay_messages_using_a_count_limit()

Declaration

[Fact]
public virtual void Journal_should_replay_messages_using_a_count_limit()

Journal_should_replay_messages_using_a_lower_sequence_number_bound()

Declaration

[Fact]
public virtual void Journal_should_replay_messages_using_a_lower_sequence_number_bound()

Journal_should_replay_messages_using_an_upper_sequence_number_bound()

Declaration

[Fact]
public virtual void Journal_should_replay_messages_using_an_upper_sequence_number_bound()

Journal_should_replay_messages_using_lower_and_upper_sequence_number_bound()

Declaration

[Fact]
public virtual void Journal_should_replay_messages_using_lower_and_upper_sequence_number_bound()

Journal_should_replay_messages_using_lower_and_upper_sequence_number_bound_and_count_limit()

Declaration

[Fact]
public virtual void Journal_should_replay_messages_using_lower_and_upper_sequence_number_bound_and_count_limit()

Journal_should_serialize_events()

Declaration

[Fact]
public virtual void Journal_should_serialize_events()

PreparePersistenceId(String)

Overridable hook that is called before populating the journal for the next test case. pid is the persistenceId that will be used in the test. This method may be needed to clean pre-existing events from the log.

Declaration

protected virtual void PreparePersistenceId(string pid)

Parameters

Type	Name	Description
String	pid

Implements

IActorRefFactory

IDisposable

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(Object)