Merge pull request #60 from petabridge/dev

v0.1.6 Release
petabridge · Aug 16, 2019 · 13dc4fd · 13dc4fd
2 parents d94b69f + eb2df36
commit 13dc4fd
Show file tree

Hide file tree

Showing 9 changed files with 27 additions and 11 deletions.
diff --git a/RELEASE_NOTES.md b/RELEASE_NOTES.md
@@ -1,2 +1,2 @@
-#### 0.1.5 August 14 2019 ####
-* Upgraded to Akka.NET v1.3.14 and Phobos v0.7.0
+#### 0.1.6 August 16 2019 ####
+* Added cluster singleton for pricing entity startup.
diff --git a/build.sh b/build.sh
@@ -91,6 +91,17 @@ if [ ! -f "$FAKE_EXE" ]; then
     exit 1
 fi
 
+###########################################################################
+# INSTALL Protobuf
+###########################################################################
+if [ ! -f "$PROTOBUF_EXE" ]; then
+    mono "$NUGET_EXE" install Google.Protobuf.Tools -ExcludeVersion -Version $PROTOBUF_VERSION -OutputDirectory "$TOOLS_DIR"
+    if [ $? -ne 0 ]; then
+        echo "An error occured while installing Google.Protobuf.Tools."
+        exit 1
+    fi
+fi
+
 ###########################################################################
 # INSTALL DOCFX
 ###########################################################################

diff --git a/k8s/pricing-deploy.yaml b/k8s/pricing-deploy.yaml
@@ -33,7 +33,7 @@ spec:
       terminationGracePeriodSeconds: 35
       containers:
       - name: pricing
-        image: akka.cqrs.pricing:0.1.5
+        image: akka.cqrs.pricing:0.1.6
         lifecycle:
           preStop:
             exec:

diff --git a/k8s/pricing-web-deploy.yaml b/k8s/pricing-web-deploy.yaml
@@ -51,7 +51,7 @@ spec:
       terminationGracePeriodSeconds: 35
       containers:
       - name: pricing-web
-        image: akka.cqrs.pricing.web:0.1.5
+        image: akka.cqrs.pricing.web:0.1.6
         lifecycle:
           preStop:
             exec:

diff --git a/k8s/tradeprocessor-deploy.yaml b/k8s/tradeprocessor-deploy.yaml
@@ -33,7 +33,7 @@ spec:
       terminationGracePeriodSeconds: 35
       containers:
       - name: trade-processor
-        image: akka.cqrs.tradeprocessor:0.1.5
+        image: akka.cqrs.tradeprocessor:0.1.6
         lifecycle:
           preStop:
             exec:

diff --git a/k8s/traders-deploy.yaml b/k8s/traders-deploy.yaml
@@ -33,7 +33,7 @@ spec:
       terminationGracePeriodSeconds: 35
       containers:
       - name: traders
-        image: akka.cqrs.traders:0.1.5
+        image: akka.cqrs.traders:0.1.6
         lifecycle:
           preStop:
             exec:

diff --git a/src/Akka.CQRS.Pricing.Actors/MatchAggregator.cs b/src/Akka.CQRS.Pricing.Actors/MatchAggregator.cs
@@ -88,9 +88,7 @@ private void Recovers()
         /// Recovery has completed successfully.
         /// </summary>
         protected override void OnReplaySuccess()
-        {
-            _publishPricesTask = Context.System.Scheduler.ScheduleTellRepeatedlyCancelable(TimeSpan.FromSeconds(10),
-                TimeSpan.FromSeconds(10), Self, PublishEvents.Instance, ActorRefs.NoSender);
+        {         
 
             // setup subscription to TradeEventPublisher
             Self.Tell(DoSubscribe.Instance);
@@ -263,6 +261,9 @@ private void Commands()
 
         protected override void PreStart()
         {
+            _publishPricesTask = Context.System.Scheduler.ScheduleTellRepeatedlyCancelable(TimeSpan.FromSeconds(10),
+               TimeSpan.FromSeconds(10), Self, PublishEvents.Instance, ActorRefs.NoSender);
+
             _log.Info("Starting...");
             base.PreStart();
         }

diff --git a/src/Akka.CQRS.Pricing.Service/Program.cs b/src/Akka.CQRS.Pricing.Service/Program.cs
@@ -32,11 +32,15 @@ static int Main(string[] args)
 
             var sharding = ClusterSharding.Get(actorSystem);
 
+
             var shardRegion = sharding.Start("priceAggregator",
                 s => Props.Create(() => new MatchAggregator(s)),
                 ClusterShardingSettings.Create(actorSystem),
                 new StockShardMsgRouter());
 
+            var priceInitiatorActor = actorSystem.ActorOf(ClusterSingletonManager.Props(Props.Create(() => new PriceInitiatorActor(shardRegion)),
+                ClusterSingletonManagerSettings.Create(actorSystem).WithRole("pricing-engine").WithSingletonName("priceInitiator")), "priceInitiator");
+
             var clientHandler =
                 actorSystem.ActorOf(Props.Create(() => new ClientHandlerActor(shardRegion)), "subscriptions");
 

diff --git a/src/common.props b/src/common.props
@@ -2,8 +2,8 @@
   <PropertyGroup>
     <Copyright>Copyright © 2015-2019 Petabridge</Copyright>
     <Authors>Petabridge</Authors>
-    <VersionPrefix>0.1.5</VersionPrefix>
-    <PackageReleaseNotes>Upgraded to Akka.NET v1.3.14 and Phobos v0.7.0</PackageReleaseNotes>
+    <VersionPrefix>0.1.6</VersionPrefix>
+    <PackageReleaseNotes>Added cluster singleton for pricing entity startup.</PackageReleaseNotes>
     <PackageIconUrl>
     </PackageIconUrl>
     <PackageProjectUrl>