Akka.Persistence 0.8.0-pre1502120115

The ID prefix of this package has been reserved for one of the owners of this package by NuGet.org. Prefix Reserved
This is a prerelease version of Akka.Persistence.
There is a newer version of this package available.
See the version list below for details.
dotnet add package Akka.Persistence --version 0.8.0-pre1502120115
NuGet\Install-Package Akka.Persistence -Version 0.8.0-pre1502120115
This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package.
<PackageReference Include="Akka.Persistence" Version="0.8.0-pre1502120115" />
For projects that support PackageReference, copy this XML node into the project file to reference the package.
paket add Akka.Persistence --version 0.8.0-pre1502120115
#r "nuget: Akka.Persistence, 0.8.0-pre1502120115"
#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package.
// Install Akka.Persistence as a Cake Addin
#addin nuget:?package=Akka.Persistence&version=0.8.0-pre1502120115&prerelease

// Install Akka.Persistence as a Cake Tool
#tool nuget:?package=Akka.Persistence&version=0.8.0-pre1502120115&prerelease

Persistence actor support for Akka.NET

Product Compatible and additional computed target framework versions.
.NET Framework net45 is compatible.  net451 was computed.  net452 was computed.  net46 was computed.  net461 was computed.  net462 was computed.  net463 was computed.  net47 was computed.  net471 was computed.  net472 was computed.  net48 was computed.  net481 was computed. 
Compatible target framework(s)
Included target framework(s) (in package)
Learn more about Target Frameworks and .NET Standard.

NuGet packages (48)

Showing the top 5 NuGet packages that depend on Akka.Persistence:

Package Downloads
Akka.Cluster.Sharding The ID prefix of this package has been reserved for one of the owners of this package by NuGet.org.

Sharded actors with managed lifecycle for Akka.NET cluster. Used to distribute state in a fault-tolerant, consistent fashion over an Akka.NET cluster.

Akka.Persistence.Sql.Common The ID prefix of this package has been reserved for one of the owners of this package by NuGet.org.

Akka.NET Persistence ADO.NET middleware

Akka.Persistence.Query The ID prefix of this package has been reserved for one of the owners of this package by NuGet.org.

Stream based query interface for persistence journal plugins for Akka.NET

Akka.Persistence.Query.Sql The ID prefix of this package has been reserved for one of the owners of this package by NuGet.org.

Akka.NET streams support for ADO.NET Persistence middleware.

Akka.Persistence.TestKit The ID prefix of this package has been reserved for one of the owners of this package by NuGet.org.

TestKit for writing tests for Akka.NET Persistance module.

GitHub repositories (4)

Showing the top 4 popular GitHub repositories that depend on Akka.Persistence:

Repository Stars
ThembisileNGQ/Akkatecture
a cqrs and event sourcing framework for dotnet core using akka.net
axzxs2001/Asp.NetCoreExperiment
原来所有项目都移动到**OleVersion**目录下进行保留。新的案例装以.net 5.0为主,一部分对以前案例进行升级,一部分将以前的工作经验总结出来,以供大家参考!
Aaronontheweb/InMemoryCQRSReplication
Akka.NET Reference Architecture - CQRS + Sharding + In-Memory Replication
Horusiath/AkkaCQRS
Event sourcing example build on Akka.NET with persistence plugin
Version Downloads Last updated
1.5.18 4,041 3/12/2024
1.5.17.1 5,897 3/2/2024
1.5.17 732 2/29/2024
1.5.16 14,710 1/29/2024
1.5.15 21,337 1/10/2024
1.5.14 27,528 11/3/2023
1.5.13 59,779 9/18/2023
1.5.13-beta1 1,021 8/25/2023
1.5.12 59,392 8/2/2023
1.5.11 3,258 7/27/2023
1.5.10 6,226 7/25/2023
1.5.9 13,346 7/17/2023
1.5.8 36,003 6/15/2023
1.5.7 28,148 5/17/2023
1.5.6 10,298 5/8/2023
1.5.5 25,917 5/4/2023
1.5.4 39,756 4/25/2023
1.5.3 4,022 4/20/2023
1.5.2 40,350 4/6/2023
1.5.1 27,944 3/15/2023
1.5.0 44,125 3/2/2023
1.5.0-beta6 1,589 3/1/2023
1.5.0-beta5 1,044 3/1/2023
1.5.0-beta4 1,163 2/28/2023
1.5.0-beta3 1,792 2/27/2023
1.5.0-beta2 1,975 2/23/2023
1.5.0-beta1 1,117 2/20/2023
1.5.0-alpha4 1,485 2/1/2023
1.5.0-alpha3 1,425 11/15/2022
1.5.0-alpha2 1,124 10/17/2022
1.5.0-alpha1 7,706 8/22/2022
1.4.51 4,534 6/28/2023
1.4.50 4,803 3/15/2023
1.4.49 29,502 1/27/2023
1.4.49-beta1 1,150 1/11/2023
1.4.48 48,628 1/5/2023
1.4.47 13,717 12/9/2022
1.4.46 40,087 11/15/2022
1.4.45 38,945 10/19/2022
1.4.44 9,207 10/17/2022
1.4.43 28,346 9/27/2022
1.4.42 8,053 9/23/2022
1.4.41 125,446 8/31/2022
1.4.40 50,402 7/22/2022
1.4.39 91,902 6/1/2022
1.4.38 45,303 5/6/2022
1.4.37 18,189 4/14/2022
1.4.36 23,431 4/5/2022
1.4.35 77,387 3/18/2022
1.4.34 15,482 3/7/2022
1.4.33 20,483 2/14/2022
1.4.32 42,706 1/18/2022
1.4.31 75,910 12/21/2021
1.4.30 3,037 12/20/2021
1.4.29 4,332 12/13/2021
1.4.28 66,313 11/10/2021
1.4.27 56,638 10/11/2021
1.4.26 7,542 9/28/2021
1.4.25 36,811 9/8/2021
1.4.24 13,876 8/17/2021
1.4.23 5,880 8/10/2021
1.4.22 8,113 8/5/2021
1.4.21 35,752 6/16/2021
1.4.21-beta1 1,977 6/4/2021
1.4.20 37,053 5/12/2021
1.4.19 25,044 4/28/2021
1.4.18 30,917 3/23/2021
1.4.17 12,661 3/10/2021
1.4.16 48,926 1/22/2021
1.4.15 5,377 1/20/2021
1.4.14 22,498 12/30/2020
1.4.13 5,986 12/16/2020
1.4.12 67,585 11/16/2020
1.4.11 22,406 11/5/2020
1.4.10 50,521 8/20/2020
1.4.9 25,381 7/21/2020
1.4.8 58,768 6/17/2020
1.4.7 15,281 5/27/2020
1.4.6 11,878 5/12/2020
1.4.5 17,012 4/29/2020
1.4.4 43,081 3/31/2020
1.4.3 13,082 3/18/2020
1.4.2 12,505 3/13/2020
1.4.1 33,198 3/11/2020
1.4.1-rc3 3,519 3/10/2020
1.4.1-rc2 2,304 3/10/2020
1.4.1-rc1 4,016 2/28/2020
1.4.0-beta4 3,580 1/28/2020
1.4.0-beta3 8,731 10/30/2019
1.4.0-beta2 5,038 9/23/2019
1.4.0-beta1 3,696 7/19/2019
1.3.18 25,021 3/9/2020
1.3.17 55,962 12/20/2019
1.3.16 15,870 11/14/2019
1.3.15 82,755 9/23/2019
1.3.14 42,605 7/30/2019
1.3.13 53,392 4/30/2019
1.3.12 35,820 3/14/2019
1.3.11 36,467 12/18/2018
1.3.10 90,167 11/2/2018
1.3.9 84,705 8/23/2018
1.3.8 26,999 6/5/2018
1.3.7 18,546 5/15/2018
1.3.6 8,828 4/17/2018
1.3.5 23,858 2/22/2018
1.3.4 7,294 2/1/2018
1.3.3 5,925 1/19/2018
1.3.2 40,014 10/21/2017
1.3.1 26,210 9/5/2017
1.3.0 13,136 8/11/2017
1.2.3.43-beta 6,314 7/10/2017
1.2.3.41-beta 2,686 7/10/2017
1.2.2.40-beta 5,764 6/28/2017
1.2.2.39-beta 2,587 6/28/2017
1.2.1.38-beta 5,544 6/23/2017
1.2.1.37-beta 2,650 6/23/2017
1.2.0.36-beta 16,111 4/13/2017
1.2.0.35-beta 2,579 4/13/2017
1.2.0.34-beta 2,494 4/12/2017
1.2.0.33-beta 2,666 4/12/2017
1.1.3.32-beta 15,084 1/23/2017
1.1.3.31-beta 2,791 1/23/2017
1.1.2.30-beta 18,545 9/22/2016
1.1.2.29-beta 2,859 9/22/2016
1.1.1.28-beta 7,867 7/16/2016
1.1.1.27-beta 2,559 7/16/2016
1.1.0.26-beta 3,007 7/7/2016
1.0.8.25-beta 4,029 4/26/2016
1.0.8.24-beta 1,981 4/26/2016
1.0.7.18-beta 2,416 4/6/2016
1.0.6.17-beta 9,989 1/18/2016
1.0.6.16-beta 1,534 1/18/2016
1.0.5.15-beta 9,193 12/3/2015
1.0.5.14-beta 1,765 12/3/2015
1.0.4.12-beta 3,163 8/8/2015
1.0.3-beta 1,997 6/12/2015
1.0.2.9-beta 1,883 6/3/2015
1.0.1-pre1504282013 1,979 4/28/2015
1.0.0-pre1504092226 1,447 4/9/2015
1.0.0-dev1504032244 1,353 4/3/2015
0.8.0-pre1502120115 2,805 2/12/2015

__Dependency Injection support for Ninject, Castle Windsor, and AutoFac__. Thanks to some amazing effort from individual contributor (**[@jcwrequests](https://github.com/jcwrequests "@jcwrequests")**), Akka.NET now has direct dependency injection support for [Ninject](http://www.ninject.org/), [Castle Windsor](http://docs.castleproject.org/Default.aspx?Page=MainPage&NS=Windsor&AspxAutoDetectCookieSupport=1), and [AutoFac](https://github.com/autofac/Autofac).
Here's an example using Ninject, for instance:
// Create and build your container
var container = new Ninject.StandardKernel();
container.Bind().To(typeof(TypedWorker));
container.Bind().To(typeof(WorkerService));
// Create the ActorSystem and Dependency Resolver
var system = ActorSystem.Create("MySystem");
var propsResolver = new NinjectDependencyResolver(container,system);
//Create some actors who need Ninject
var worker1 = system.ActorOf(propsResolver.Create<TypedWorker>(), "Worker1");
var worker2 = system.ActorOf(propsResolver.Create<TypedWorker>(), "Worker2");
//send them messages
worker1.Tell("hi!");
You can install these DI plugins for Akka.NET via NuGet - here's how:
Ninject** - `install-package Akka.DI.Ninject`
Castle Windsor** - `install-package Akka.DI.CastleWindsor`
AutoFac** - `install-package Akka.DI.AutoFac`
Read the [full Dependency Injection with Akka.NET documentation](http://getakka.net/wiki/Dependency%20injection "Dependency Injection with Akka.NET") here.**
__Persistent Actors with Akka.Persistence (Alpha)__. Core contributor **[@Horusiath](https://github.com/Horusiath)** ported the majority of Akka's Akka.Persistence and Akka.Persistence.TestKit modules.
> Even in the core Akka project these modules are considered to be "experimental," but the goal is to provide actors with a way of automatically saving and recovering their internal state to a configurable durable store - such as a database or filesystem.
Akka.Persistence also introduces the notion of *reliable delivery* of messages, achieved through the `GuaranteedDeliveryActor`.
Akka.Persistence also ships with an FSharp API out of the box, so while this package is in beta you can start playing with it either F# or C# from day one.
If you want to play with Akka.Persistence, please install any one of the following packages:
Akka.Persistence** - `install-package Akka.Persistence -pre`
Akka.Persistence.FSharp** - `install-package Akka.Persistence.FSharp -pre`
Akka.Persistence.TestKit** - `install-package Akka.Persistence.TestKit -pre`
Read the [full Persistent Actors with Akka.NET documentation](http://getakka.net/wiki/Persistence "Persistent Actors with Akka.NET") here.**
__Remote Deployment of Routers and Routees__. You can now remotely deploy routers and routees via configuration, like so:
Deploying _routees_ remotely via `Config`**:
actor.deployment {
   /blub {
     router = round-robin-pool
     nr-of-instances = 2
     target.nodes = [""akka.tcp://${sysName}@localhost:${port}""]
   }
}
var router = masterActorSystem.ActorOf(new RoundRobinPool(2).Props(Props.Create<Echo>()), "blub");
When deploying a router via configuration, just specify the `target.nodes` property with a list of `Address` instances for each node you want to deploy your routees.
> NOTE: Remote deployment of routees only works for `Pool` routers.
Deploying _routers_ remotely via `Config`**:
actor.deployment {
   /blub {
     router = round-robin-pool
     nr-of-instances = 2
     remote = ""akka.tcp://${sysName}@localhost:${port}""
   }
}
var router = masterActorSystem.ActorOf(Props.Create<Echo>().WithRouter(FromConfig.Instance), "blub");
Works just like remote deployment of actors.
If you want to deploy a router remotely via explicit configuration, you can do it in code like this via the `RemoteScope` and `RemoteRouterConfig`:
Deploying _routees_ remotely via explicit configuration**:
var intendedRemoteAddress = Address.Parse("akka.tcp://${sysName}@localhost:${port}"
.Replace("${sysName}", sysName)
.Replace("${port}", port.ToString()));
var router = myActorSystem.ActorOf(new RoundRobinPool(2).Props(Props.Create<Echo>())
.WithDeploy(new Deploy(
new RemoteScope(intendedRemoteAddress.Copy()))), "myRemoteRouter");
Deploying _routers_ remotely via explicit configuration**:
var intendedRemoteAddress = Address.Parse("akka.tcp://${sysName}@localhost:${port}"
.Replace("${sysName}", sysName)
.Replace("${port}", port.ToString()));
var router = myActorSystem.ActorOf(
new RemoteRouterConfig(
new RoundRobinPool(2), new[] { new Address("akka.tcp", sysName, "localhost", port) })
.Props(Props.Create<Echo>()), "blub2");
Improved Serialization and Remote Deployment Support**. All internals related to serialization and remote deployment have undergone vast improvements in order to support the other work that went into this release.
Pluggable Actor Creation Pipeline**. We reworked the plumbing that's used to provide automatic `Stash` support and exposed it as a pluggable actor creation pipeline for local actors.
This release adds the `ActorProducerPipeline`, which is accessible from `ExtendedActorSystem` (to be able to configure by plugins) and allows you to inject custom hooks satisfying following interface:
interface IActorProducerPlugin {
   bool CanBeAppliedTo(ActorBase actor);
   void AfterActorCreated(ActorBase actor, IActorContext context);
   void BeforeActorTerminated(ActorBase actor, IActorContext context);
}
- **CanBeAppliedTo** determines if plugin can be applied to specific actor instance.
- **AfterActorCreated** is applied to actor after it has been instantiated by an `ActorCell` and before `InitializableActor.Init` method will (optionally) be invoked.
- **BeforeActorTerminated** is applied before actor terminates and before `IDisposable.Dispose` method will be invoked (for disposable actors) - **auto handling disposable actors is second feature of this commit**.
For common use it's better to create custom classes inheriting from `ActorProducerPluginBase` and `ActorProducerPluginBase<TActor>` classes.
Pipeline itself provides following interface:
class ActorProducerPipeline : IEnumerable<IActorProducerPlugin> {
   int Count { get; } // current plugins count - 1 by default (ActorStashPlugin)
   bool Register(IActorProducerPlugin plugin)
   bool Unregister(IActorProducerPlugin plugin)
   bool IsRegistered(IActorProducerPlugin plugin)
   bool Insert(int index, IActorProducerPlugin plugin)
}
- **Register** - registers a plugin if no other plugin of the same type has been registered already (plugins with generic types are counted separately). Returns true if plugin has been registered.
- **Insert** - same as register, but plugin will be placed in specific place inside the pipeline - useful if any plugins precedence is required.
- **Unregister** - unregisters specified plugin if it has been found. Returns true if plugin was found and unregistered.
- **IsRegistered** - checks if plugin has been already registered.
By default pipeline is filled with one already used plugin - `ActorStashPlugin`, which replaces stash initialization/unstashing mechanism used up to this moment.
MultiNodeTestRunner and Akka.Remote.TestKit**. The MultiNodeTestRunner and the Multi Node TestKit (Akka.Remote.TestKit) underwent some drastic changes in this update. They're still not quite ready for public use yet, but if you want to see what the experience is like you can [clone the Akka.NET Github repository](https://github.com/akkadotnet/akka.net) and run the following command:
````
C:\akkadotnet> .\build.cmd MultiNodeTests
````
This will automatically launch all `MultiNodeSpec` instances found inside `Akka.Cluster.Tests`. We'll need to make this more flexible to be able to run other assemblies that require multinode tests in the future.
These tests are not enabled by default in normal build runs, but they will at some point in the future.
Here's a sample of the output from the console, to give you a sense of what the reporting looks like:
![image](https://cloud.githubusercontent.com/assets/326939/6075685/5f7c56b2-ad8c-11e4-9d93-8216a8cbabaf.png)
The MultiNodeTestRunner uses XUnit internally and will dynamically deploy as many processes are needed to satisfy any individual test. Has been tested with up to 6 processes.