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 <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
