From 14ef960f5e963343a8c626e860bb816d9ac33921 Mon Sep 17 00:00:00 2001 From: Arnout Engelen Date: Fri, 7 Jul 2017 11:29:58 +0200 Subject: [PATCH] Improve Java pubsub example `Put` does not result in a `SubscribeAck` --- .../akka/cluster/pubsub/DistributedPubSubMediatorTest.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/akka-cluster-tools/src/test/java/akka/cluster/pubsub/DistributedPubSubMediatorTest.java b/akka-cluster-tools/src/test/java/akka/cluster/pubsub/DistributedPubSubMediatorTest.java index 5de6397475..fdf3fc93d5 100644 --- a/akka-cluster-tools/src/test/java/akka/cluster/pubsub/DistributedPubSubMediatorTest.java +++ b/akka-cluster-tools/src/test/java/akka/cluster/pubsub/DistributedPubSubMediatorTest.java @@ -82,7 +82,7 @@ public class DistributedPubSubMediatorTest extends JUnitSuite { .match(String.class, msg -> log.info("Got: {}", msg)) .match(DistributedPubSubMediator.SubscribeAck.class, msg -> - log.info("subscribing")) + log.info("subscribed")) .build(); } } @@ -126,8 +126,6 @@ public class DistributedPubSubMediatorTest extends JUnitSuite { return receiveBuilder() .match(String.class, msg -> log.info("Got: {}", msg)) - .match(DistributedPubSubMediator.SubscribeAck.class, msg -> - log.info("subscribing")) .build(); }