[incubator-pekko-samples] 02/09: test ask - scala

[fa...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

fanningpj pushed a commit to branch wip-rolling-update-typed-patriknw
in repository https://gitbox.apache.org/repos/asf/incubator-pekko-samples.git

commit 6ee737c99a6ff32cb65bf76562c1322e04b95d2a
Author: Patrik Nordwall <pa...@gmail.com>
AuthorDate: Wed Jun 19 18:19:06 2019 +0200

    test ask - scala
    
    * use ask for deviceId >= 40
---
 .../src/main/scala/sample/sharding/Devices.scala               | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git a/akka-sample-sharding-scala/src/main/scala/sample/sharding/Devices.scala b/akka-sample-sharding-scala/src/main/scala/sample/sharding/Devices.scala
index 6cbe318..5803a76 100644
--- a/akka-sample-sharding-scala/src/main/scala/sample/sharding/Devices.scala
+++ b/akka-sample-sharding-scala/src/main/scala/sample/sharding/Devices.scala
@@ -5,6 +5,9 @@ import scala.util.Random
 
 import akka.actor._
 import akka.cluster.sharding._
+import akka.pattern.ask
+import akka.pattern.pipe
+import akka.util.Timeout
 
 object Devices {
   // Update a random device
@@ -64,7 +67,12 @@ class Devices extends Actor with ActorLogging with Timers {
 
     case ReadTemperatures =>
       (0 to numberOfDevices).foreach { deviceId =>
-        deviceRegion ! Device.GetTemperature(deviceId)
+        if (deviceId >= 40) {
+          import context.dispatcher
+          implicit val timeout = Timeout(3.seconds)
+          deviceRegion.ask(Device.GetTemperature(deviceId)).pipeTo(self)
+        } else
+          deviceRegion ! Device.GetTemperature(deviceId)
       }
 
     case temp: Device.Temperature =>


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org