Danthar

[TestFixture()]
public class ChangeModeTests : RavenTestDriver
{
    public ChangeModeTests()
    {
        ConfigureServer(new TestServerOptions()
        {
        });
    }

Danthar

    ///                      a=>process1 =>ack
    ///                     /                 \
    ///                     /                   \
    /// a=>(a)=>BROADCAST - a=>process2 =>ack  ZIP=>transform(a, completionSignal)
    ///                     \                   /
    ///                      \                 /
    ///                       a=>process3 => ack
public static Flow<I, O, NotUsed> ParralelProcessingStream<I, O>(params Flow<I, O, NotUsed>[] processingFlows)
        {
            return Flow.FromGraph(GraphDsl.Create(builder =>

Danthar

/// <summary>
    /// As translated from: https://doc.akka.io/docs/alpakka/current/patterns.html#passthrough
    /// </summary>
public class PassThroughFlow
    {
        public static IGraph<FlowShape<A, (T,A)>, NotUsed> create<A,T>(Flow<A, T, NotUsed> flow) {
            return create(flow, Keep.Both);
        }
        

Danthar

[Test]
public void Can_Serialize_ICommandResult_With_Sql_Exception()
{
  SqlException exception;
            
  try
  {

      throw SqlExceptionCreator.NewSqlException(101);
  } catch(SqlException ex)

Danthar

<Project Sdk="Microsoft.NET.Sdk">
  <PropertyGroup>
    
    <TargetsForTfmSpecificBuildOutput>$(TargetsForTfmSpecificBuildOutput);PackReferencedProjectOutputs</TargetsForTfmSpecificBuildOutput>
    
  </PropertyGroup>
  // we put this target in an props file and import it
  <Target Name="PackReferencedProjectOutputs" DependsOnTargets="BuildOnlySettings;ResolveReferences">
    <ItemGroup>
      <BuildOutputInPackage Include="@(ReferenceCopyLocalPaths-&gt;WithMetadataValue('ReferenceSourceTarget', 'ProjectReference'))" />

Danthar

<Project Sdk="Microsoft.NET.Sdk">
  <PropertyGroup>
    
    <TargetsForTfmSpecificBuildOutput>$(TargetsForTfmSpecificBuildOutput);PackReferencedProjectOutputs</TargetsForTfmSpecificBuildOutput>
    
  </PropertyGroup>
  // we put this target in an props file and import it
  <Target Name="PackReferencedProjectOutputs" DependsOnTargets="BuildOnlySettings;ResolveReferences">
    <ItemGroup>
      <BuildOutputInPackage Include="@(ReferenceCopyLocalPaths-&gt;WithMetadataValue('ReferenceSourceTarget', 'ProjectReference'))" />

Danthar

Premise:

We need an extra manifest column for EventAdapters. Because SerializerWithStringManifest type serializers are not compatible.


Findings:

EventAdapters are registered via an ActorSystem extension. And they are utilised based on an type -> adapter mapper. Which means if you want to utilise them you have to provide a mapping for the message type you want to use it on. Same concept as how serialization-bindings work.

EventAdapters are layered in the persistence system. Like a layer of a sandwich :P.

Danthar

cluster {
                seed-nodes = ["akka.tcp://TradingRoomActors@localhost:8083"]
                roles = ["traderworker"]
                singleton {
                  singleton-name = "TraderActor"
                  role = "traderworker"
                  hand-over-retry-interval = 1s
                }
                singleton-proxy {
                  singleton-name = "TradesActor"

Danthar

public class LogAttribute : ActionFilterAttribute {
        private IDictionary<string, object> parameters;
        private string description;

        public LogAttribute(string description) {
            this.description = description;
        }

        public override void OnActionExecuting(ActionExecutingContext filterContext) {
            parameters = filterContext.ActionParameters;

Danthar

 public abstract class BackoffProtocol
    {
        /// <summary>
        /// I made the TrackedMsg generic so you wont have to do manual matching in your child actor.
        /// Downside is, that it limits your communication options with the child actor.
        /// </summary>
        /// <typeparam name="T"></typeparam>
        [Serializable]
        public sealed class TrackedMsg<T>
        {