adbrowne · dgchurchill · Jan 15, 2015 · Jan 19, 2015 · Jan 20, 2015 · Jan 21, 2015
diff --git a/build.cmd b/build.cmd
diff --git a/build/tools/nuget/nuget.exe b/build/tools/nuget/nuget.exe
diff --git a/src/Eventful.CsTests/Eventful.CsTests.csproj b/src/Eventful.CsTests/Eventful.CsTests.csproj
@@ -36,18 +36,29 @@
     <Reference Include="EventStore.ClientAPI">
       <HintPath>..\packages\EventStore.Client.3.0.1\lib\net40\EventStore.ClientAPI.dll</HintPath>
     </Reference>
-    <Reference Include="FSharp.Core, Version=4.3.1.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a, processorArchitecture=MSIL" />
-    <Reference Include="FSharpx.Collections, Version=1.9.4.0, Culture=neutral, processorArchitecture=MSIL">
-      <SpecificVersion>False</SpecificVersion>
-      <HintPath>..\packages\FSharpx.Collections.1.9.4\lib\net35\FSharpx.Collections.dll</HintPath>
+    <Reference Include="FSharp.Control.AsyncSeq, Version=0.0.0.0, Culture=neutral, processorArchitecture=MSIL">
+      <HintPath>..\packages\FSharp.Control.AsyncSeq.2.0.1\lib\net45\FSharp.Control.AsyncSeq.dll</HintPath>
+      <Private>True</Private>
     </Reference>
-    <Reference Include="FSharpx.Core, Version=1.8.41.0, Culture=neutral, processorArchitecture=MSIL">
-      <SpecificVersion>False</SpecificVersion>
-      <HintPath>..\packages\FSharpx.Core.1.8.41\lib\40\FSharpx.Core.dll</HintPath>
+    <Reference Include="FSharp.Core, Version=4.3.1.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a, processorArchitecture=MSIL">
+      <HintPath>..\packages\FSharp.Core.3.1.2.1\lib\net40\FSharp.Core.dll</HintPath>
+      <Private>True</Private>
+    </Reference>
+    <Reference Include="FSharpx.Async, Version=0.0.0.0, Culture=neutral, processorArchitecture=MSIL">
+      <HintPath>..\packages\FSharpx.Async.1.12.0\lib\net40\FSharpx.Async.dll</HintPath>
+      <Private>True</Private>
+    </Reference>
+    <Reference Include="FSharpx.Collections, Version=1.10.1.0, Culture=neutral, processorArchitecture=MSIL">
+      <HintPath>..\packages\FSharpx.Collections.1.10.1\lib\net40\FSharpx.Collections.dll</HintPath>
+      <Private>True</Private>
+    </Reference>
+    <Reference Include="FSharpx.Extras, Version=1.10.2.0, Culture=neutral, processorArchitecture=MSIL">
+      <HintPath>..\packages\FSharpx.Extras.1.10.2\lib\40\FSharpx.Extras.dll</HintPath>
+      <Private>True</Private>
     </Reference>
-    <Reference Include="Metrics, Version=0.2.6.0, Culture=neutral, processorArchitecture=MSIL">
+    <Reference Include="Metrics, Version=0.3.2.0, Culture=neutral, processorArchitecture=MSIL">
       <SpecificVersion>False</SpecificVersion>
-      <HintPath>..\packages\Metrics.NET.0.2.6\lib\net45\Metrics.dll</HintPath>
+      <HintPath>..\..\..\packages\Metrics.NET.0.3.2-pre\lib\net45\Metrics.dll</HintPath>
     </Reference>
     <Reference Include="Serilog">
       <HintPath>..\packages\Serilog.1.5.7\lib\net45\Serilog.dll</HintPath>

diff --git a/src/Eventful.CsTests/app.config b/src/Eventful.CsTests/app.config
@@ -51,7 +51,7 @@
       </dependentAssembly>
       <dependentAssembly>
         <assemblyIdentity name="Newtonsoft.Json" publicKeyToken="30ad4fe6b2a6aeed" culture="neutral" />
-        <bindingRedirect oldVersion="0.0.0.0-6.0.0.0" newVersion="6.0.0.0" />
+        <bindingRedirect oldVersion="0.0.0.0-7.0.0.0" newVersion="7.0.0.0" />
       </dependentAssembly>
       <dependentAssembly>
         <assemblyIdentity name="Microsoft.WindowsAzure.Storage" publicKeyToken="31bf3856ad364e35" culture="neutral" />

diff --git a/src/Eventful.CsTests/packages.config b/src/Eventful.CsTests/packages.config
@@ -1,9 +1,11 @@
 <?xml version="1.0" encoding="utf-8"?>
 <packages>
   <package id="EventStore.Client" version="3.0.1" targetFramework="net45" />
-  <package id="FSharpx.Collections" version="1.9.4" targetFramework="net45" />
-  <package id="FSharpx.Core" version="1.8.41" targetFramework="net45" />
-  <package id="Metrics.NET" version="0.2.6" targetFramework="net45" />
+  <package id="FSharp.Control.AsyncSeq" version="2.0.1" targetFramework="net45" />
+  <package id="Metrics.NET" version="0.3.2-pre" targetFramework="net45" />
+  <package id="FSharp.Core" version="3.1.2.1" targetFramework="net45" />
+  <package id="FSharpx.Async" version="1.12.0" targetFramework="net45" />
+  <package id="FSharpx.Extras" version="1.10.2" targetFramework="net45" />
   <package id="Serilog" version="1.5.7" targetFramework="net45" />
   <package id="xunit" version="1.9.2" targetFramework="net45" />
 </packages>
diff --git a/src/Eventful.EventStore/Client.fs b/src/Eventful.EventStore/Client.fs
@@ -4,6 +4,7 @@ open FSharp.Control
 open EventStore.ClientAPI
 open System
 open FSharpx
+open FSharpx.Functional
 open Eventful
 
 /// simple F# wrapper around EventStore functions
@@ -86,7 +87,7 @@ type EventStoreClient (connection : IEventStoreConnection) =
 
     member x.getNextPosition () = async {
         let position = Position.End
-        let! (finalSlice : AllEventsSlice) = connection.ReadAllEventsBackwardAsync(position, 1, false, null)
+        let! (finalSlice : AllEventsSlice) = connection.ReadAllEventsBackwardAsync(position, 1, false, null) |> Async.AwaitTask
         let nextPosition = finalSlice.NextPosition
         return nextPosition }
 

diff --git a/src/Eventful.EventStore/EventStoreSystem.fs b/src/Eventful.EventStore/EventStoreSystem.fs
@@ -6,6 +6,7 @@ open EventStore.ClientAPI
 open System
 open FSharpx
 open FSharpx.Collections
+open FSharpx.Functional
 
 type EventStoreSystem<'TCommandContext, 'TEventContext,'TMetadata, 'TBaseEvent when 'TMetadata : equality and 'TEventContext :> System.IDisposable> 
     ( 

diff --git a/src/Eventful.EventStore/EventStreamInterpreter.fs b/src/Eventful.EventStore/EventStreamInterpreter.fs
@@ -34,7 +34,7 @@ module EventStreamInterpreter =
         (readSnapshot : string -> Map<string,Type> -> Async<StateSnapshot>)
         (startContext : ContextStartData)
         (prog : FreeEventStream<obj,'A,'TMetadata>) : Async<'A> = 
-        let rec loop prog (values : Map<EventToken,(byte[]*byte[])>) (writes : Vector<string * int * obj * 'TMetadata>) : Async<'A> =
+        let rec loop prog (values : Map<EventToken,(byte[]*byte[])>) (writes : PersistentVector<string * int * obj * 'TMetadata>) : Async<'A> =
             match prog with
             | FreeEventStream (GetEventStoreTypeToClassMap ((), f)) ->
                 let next = f eventStoreTypeToClassMap
@@ -162,4 +162,4 @@ module EventStreamInterpreter =
                 async {
                     return result
                 }
-        loop prog Map.empty Vector.empty
+        loop prog Map.empty PersistentVector.empty
diff --git a/src/Eventful.EventStore/Eventful.EventStore.fsproj b/src/Eventful.EventStore/Eventful.EventStore.fsproj
@@ -78,23 +78,32 @@
       <Private>True</Private>
     </Reference>
     <Reference Include="EventStore.ClientAPI" />
-    <Reference Include="FSharp.Core, Version=$(TargetFSharpCoreVersion), Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a">
+    <Reference Include="FSharp.Control.AsyncSeq">
+      <HintPath>..\packages\FSharp.Control.AsyncSeq.2.0.1\lib\net45\FSharp.Control.AsyncSeq.dll</HintPath>
+      <Private>True</Private>
+    </Reference>
+    <Reference Include="FSharp.Core">
+      <HintPath>..\packages\FSharp.Core.3.1.2.1\lib\net40\FSharp.Core.dll</HintPath>
       <Private>True</Private>
     </Reference>
     <Reference Include="FSharp.Data">
       <HintPath>..\packages\FSharp.Data.2.2.0\lib\net40\FSharp.Data.dll</HintPath>
       <Private>True</Private>
     </Reference>
+    <Reference Include="FSharpx.Async">
+      <HintPath>..\packages\FSharpx.Async.1.12.0\lib\net40\FSharpx.Async.dll</HintPath>
+      <Private>True</Private>
+    </Reference>
     <Reference Include="FSharpx.Collections">
-      <HintPath>..\packages\FSharpx.Collections.1.9.4\lib\net35\FSharpx.Collections.dll</HintPath>
+      <HintPath>..\packages\FSharpx.Collections.1.10.1\lib\net40\FSharpx.Collections.dll</HintPath>
       <Private>True</Private>
     </Reference>
-    <Reference Include="FSharpx.Core">
-      <HintPath>..\packages\FSharpx.Core.1.8.41\lib\40\FSharpx.Core.dll</HintPath>
+    <Reference Include="FSharpx.Extras">
+      <HintPath>..\packages\FSharpx.Extras.1.10.2\lib\40\FSharpx.Extras.dll</HintPath>
       <Private>True</Private>
     </Reference>
     <Reference Include="Metrics">
-      <HintPath>..\packages\Metrics.NET.0.2.6\lib\net45\Metrics.dll</HintPath>
+      <HintPath>..\..\..\packages\Metrics.NET.0.3.2-pre\lib\net45\Metrics.dll</HintPath>
       <Private>True</Private>
     </Reference>
     <Reference Include="mscorlib" />

diff --git a/src/Eventful.EventStore/MultiTenancyEventStoreSubscriber.fs b/src/Eventful.EventStore/MultiTenancyEventStoreSubscriber.fs
@@ -3,7 +3,7 @@
 open EventStore.ClientAPI
 open Eventful
 open Metrics
-open FSharp.Control
+open FSharpx.Control
 
 type MultiTenancyEventStoreSubscriber<'TWrappedEvent>
     (

diff --git a/src/Eventful.EventStore/app.config b/src/Eventful.EventStore/app.config
@@ -12,7 +12,7 @@
       </dependentAssembly>
       <dependentAssembly>
         <assemblyIdentity name="Newtonsoft.Json" publicKeyToken="30ad4fe6b2a6aeed" culture="neutral" />
-        <bindingRedirect oldVersion="0.0.0.0-6.0.0.0" newVersion="6.0.0.0" />
+        <bindingRedirect oldVersion="0.0.0.0-7.0.0.0" newVersion="7.0.0.0" />
       </dependentAssembly>
       <dependentAssembly>
         <assemblyIdentity name="System.Net.Http.Formatting" publicKeyToken="31bf3856ad364e35" culture="neutral" />

diff --git a/src/Eventful.EventStore/packages.config b/src/Eventful.EventStore/packages.config
@@ -1,9 +1,12 @@
 <?xml version="1.0" encoding="utf-8"?>
 <packages>
   <package id="EventStore.Client" version="3.0.1" targetFramework="net45" />
+  <package id="FSharp.Control.AsyncSeq" version="2.0.1" targetFramework="net45" />
+  <package id="FSharp.Core" version="3.1.2.1" targetFramework="net45" />
   <package id="FSharp.Data" version="2.2.0" targetFramework="net45" />
-  <package id="FSharpx.Collections" version="1.9.4" targetFramework="net45" />
-  <package id="FSharpx.Core" version="1.8.41" targetFramework="net45" />
-  <package id="Metrics.NET" version="0.2.6" targetFramework="net45" />
+  <package id="FSharpx.Async" version="1.12.0" targetFramework="net45" />
+  <package id="FSharpx.Collections" version="1.10.1" targetFramework="net45" />
+  <package id="Metrics.NET" version="0.3.2-pre" targetFramework="net45" />
+  <package id="FSharpx.Extras" version="1.10.2" targetFramework="net45" />
   <package id="Serilog" version="1.5.7" targetFramework="net45" />
 </packages>
diff --git a/src/Eventful.Neo4j/Eventful.Neo4j.fsproj b/src/Eventful.Neo4j/Eventful.Neo4j.fsproj
@@ -72,28 +72,37 @@
     <Compile Include="Neo4jReadQueue.fs" />
   </ItemGroup>
   <ItemGroup>
+    <Reference Include="FSharp.Control.AsyncSeq">
+      <HintPath>..\..\..\packages\FSharp.Control.AsyncSeq.2.0.1\lib\net45\FSharp.Control.AsyncSeq.dll</HintPath>
+      <Private>True</Private>
+    </Reference>
+    <Reference Include="FSharp.Core">
+      <HintPath>..\..\..\packages\FSharp.Core.3.1.2.1\lib\net40\FSharp.Core.dll</HintPath>
+      <Private>True</Private>
+    </Reference>
     <Reference Include="FSharp.Data">
       <HintPath>..\packages\FSharp.Data.2.2.0\lib\net40\FSharp.Data.dll</HintPath>
       <Private>True</Private>
     </Reference>
+    <Reference Include="FSharpx.Async">
+      <HintPath>..\..\..\packages\FSharpx.Async.1.12.0\lib\net40\FSharpx.Async.dll</HintPath>
+      <Private>True</Private>
+    </Reference>
     <Reference Include="FSharpx.Collections">
-      <HintPath>..\packages\FSharpx.Collections.1.9.4\lib\net35\FSharpx.Collections.dll</HintPath>
+      <HintPath>..\..\..\packages\FSharpx.Collections.1.10.1\lib\net40\FSharpx.Collections.dll</HintPath>
       <Private>True</Private>
     </Reference>
-    <Reference Include="FSharpx.Core">
-      <HintPath>..\packages\FSharpx.Core.1.8.41\lib\40\FSharpx.Core.dll</HintPath>
+    <Reference Include="FSharpx.Extras">
+      <HintPath>..\..\..\packages\FSharpx.Extras.1.10.2\lib\40\FSharpx.Extras.dll</HintPath>
       <Private>True</Private>
     </Reference>
     <Reference Include="Metrics">
-      <HintPath>..\packages\Metrics.NET.0.2.8\lib\net45\Metrics.dll</HintPath>
+      <HintPath>..\..\..\packages\Metrics.NET.0.3.2-pre\lib\net45\Metrics.dll</HintPath>
       <Private>True</Private>
     </Reference>
     <Reference Include="mscorlib" />
-    <Reference Include="FSharp.Core, Version=$(TargetFSharpCoreVersion), Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a">
-      <Private>True</Private>
-    </Reference>
     <Reference Include="Newtonsoft.Json">
-      <HintPath>..\packages\Newtonsoft.Json.6.0.3\lib\net45\Newtonsoft.Json.dll</HintPath>
+      <HintPath>..\..\..\packages\Newtonsoft.Json.7.0.1\lib\net45\Newtonsoft.Json.dll</HintPath>
       <Private>True</Private>
     </Reference>
     <Reference Include="Serilog">
@@ -129,11 +138,6 @@
       <Private>True</Private>
     </ProjectReference>
   </ItemGroup>
-  <Import Project="..\packages\Microsoft.Bcl.Build.1.0.14\tools\Microsoft.Bcl.Build.targets" Condition="Exists('..\packages\Microsoft.Bcl.Build.1.0.14\tools\Microsoft.Bcl.Build.targets')" />
-  <Target Name="EnsureBclBuildImported" BeforeTargets="BeforeBuild" Condition="'$(BclBuildImported)' == ''">
-    <Error Condition="!Exists('..\packages\Microsoft.Bcl.Build.1.0.14\tools\Microsoft.Bcl.Build.targets')" Text="This project references NuGet package(s) that are missing on this computer. Enable NuGet Package Restore to download them.  For more information, see http://go.microsoft.com/fwlink/?LinkID=317567." HelpKeyword="BCLBUILD2001" />
-    <Error Condition="Exists('..\packages\Microsoft.Bcl.Build.1.0.14\tools\Microsoft.Bcl.Build.targets')" Text="The build restored NuGet packages. Build the project again to include these packages in the build. For more information, see http://go.microsoft.com/fwlink/?LinkID=317568." HelpKeyword="BCLBUILD2002" />
-  </Target>
   <!-- To modify your build process, add your task inside one of the targets below and uncomment it. 
        Other similar extension points exist, see Microsoft.Common.targets.
   <Target Name="BeforeBuild">

diff --git a/src/Eventful.Neo4j/Neo4jOperations.fs b/src/Eventful.Neo4j/Neo4jOperations.fs
@@ -98,7 +98,7 @@ module Operations =
     // TODO: Use the transaction support http://neo4j.com/docs/stable/rest-api-transactional.html
     //       Neo4jClient doesn't yet support this. CypherNet does, but doesn't support MERGE.
     let chainQ (query : CypherQuery) =
-        { query with Query = query.Query.With("1 as dummy") }
+        { query with Query = query.Query.With("count(*) as dummy") }
 
 
     let graphLabel (query : CypherQuery) =
@@ -361,6 +361,8 @@ module Operations =
 
             loop emptyState)
 
+        agent.Error.Add (fun exn -> log.ErrorWithException <| lazy ("Neo4j transaction batcher failed", exn))
+
         { new ITransactionBatcher with
             member x.Add graphName actions =
                 async {

diff --git a/src/Eventful.Neo4j/app.config b/src/Eventful.Neo4j/app.config
@@ -14,6 +14,10 @@
         <assemblyIdentity name="System.Net.Http.Formatting" publicKeyToken="31bf3856ad364e35" culture="neutral" />
         <bindingRedirect oldVersion="0.0.0.0-5.2.2.0" newVersion="5.2.2.0" />
       </dependentAssembly>
+      <dependentAssembly>
+        <assemblyIdentity name="Newtonsoft.Json" publicKeyToken="30ad4fe6b2a6aeed" culture="neutral" />
+        <bindingRedirect oldVersion="0.0.0.0-7.0.0.0" newVersion="7.0.0.0" />
+      </dependentAssembly>
     </assemblyBinding>
   </runtime>
 </configuration>
diff --git a/src/Eventful.Neo4j/packages.config b/src/Eventful.Neo4j/packages.config
@@ -1,12 +1,15 @@
 <?xml version="1.0" encoding="utf-8"?>
 <packages>
+  <package id="FSharp.Control.AsyncSeq" version="2.0.1" targetFramework="net45" />
+  <package id="FSharp.Core" version="3.1.2.1" targetFramework="net45" />
   <package id="FSharp.Data" version="2.2.0" targetFramework="net45" />
-  <package id="FSharpx.Collections" version="1.9.4" targetFramework="net45" />
-  <package id="FSharpx.Core" version="1.8.41" targetFramework="net45" />
-  <package id="Metrics.NET" version="0.2.8" targetFramework="net45" />
+  <package id="FSharpx.Async" version="1.12.0" targetFramework="net45" />
+  <package id="FSharpx.Collections" version="1.10.1" targetFramework="net45" />
+  <package id="Metrics.NET" version="0.3.2-pre" targetFramework="net45" />
+  <package id="FSharpx.Extras" version="1.10.2" targetFramework="net45" />
   <package id="Microsoft.Bcl" version="1.1.9" targetFramework="net45" />
   <package id="Microsoft.Bcl.Build" version="1.0.14" targetFramework="net45" />
   <package id="Microsoft.Net.Http" version="2.2.28" targetFramework="net45" />
-  <package id="Newtonsoft.Json" version="6.0.3" targetFramework="net45" />
+  <package id="Newtonsoft.Json" version="7.0.1" targetFramework="net45" />
   <package id="Serilog" version="1.5.7" targetFramework="net45" />
 </packages>
diff --git a/src/Eventful.RavenDb/AggregateStatePersistence.fs b/src/Eventful.RavenDb/AggregateStatePersistence.fs
@@ -2,6 +2,7 @@
 
 open System
 open FSharpx
+open FSharpx.Functional
 open FSharpx.Option
 open Raven.Json.Linq
 open Eventful
@@ -173,7 +174,7 @@ module AggregateStatePersistence =
                 |> Seq.toList
                 |> function
                     | [aggregateType] -> aggregateType
-                    | x -> failwith <| sprintf "Got messages for mixed aggreate type. Stream: %s, AggregateTypes: %A" streamId x
+                    | x -> failwith <| sprintf "Got messages for mixed aggregate type. Stream: %s, AggregateTypes: %A" streamId x
 
             match handlers.AggregateTypes |> Map.tryFind aggregateType with
             | Some aggregateConfig -> 

diff --git a/src/Eventful.RavenDb/Eventful.RavenDb.fsproj b/src/Eventful.RavenDb/Eventful.RavenDb.fsproj
@@ -82,16 +82,28 @@
       <HintPath>..\packages\FSharp.Collections.ParallelSeq.1.0.2\lib\net40\FSharp.Collections.ParallelSeq.dll</HintPath>
       <Private>True</Private>
     </Reference>
+    <Reference Include="FSharp.Control.AsyncSeq">
+      <HintPath>..\..\..\packages\FSharp.Control.AsyncSeq.2.0.1\lib\net45\FSharp.Control.AsyncSeq.dll</HintPath>
+      <Private>True</Private>
+    </Reference>
+    <Reference Include="FSharp.Core">
+      <HintPath>..\..\..\packages\FSharp.Core.3.1.2.1\lib\net40\FSharp.Core.dll</HintPath>
+      <Private>True</Private>
+    </Reference>
+    <Reference Include="FSharpx.Async">
+      <HintPath>..\..\..\packages\FSharpx.Async.1.12.0\lib\net40\FSharpx.Async.dll</HintPath>
+      <Private>True</Private>
+    </Reference>
     <Reference Include="FSharpx.Collections">
-      <HintPath>..\packages\FSharpx.Collections.1.9.4\lib\net35\FSharpx.Collections.dll</HintPath>
+      <HintPath>..\..\..\packages\FSharpx.Collections.1.10.1\lib\net40\FSharpx.Collections.dll</HintPath>
       <Private>True</Private>
     </Reference>
-    <Reference Include="FSharpx.Core">
-      <HintPath>..\packages\FSharpx.Core.1.8.41\lib\40\FSharpx.Core.dll</HintPath>
+    <Reference Include="FSharpx.Extras">
+      <HintPath>..\..\..\packages\FSharpx.Extras.1.10.2\lib\40\FSharpx.Extras.dll</HintPath>
       <Private>True</Private>
     </Reference>
     <Reference Include="Metrics">
-      <HintPath>..\packages\Metrics.NET.0.2.6\lib\net45\Metrics.dll</HintPath>
+      <HintPath>..\..\..\packages\Metrics.NET.0.3.2-pre\lib\net45\Metrics.dll</HintPath>
       <Private>True</Private>
     </Reference>
     <Reference Include="mscorlib" />
@@ -114,9 +126,6 @@
     <Reference Include="System.Core" />
     <Reference Include="System.Numerics" />
     <Reference Include="System.Runtime.Caching" />
-    <Reference Include="FSharp.Core, Version=$(TargetFSharpCoreVersion), Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a">
-      <Private>True</Private>
-    </Reference>
   </ItemGroup>
   <ItemGroup>
     <ProjectReference Include="..\Eventful\Eventful.fsproj">

diff --git a/src/Eventful.RavenDb/WakeupMonitor.fs b/src/Eventful.RavenDb/WakeupMonitor.fs
@@ -70,7 +70,14 @@ type WakeupMonitor
 
                 do! 
                     getWakeups (DateTime.UtcNow |> UtcDateTime.fromDateTime)
-                    |> AsyncSeq.iter (fun (streamId, aggregateType, wakeupTime) -> onStreamWakeup streamId aggregateType wakeupTime)
+                    |> AsyncSeq.iter (
+                        fun (streamId, aggregateType, wakeupTime) -> 
+                            try
+                                onStreamWakeup streamId aggregateType wakeupTime
+                            with
+                            | ex ->
+                                log.WarnWithException(lazy (sprintf "Error onStreamWakeup with streamId %s" streamId, ex))
+                    )
                 return! loop ()
             }
 

diff --git a/src/Eventful.RavenDb/app.config b/src/Eventful.RavenDb/app.config
@@ -8,7 +8,7 @@
       </dependentAssembly>
       <dependentAssembly>
         <assemblyIdentity name="Newtonsoft.Json" publicKeyToken="30ad4fe6b2a6aeed" culture="neutral" />
-        <bindingRedirect oldVersion="0.0.0.0-6.0.0.0" newVersion="6.0.0.0" />
+        <bindingRedirect oldVersion="0.0.0.0-7.0.0.0" newVersion="7.0.0.0" />
       </dependentAssembly>
       <dependentAssembly>
         <assemblyIdentity name="System.Net.Http.Formatting" publicKeyToken="31bf3856ad364e35" culture="neutral" />