added price initiator to keep price shards warm w/o entity passivation (

#57)
petabridge · Aug 16, 2019 · 98d6c8d · 98d6c8d
1 parent 4babf95
commit 98d6c8d
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 3 deletions.
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");