diff options
author | Jon Bratseth <bratseth@yahoo-inc.com> | 2016-09-29 16:36:21 +0200 |
---|---|---|
committer | Jon Bratseth <bratseth@yahoo-inc.com> | 2016-09-29 16:36:21 +0200 |
commit | b4656dc85fe215bf79eadedd868be0082fe70ab0 (patch) | |
tree | a3e11af2608694114a7fd5288748c7b2508e20d0 /messagebus/src/test | |
parent | 59f27953f5c8cd144f31f45a82d88d21511b8e6a (diff) |
Yahoo sets up mac wireless networks such that the local hostname points to an
ip which does not resolve. This works around that problem by finding a resolvable
address (while still falling back to localhost if we only get ipv6 addresses,
as that causes other problems in docker containers).
Diffstat (limited to 'messagebus/src/test')
-rwxr-xr-x | messagebus/src/test/java/com/yahoo/messagebus/ChokeTestCase.java | 37 |
1 files changed, 15 insertions, 22 deletions
diff --git a/messagebus/src/test/java/com/yahoo/messagebus/ChokeTestCase.java b/messagebus/src/test/java/com/yahoo/messagebus/ChokeTestCase.java index cde801d81f2..5e0df7068b0 100755 --- a/messagebus/src/test/java/com/yahoo/messagebus/ChokeTestCase.java +++ b/messagebus/src/test/java/com/yahoo/messagebus/ChokeTestCase.java @@ -11,28 +11,30 @@ import com.yahoo.messagebus.test.Receptor; import com.yahoo.messagebus.test.SimpleMessage; import com.yahoo.messagebus.test.SimpleProtocol; import junit.framework.TestCase; +import org.junit.After; +import org.junit.Before; +import org.junit.Ignore; +import org.junit.Test; import java.net.UnknownHostException; import java.util.ArrayList; import java.util.List; +import static org.junit.Assert.assertEquals; +import static org.junit.Assert.assertTrue; +import static org.junit.Assert.assertNotNull; +import static org.junit.Assert.assertFalse; /** - * @author <a href="mailto:simon@yahoo-inc.com">Simon Thoresen</a> + * @author Simon Thoresen */ -public class ChokeTestCase extends TestCase { - - //////////////////////////////////////////////////////////////////////////////// - // - // Setup - // - //////////////////////////////////////////////////////////////////////////////// +public class ChokeTestCase { Slobrok slobrok; TestServer srcServer, dstServer; SourceSession srcSession; DestinationSession dstSession; - @Override + @Before public void setUp() throws ListenFailedException, UnknownHostException { slobrok = new Slobrok(); dstServer = new TestServer(new MessageBusParams().addProtocol(new SimpleProtocol()), @@ -45,7 +47,7 @@ public class ChokeTestCase extends TestCase { assertTrue(srcServer.waitSlobrok("dst/session", 1)); } - @Override + @After public void tearDown() { slobrok.stop(); dstSession.destroy(); @@ -54,12 +56,7 @@ public class ChokeTestCase extends TestCase { srcServer.destroy(); } - //////////////////////////////////////////////////////////////////////////////// - // - // Tests - // - //////////////////////////////////////////////////////////////////////////////// - + @Test public void testMaxCount() { int max = 10; dstServer.mb.setMaxPendingCount(max); @@ -107,6 +104,7 @@ public class ChokeTestCase extends TestCase { assertEquals(0, dstServer.mb.getPendingCount()); } + @Test public void testMaxSize() { int size = createMessage("msg").getApproxSize(); int max = size * 10; @@ -155,15 +153,10 @@ public class ChokeTestCase extends TestCase { assertEquals(0, dstServer.mb.getPendingSize()); } - //////////////////////////////////////////////////////////////////////////////// - // - // Utilities - // - //////////////////////////////////////////////////////////////////////////////// - private static Message createMessage(String msg) { Message ret = new SimpleMessage(msg); ret.getTrace().setLevel(9); return ret; } + } |