diff options
Diffstat (limited to 'jdisc_messagebus_service/src/test/java/com/yahoo/messagebus/jdisc/MbusRequestTestCase.java')
-rw-r--r-- | jdisc_messagebus_service/src/test/java/com/yahoo/messagebus/jdisc/MbusRequestTestCase.java | 71 |
1 files changed, 71 insertions, 0 deletions
diff --git a/jdisc_messagebus_service/src/test/java/com/yahoo/messagebus/jdisc/MbusRequestTestCase.java b/jdisc_messagebus_service/src/test/java/com/yahoo/messagebus/jdisc/MbusRequestTestCase.java new file mode 100644 index 00000000000..4a19dff5d96 --- /dev/null +++ b/jdisc_messagebus_service/src/test/java/com/yahoo/messagebus/jdisc/MbusRequestTestCase.java @@ -0,0 +1,71 @@ +// Copyright 2016 Yahoo Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. +package com.yahoo.messagebus.jdisc; + +import com.yahoo.jdisc.test.TestDriver; +import com.yahoo.messagebus.Message; +import com.yahoo.messagebus.test.SimpleMessage; +import com.yahoo.text.Utf8String; +import org.junit.Test; + +import java.net.URI; + +import static org.junit.Assert.*; + +/** + * @author <a href="mailto:simon@yahoo-inc.com">Simon Thoresen</a> + */ +public class MbusRequestTestCase { + + @Test + public void requireThatAccessorsWork() { + TestDriver driver = TestDriver.newSimpleApplicationInstanceWithoutOsgi(); + driver.activateContainer(driver.newContainerBuilder()); + + MyMessage msg = new MyMessage(); + MbusRequest request = new MbusRequest(driver, URI.create("mbus://host/path"), msg); + assertSame(msg, request.getMessage()); + request.release(); + driver.close(); + } + + @Test + public void requireThatMessageCanNotBeNullInRootRequest() { + TestDriver driver = TestDriver.newSimpleApplicationInstanceWithoutOsgi(); + driver.activateContainer(driver.newContainerBuilder()); + try { + new MbusRequest(driver, URI.create("mbus://host/path"), null); + fail(); + } catch (NullPointerException e) { + // expected + } + assertTrue(driver.close()); + } + + @Test + public void requireThatMessageCanNotBeNullInChildRequest() { + TestDriver driver = TestDriver.newSimpleApplicationInstanceWithoutOsgi(); + driver.activateContainer(driver.newContainerBuilder()); + MbusRequest parent = new MbusRequest(driver, URI.create("mbus://host/path"), new SimpleMessage("foo")); + try { + new MbusRequest(parent, URI.create("mbus://host/path"), null); + fail(); + } catch (NullPointerException e) { + // expected + } + parent.release(); + assertTrue(driver.close()); + } + + private class MyMessage extends Message { + + @Override + public Utf8String getProtocol() { + return null; + } + + @Override + public int getType() { + return 0; + } + } +} |