diff options
Diffstat (limited to 'jdisc_messagebus_service/src/test/java/com/yahoo/messagebus/shared/SharedMessageBusTestCase.java')
-rw-r--r-- | jdisc_messagebus_service/src/test/java/com/yahoo/messagebus/shared/SharedMessageBusTestCase.java | 37 |
1 files changed, 37 insertions, 0 deletions
diff --git a/jdisc_messagebus_service/src/test/java/com/yahoo/messagebus/shared/SharedMessageBusTestCase.java b/jdisc_messagebus_service/src/test/java/com/yahoo/messagebus/shared/SharedMessageBusTestCase.java new file mode 100644 index 00000000000..8cd705bbcab --- /dev/null +++ b/jdisc_messagebus_service/src/test/java/com/yahoo/messagebus/shared/SharedMessageBusTestCase.java @@ -0,0 +1,37 @@ +// Copyright 2016 Yahoo Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. +package com.yahoo.messagebus.shared; + +import com.yahoo.jrt.ListenFailedException; +import com.yahoo.jrt.slobrok.server.Slobrok; +import com.yahoo.messagebus.MessageBusParams; +import com.yahoo.messagebus.network.rpc.RPCNetworkParams; +import org.junit.Test; + +import static org.junit.Assert.assertFalse; +import static org.junit.Assert.fail; + +/** + * @author <a href="mailto:simon@yahoo-inc.com">Simon Thoresen</a> + */ +public class SharedMessageBusTestCase { + + @Test + public void requireThatMbusCanNotBeNull() { + try { + new SharedMessageBus(null); + fail(); + } catch (NullPointerException e) { + // expected + } + } + + @Test + public void requireThatMbusIsClosedOnDestroy() throws ListenFailedException { + Slobrok slobrok = new Slobrok(); + SharedMessageBus mbus = SharedMessageBus.newInstance(new MessageBusParams(), + new RPCNetworkParams() + .setSlobrokConfigId(slobrok.configId())); + mbus.release(); + assertFalse(mbus.messageBus().destroy()); + } +} |