rogeralsing

open Akka.FSharp
open Akka
open Akka.Configuration

let system = System.create "my-system" (Configuration.defaultConfig())

let aref = 
    spawn system "my-actor" 
        (fun mailbox -> 
            let rec loop(state) = actor {

rogeralsing

Domain
	ref till Squeed.Infrastructure
	
	innehåller repos, entiteter, value objects etc
	Känner bara till IUoW	


Context
	ref till domän och EF

rogeralsing

open Akka.FSharp
open Akka
open Akka.Configuration
 
let system = System.create "my-system" (Configuration.defaultConfig())
 
let aref = 
    spawn system "my-actor" 
        (fun mailbox -> 
            let rec loop(state) = actor {

rogeralsing

using System;
using System.Threading.Tasks;
using Akka.Actor;
using Akka.TestKit;
using Xunit;

namespace Akka.Tests.Dispatch
{
    public class AsyncAwaitActor : ReceiveActor
    {

rogeralsing

using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Diagnostics;
using System.Threading;

namespace NaiveThreadPool
{
    class Program
    {

rogeralsing

Actor Plugins

Plugins let you register handlers that help initialize an actor upon start up. We are currently using this for the Stashing support.

Instead of providing AbstractUntypedStashedActor, AbstractTypedStashedActor, AbstractYaddaYaddaStashedActor etc. (F# versions etc) We can instead apply an interface to the actor type, and let the framework inject extra state holders and such. it's sort of a poor mans Mixins

Dependency Injection

rogeralsing

using System;
using System.Linq;
using System.Threading.Tasks;
using Akka.Actor;
using Akka.Routing;
using Microsoft.ServiceBus.Messaging;

namespace ConsoleApplication13
{
    public class MyBusinessActor : ReceiveActor

rogeralsing

                //other junk
                ....
                ....
                Dictionary<StatementSyntax,StatementSyntax> lookup = new Dictionary<StatementSyntax,StatementSyntax>();
                if (returnActions.Count > 0)
                {
                    foreach(var ifStatement in returnActions)
                    {
                        var mainCall = ifStatement.GetPrevious() as ExpressionStatementSyntax;                        
                        var newIfStatement = ifStatement.WithCondition(mainCall.Expression.WithoutTrivia());

rogeralsing

var references = await SymbolFinder.FindReferencesAsync(semanticClass, document.Project.Solution);

var referenceCount = (from reference in references
                      from locaton in reference.Locations
                      select locaton).Count();

rogeralsing

import akka.actor._
import com.typesafe.config.ConfigFactory

object Program {
  def main(args:Array[String]): Unit ={
    val conf = ConfigFactory.load(ConfigFactory.parseString("""
akka{
  stdout-loglevel = WARN
  loglevel = WARN
  log-config-on-start = off