LocalNetwork implements Network { @Override public void send(Message msg, List<RoutingNode> recipients) { for (RoutingNode recipient : recipients) { new MessageEnvelope(this, msg, recipient).send(); } } LocalNetwork();  LocalNetwork(LocalWire wire); @Override boolean waitUntilReady(double seconds); @Override void attach(NetworkOwner owner); @Override void registerSession(String session); @Override void unregisterSession(String session); @Override boolean allocServiceAddress(RoutingNode recipient); @Override void freeServiceAddress(RoutingNode recipient); @Override void send(Message msg, List<RoutingNode> recipients); @Override void sync(); @Override void shutdown(); @Override String getConnectionSpec(); @Override IMirror getMirror();  }
@Test public void requireThatUnknownServiceRepliesWithNoAddressForService() throws InterruptedException { final Server server = new Server(new LocalWire()); final SourceSession source = server.newSourceSession(); final Message msg = new SimpleMessage("foo").setRoute(Route.parse("bar")); assertTrue(source.send(msg).isAccepted()); final Reply reply = server.replies.poll(60, TimeUnit.SECONDS); assertTrue(reply instanceof EmptyReply); server.mbus.destroy(); }