Akka.NET v0.6.3 - Release Notes

RELEASE_NOTES.md

@@ -1,3 +1,8 @@
+#### 0.6.3 Aug 13 2014
+* Made it so HOCON config sections chain properly
+* Optimized actor memory footprint
+* Fixed a Helios bug that caused Akka.NET to drop messages larger than 32kb
+
 #### 0.6.2 Aug 05 2014
 * Upgraded Helios dependency
 * Bug fixes

src/SharedAssemblyInfo.cs

@@ -4,7 +4,7 @@
 [assembly: AssemblyCompanyAttribute("Akka")]
 [assembly: AssemblyCopyrightAttribute("Copyright © Roger Alsing 2013-2014")]
 [assembly: AssemblyTrademarkAttribute("")]
-[assembly: AssemblyVersionAttribute("0.6.2.0")]
-[assembly: AssemblyFileVersionAttribute("0.6.2.0")]
+[assembly: AssemblyVersionAttribute("0.6.3.0")]
+[assembly: AssemblyFileVersionAttribute("0.6.3.0")]
 namespace System {
 }

src/core/Akka.FSharp/Properties/AssemblyInfo.fs

@@ -10,9 +10,9 @@ open System.Runtime.InteropServices
 [<assembly: AssemblyCompanyAttribute("Akka.net")>]
 [<assembly: ComVisibleAttribute(false)>]
 [<assembly: CLSCompliantAttribute(true)>]
-[<assembly: AssemblyVersionAttribute("0.6.2.0")>]
-[<assembly: AssemblyFileVersionAttribute("0.6.2.0")>]
+[<assembly: AssemblyVersionAttribute("0.6.3.0")>]
+[<assembly: AssemblyFileVersionAttribute("0.6.3.0")>]
 do ()
 
 module internal AssemblyVersionInformation =
-    let [<Literal>] Version = "0.6.2.0"
+    let [<Literal>] Version = "0.6.3.0"

src/core/Akka.Remote/Akka.Remote.csproj

@@ -60,7 +60,7 @@
     </Reference>
     <Reference Include="Helios, Version=1.3.0.0, Culture=neutral, processorArchitecture=MSIL">
       <SpecificVersion>False</SpecificVersion>
-      <HintPath>..\..\packages\Helios.1.3.0.0\lib\net45\Helios.dll</HintPath>
+      <HintPath>..\..\packages\Helios.1.3.4.0\lib\net45\Helios.dll</HintPath>
     </Reference>
     <Reference Include="System" />
     <Reference Include="System.Core" />

src/core/Akka.Remote/packages.config

@@ -1,5 +1,5 @@
 <?xml version="1.0" encoding="utf-8"?>
 <packages>
   <package id="Google.ProtocolBuffers" version="2.4.1.521" targetFramework="net45" />
-  <package id="Helios" version="1.3.0.0" targetFramework="net45" />
+  <package id="Helios" version="1.3.4.0" targetFramework="net45" />
 </packages>

src/core/Akka.TestKit/Akka.TestKit.csproj

@@ -82,6 +82,7 @@
     <Compile Include="Properties\AssemblyInfo.cs" />
     <Compile Include="Supervisor.cs" />
     <Compile Include="TestActorRef.cs" />
+    <Compile Include="TestEvents.cs" />
     <Compile Include="TestKitExtension.cs" />
     <Compile Include="TestKitSettings.cs" />
     <Compile Include="TestLatch.cs" />

src/core/Akka.TestKit/AkkaSpec.cs

@@ -12,6 +12,7 @@
 using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
+using Xunit.Sdk;
 
 namespace Akka.Tests
 {
@@ -124,6 +125,7 @@ public class AkkaSpec : TestKitBase, IDisposable
 
         public AkkaSpec()
         {
+
             var config = ConfigurationFactory.ParseString(GetConfig());
             queue = new BlockingCollection<object>();
             messages = new List<object>();
@@ -134,7 +136,7 @@ public AkkaSpec()
 
         protected virtual string GetConfig()
         {
-            return "";
+            return ""+"";
         }
 
         public virtual void Dispose()
@@ -239,6 +241,12 @@ protected TMessage expectMsgType<TMessage>(TimeSpan timeout)
             return default(TMessage);
         }
 
+        protected T AwaitResult<T>(Task<object> ask, TimeSpan timeout)
+        {
+            ask.Wait(timeout);
+            return (T)ask.Result;
+        }
+
         /// <summary>
         /// Uses an epsilon value to compare between floating point numbers.
         /// Uses a default epsilon value of 0.001d
@@ -502,6 +510,30 @@ protected void intercept<T>(Action intercept) where T : Exception
             Xunit.Assert.True(false, "Expected exception of type " + typeof(T).Name);
         }
 
+        protected void FilterEvents(ActorSystem system, EventFilter[] eventFilters, Action action)
+        {
+            sys.EventStream.Publish(new Mute(eventFilters));
+            try
+            {
+                action();
+
+                var leeway = TestKitSettings.TestEventFilterLeeway;
+                var failed = eventFilters
+                    .Where(x => !x.AwaitDone(leeway))
+                    .Select(x => string.Format("Timeout {0} waiting for {1}", leeway, x))
+                    .ToArray();
+
+                if (failed.Any())
+                {
+                    throw new AssertException("Filter completion error: " + string.Join("\n", failed));
+                }
+            }
+            finally
+            {
+                sys.EventStream.Publish(new Unmute(eventFilters));
+            }
+        }
+
         protected void EventFilter<T>(string message, int occurances, Action intercept) where T : Exception
         {
             sys.EventStream.Subscribe(testActor, typeof(Error));