Ref local

jet · Jun 10, 2019 · 0045a0d · 0045a0d
1 parent dd17999
commit 0045a0d
Show file tree

Hide file tree

Showing 3 changed files with 27 additions and 4 deletions.
diff --git a/equinox-projector/Projector/Program.fs b/equinox-projector/Projector/Program.fs
@@ -148,8 +148,8 @@ module Logging =
             |> fun c -> c.CreateLogger()
 
 let replaceLongDataWithNull (x : Propulsion.Streams.IEvent<byte[]>) : Propulsion.Streams.IEvent<_> =
-    if x.Data.Length < 900_000 then x
-    else Propulsion.Streams.Internal.EventData.Create(x.EventType,null,x.Meta,x.Timestamp) :> _
+    //if x.Data.Length < 900_000 then x
+    Propulsion.Streams.Internal.EventData.Create(x.EventType,null,x.Meta,x.Timestamp) :> _
 
 let hackDropBigBodies (e : Propulsion.Streams.StreamEvent<_>) : Propulsion.Streams.StreamEvent<_> =
     { stream = e.stream; index = e.index; event = replaceLongDataWithNull e.event }

diff --git a/equinox-projector/Projector/Projector.fsproj b/equinox-projector/Projector/Projector.fsproj
@@ -14,11 +14,16 @@
   <ItemGroup>
     <PackageReference Include="Argu" Version="5.4.0" />
     <PackageReference Include="Destructurama.FSharp.NetCore" Version="1.0.14" />
-    <PackageReference Include="Propulsion.Cosmos" Version="1.0.1-rc2" />
+    <!--<PackageReference Include="Propulsion.Cosmos" Version="1.0.1-rc2" />-->
     <!--#if (kafka)-->
-    <PackageReference Include="Propulsion.Kafka" Version="1.0.1-rc2" />
+    <!--<PackageReference Include="Propulsion.Kafka" Version="1.0.1-rc2" />-->
     <!--#endif-->
     <PackageReference Include="Serilog.Sinks.Console" Version="3.1.1" />
   </ItemGroup>
 
+  <ItemGroup>
+    <ProjectReference Include="..\..\..\propulsion\src\Propulsion.Cosmos\Propulsion.Cosmos.fsproj" />
+    <ProjectReference Include="..\..\..\propulsion\src\Propulsion.Kafka\Propulsion.Kafka.fsproj" />
+  </ItemGroup>
+
 </Project>
diff --git a/equinox-projector/equinox-projector-consumer.sln b/equinox-projector/equinox-projector-consumer.sln
@@ -12,6 +12,12 @@ Project("{6EC3EE1D-3C4E-46DD-8F32-0CC8E7565705}") = "Consumer", "Consumer\Consum
 EndProject
 Project("{6EC3EE1D-3C4E-46DD-8F32-0CC8E7565705}") = "Projector", "Projector\Projector.fsproj", "{72668C1E-2187-4DAF-BDBE-1637CDA67894}"
 EndProject
+Project("{6EC3EE1D-3C4E-46DD-8F32-0CC8E7565705}") = "Propulsion.Kafka", "..\..\propulsion\src\Propulsion.Kafka\Propulsion.Kafka.fsproj", "{B1E538BB-8C5B-4120-9BE9-2D3C1DC28207}"
+EndProject
+Project("{6EC3EE1D-3C4E-46DD-8F32-0CC8E7565705}") = "Propulsion", "..\..\propulsion\src\Propulsion\Propulsion.fsproj", "{5FA33C5B-9DD2-44BF-B2DF-B790DCED2A76}"
+EndProject
+Project("{6EC3EE1D-3C4E-46DD-8F32-0CC8E7565705}") = "Propulsion.Cosmos", "..\..\propulsion\src\Propulsion.Cosmos\Propulsion.Cosmos.fsproj", "{EC6A27BB-DECF-4799-8E2A-85102E7328CF}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -26,6 +32,18 @@ Global
 		{72668C1E-2187-4DAF-BDBE-1637CDA67894}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{72668C1E-2187-4DAF-BDBE-1637CDA67894}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{72668C1E-2187-4DAF-BDBE-1637CDA67894}.Release|Any CPU.Build.0 = Release|Any CPU
+		{B1E538BB-8C5B-4120-9BE9-2D3C1DC28207}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{B1E538BB-8C5B-4120-9BE9-2D3C1DC28207}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{B1E538BB-8C5B-4120-9BE9-2D3C1DC28207}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{B1E538BB-8C5B-4120-9BE9-2D3C1DC28207}.Release|Any CPU.Build.0 = Release|Any CPU
+		{5FA33C5B-9DD2-44BF-B2DF-B790DCED2A76}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{5FA33C5B-9DD2-44BF-B2DF-B790DCED2A76}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{5FA33C5B-9DD2-44BF-B2DF-B790DCED2A76}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{5FA33C5B-9DD2-44BF-B2DF-B790DCED2A76}.Release|Any CPU.Build.0 = Release|Any CPU
+		{EC6A27BB-DECF-4799-8E2A-85102E7328CF}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{EC6A27BB-DECF-4799-8E2A-85102E7328CF}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{EC6A27BB-DECF-4799-8E2A-85102E7328CF}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{EC6A27BB-DECF-4799-8E2A-85102E7328CF}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE