diff options
Diffstat (limited to 'messagebus/src/test/java/com/yahoo/messagebus/SimpleTripTestCase.java')
-rwxr-xr-x | messagebus/src/test/java/com/yahoo/messagebus/SimpleTripTestCase.java | 22 |
1 files changed, 10 insertions, 12 deletions
diff --git a/messagebus/src/test/java/com/yahoo/messagebus/SimpleTripTestCase.java b/messagebus/src/test/java/com/yahoo/messagebus/SimpleTripTestCase.java index f13749ae213..0f930c51152 100755 --- a/messagebus/src/test/java/com/yahoo/messagebus/SimpleTripTestCase.java +++ b/messagebus/src/test/java/com/yahoo/messagebus/SimpleTripTestCase.java @@ -11,11 +11,9 @@ import com.yahoo.messagebus.test.Receptor; import com.yahoo.messagebus.test.SimpleMessage; import com.yahoo.messagebus.test.SimpleProtocol; import com.yahoo.messagebus.test.SimpleReply; -import org.junit.Test; +import org.junit.jupiter.api.Test; -import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertNotNull; -import static org.junit.Assert.assertTrue; +import static org.junit.jupiter.api.Assertions.*; /** * @author Simon Thoresen Hult @@ -23,32 +21,32 @@ import static org.junit.Assert.assertTrue; public class SimpleTripTestCase { @Test - public void testSimpleTrip() throws ListenFailedException { + void testSimpleTrip() throws ListenFailedException { Slobrok slobrok = new Slobrok(); TestServer server = new TestServer(new MessageBusParams().addProtocol(new SimpleProtocol()), - new RPCNetworkParams() - .setIdentity(new Identity("srv")) - .setSlobrokConfigId(TestServer.getSlobrokConfig(slobrok))); + new RPCNetworkParams() + .setIdentity(new Identity("srv")) + .setSlobrokConfigId(TestServer.getSlobrokConfig(slobrok))); DestinationSession dst = server.mb.createDestinationSession(new DestinationSessionParams().setName("session").setMessageHandler(new Receptor())); SourceSession src = server.mb.createSourceSession( new SourceSessionParams().setTimeout(600.0).setReplyHandler(new Receptor())); assertTrue(server.waitSlobrok("srv/session", 1)); assertTrue(src.send(new SimpleMessage("msg"), Route.parse("srv/session")).isAccepted()); - Message msg = ((Receptor)dst.getMessageHandler()).getMessage(60); + Message msg = ((Receptor) dst.getMessageHandler()).getMessage(60); assertNotNull(msg); assertEquals(SimpleProtocol.NAME, msg.getProtocol()); assertEquals(SimpleProtocol.MESSAGE, msg.getType()); - assertEquals("msg", ((SimpleMessage)msg).getValue()); + assertEquals("msg", ((SimpleMessage) msg).getValue()); Reply reply = new SimpleReply("reply"); reply.swapState(msg); dst.reply(reply); - assertNotNull(reply = ((Receptor)src.getReplyHandler()).getReply(60)); + assertNotNull(reply = ((Receptor) src.getReplyHandler()).getReply(60)); assertEquals(SimpleProtocol.NAME, reply.getProtocol()); assertEquals(SimpleProtocol.REPLY, reply.getType()); - assertEquals("reply", ((SimpleReply)reply).getValue()); + assertEquals("reply", ((SimpleReply) reply).getValue()); src.destroy(); dst.destroy(); |