From a46b74654f4a0ef1cbc93286dca8d706b6c7ccd9 Mon Sep 17 00:00:00 2001 From: Viktor Klang Date: Thu, 29 Nov 2012 14:46:42 +0100 Subject: [PATCH] #2754 - adding the stopping of 0mq actors in the Java doc example as the Scala version has. --- akka-docs/rst/java/code/docs/zeromq/ZeromqDocTestBase.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/akka-docs/rst/java/code/docs/zeromq/ZeromqDocTestBase.java b/akka-docs/rst/java/code/docs/zeromq/ZeromqDocTestBase.java index d9d09a9bac..9ec3bc49f9 100644 --- a/akka-docs/rst/java/code/docs/zeromq/ZeromqDocTestBase.java +++ b/akka-docs/rst/java/code/docs/zeromq/ZeromqDocTestBase.java @@ -99,6 +99,9 @@ public class ZeromqDocTestBase { pubSocket.tell(new ZMQMessage(new Frame("foo.bar"), new Frame(payload)), null); //#pub-topic + system.stop(subSocket); + system.stop(subTopicSocket); + //#high-watermark ActorRef highWatermarkSocket = ZeroMQExtension.get(system).newRouterSocket( new SocketOption[] { new Listener(listener),