summaryrefslogtreecommitdiffstats
path: root/policy-management/src
diff options
context:
space:
mode:
Diffstat (limited to 'policy-management/src')
-rw-r--r--policy-management/src/test/java/org/onap/policy/drools/system/PolicyControllerFactoryTest.java69
-rw-r--r--policy-management/src/test/java/org/onap/policy/drools/system/PolicyEngineManagerTest.java118
-rw-r--r--policy-management/src/test/java/org/onap/policy/drools/system/internal/AggregatedPolicyControllerTest.java25
3 files changed, 111 insertions, 101 deletions
diff --git a/policy-management/src/test/java/org/onap/policy/drools/system/PolicyControllerFactoryTest.java b/policy-management/src/test/java/org/onap/policy/drools/system/PolicyControllerFactoryTest.java
index f5c71064..f5fc8a5c 100644
--- a/policy-management/src/test/java/org/onap/policy/drools/system/PolicyControllerFactoryTest.java
+++ b/policy-management/src/test/java/org/onap/policy/drools/system/PolicyControllerFactoryTest.java
@@ -2,7 +2,7 @@
* ============LICENSE_START=======================================================
* ONAP
* ================================================================================
- * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2018-2019 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -20,6 +20,8 @@
package org.onap.policy.drools.system;
+import static org.assertj.core.api.Assertions.assertThatIllegalArgumentException;
+import static org.assertj.core.api.Assertions.assertThatIllegalStateException;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.mockito.Matchers.any;
@@ -28,7 +30,6 @@ import static org.mockito.Mockito.never;
import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;
-import static org.onap.policy.common.utils.test.PolicyAssert.assertThrows;
import java.util.Arrays;
import java.util.Collections;
@@ -127,7 +128,7 @@ public class PolicyControllerFactoryTest {
@Test
public void testPatchStringDroolsConfiguration() {
// unknown controller
- assertThrows(IllegalArgumentException.class, () -> ipc.patch(MY_NAME, config));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.patch(MY_NAME, config));
/*
* Build controller to be used by remaining tests.
@@ -136,10 +137,10 @@ public class PolicyControllerFactoryTest {
// null name
String nullName = null;
- assertThrows(IllegalArgumentException.class, () -> ipc.patch(nullName, config));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.patch(nullName, config));
// empty name
- assertThrows(IllegalArgumentException.class, () -> ipc.patch("", config));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.patch("", config));
// success
ipc.patch(MY_NAME, config);
@@ -153,7 +154,7 @@ public class PolicyControllerFactoryTest {
}
};
ipc.build(MY_NAME, properties);
- assertThrows(IllegalArgumentException.class, () -> ipc.patch(MY_NAME, config));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.patch(MY_NAME, config));
}
@Test
@@ -163,10 +164,10 @@ public class PolicyControllerFactoryTest {
// null controller
PolicyController nullCtlr = null;
- assertThrows(IllegalArgumentException.class, () -> ipc.patch(nullCtlr, config));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.patch(nullCtlr, config));
// null config
- assertThrows(IllegalArgumentException.class, () -> ipc.patch(controller, null));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.patch(controller, null));
// brained
when(drools.isBrained()).thenReturn(true);
@@ -174,17 +175,17 @@ public class PolicyControllerFactoryTest {
// update failed
when(controller.updateDrools(config)).thenReturn(false);
- assertThrows(IllegalArgumentException.class, () -> ipc.patch(controller, config));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.patch(controller, config));
}
@Test
public void testShutdownString() {
// null name
String nullName = null;
- assertThrows(IllegalArgumentException.class, () -> ipc.shutdown(nullName));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.shutdown(nullName));
// empty name
- assertThrows(IllegalArgumentException.class, () -> ipc.shutdown(""));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.shutdown(""));
// unknown controller
ipc.shutdown(MY_NAME);
@@ -205,7 +206,7 @@ public class PolicyControllerFactoryTest {
verify(controller).shutdown();
// should no longer be managed
- assertThrows(IllegalArgumentException.class, () -> ipc.get(MY_NAME));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.get(MY_NAME));
}
@Test
@@ -219,8 +220,8 @@ public class PolicyControllerFactoryTest {
verify(controller2).shutdown();
// should no longer be managed
- assertThrows(IllegalArgumentException.class, () -> ipc.get(MY_NAME));
- assertThrows(IllegalArgumentException.class, () -> ipc.get(MY_NAME2));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.get(MY_NAME));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.get(MY_NAME2));
}
@Test
@@ -234,14 +235,14 @@ public class PolicyControllerFactoryTest {
verify(controller2, never()).shutdown();
// should no longer be managed
- assertThrows(IllegalArgumentException.class, () -> ipc.get(MY_NAME));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.get(MY_NAME));
// should still be managed
assertEquals(controller2, ipc.get(MY_NAME2));
// null controller
PolicyController nullCtlr = null;
- assertThrows(IllegalArgumentException.class, () -> ipc.shutdown(nullCtlr));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.shutdown(nullCtlr));
// unknown controller
ipc.shutdown(controller);
@@ -252,10 +253,10 @@ public class PolicyControllerFactoryTest {
public void testDestroyString() {
// null name
String nullName = null;
- assertThrows(IllegalArgumentException.class, () -> ipc.destroy(nullName));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.destroy(nullName));
// empty name
- assertThrows(IllegalArgumentException.class, () -> ipc.destroy(""));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.destroy(""));
// unknown controller
ipc.destroy(MY_NAME);
@@ -276,7 +277,7 @@ public class PolicyControllerFactoryTest {
verify(controller).halt();
// should no longer be managed
- assertThrows(IllegalArgumentException.class, () -> ipc.get(MY_NAME));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.get(MY_NAME));
}
@Test
@@ -290,14 +291,14 @@ public class PolicyControllerFactoryTest {
verify(controller2).halt();
// should no longer be managed
- assertThrows(IllegalArgumentException.class, () -> ipc.get(MY_NAME));
- assertThrows(IllegalArgumentException.class, () -> ipc.get(MY_NAME2));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.get(MY_NAME));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.get(MY_NAME2));
}
@Test
public void testGetString() {
// unknown name
- assertThrows(IllegalArgumentException.class, () -> ipc.get(MY_NAME));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.get(MY_NAME));
ipc.build(MY_NAME, properties);
ipc.build(MY_NAME2, properties);
@@ -307,16 +308,16 @@ public class PolicyControllerFactoryTest {
// null name
String nullName = null;
- assertThrows(IllegalArgumentException.class, () -> ipc.get(nullName));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.get(nullName));
// empty name
- assertThrows(IllegalArgumentException.class, () -> ipc.get(""));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.get(""));
}
@Test
public void testGetStringString_testToKey() {
// unknown controller
- assertThrows(IllegalArgumentException.class, () -> ipc.get(GROUP1, ARTIFACT1));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.get(GROUP1, ARTIFACT1));
when(drools.isBrained()).thenReturn(true);
when(drools2.isBrained()).thenReturn(true);
@@ -328,22 +329,22 @@ public class PolicyControllerFactoryTest {
assertEquals(controller2, ipc.get(GROUP2, ARTIFACT2));
// null group
- assertThrows(IllegalArgumentException.class, () -> ipc.get(null, ARTIFACT1));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.get(null, ARTIFACT1));
// empty group
- assertThrows(IllegalArgumentException.class, () -> ipc.get("", ARTIFACT1));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.get("", ARTIFACT1));
// null artifact
- assertThrows(IllegalArgumentException.class, () -> ipc.get(GROUP1, null));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.get(GROUP1, null));
// empty artifact
- assertThrows(IllegalArgumentException.class, () -> ipc.get(GROUP1, ""));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.get(GROUP1, ""));
}
@Test
public void testGetDroolsController() {
// unknown controller
- assertThrows(IllegalStateException.class, () -> ipc.get(drools));
+ assertThatIllegalStateException().isThrownBy(() -> ipc.get(drools));
when(drools.isBrained()).thenReturn(true);
when(drools2.isBrained()).thenReturn(true);
@@ -356,7 +357,7 @@ public class PolicyControllerFactoryTest {
// null controller
DroolsController nullDrools = null;
- assertThrows(IllegalArgumentException.class, () -> ipc.get(nullDrools));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.get(nullDrools));
}
@Test
@@ -382,13 +383,13 @@ public class PolicyControllerFactoryTest {
@Test
public void testGetFeatureProvider() {
// null name
- assertThrows(IllegalArgumentException.class, () -> ipc.getFeatureProvider(null));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.getFeatureProvider(null));
// empty name
- assertThrows(IllegalArgumentException.class, () -> ipc.getFeatureProvider(""));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.getFeatureProvider(""));
// unknown name
- assertThrows(IllegalArgumentException.class, () -> ipc.getFeatureProvider("unknown-feature"));
+ assertThatIllegalArgumentException().isThrownBy(() -> ipc.getFeatureProvider("unknown-feature"));
assertEquals(feature1, ipc.getFeatureProvider(FEATURE1));
assertEquals(feature2, ipc.getFeatureProvider(FEATURE2));
diff --git a/policy-management/src/test/java/org/onap/policy/drools/system/PolicyEngineManagerTest.java b/policy-management/src/test/java/org/onap/policy/drools/system/PolicyEngineManagerTest.java
index 5329dcc3..4f7e1b0a 100644
--- a/policy-management/src/test/java/org/onap/policy/drools/system/PolicyEngineManagerTest.java
+++ b/policy-management/src/test/java/org/onap/policy/drools/system/PolicyEngineManagerTest.java
@@ -2,7 +2,7 @@
* ============LICENSE_START=======================================================
* ONAP
* ================================================================================
- * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2018-2019 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -20,6 +20,9 @@
package org.onap.policy.drools.system;
+import static org.assertj.core.api.Assertions.assertThatIllegalArgumentException;
+import static org.assertj.core.api.Assertions.assertThatIllegalStateException;
+import static org.assertj.core.api.Assertions.assertThatThrownBy;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertNotNull;
@@ -33,7 +36,6 @@ import static org.mockito.Mockito.never;
import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;
-import static org.onap.policy.common.utils.test.PolicyAssert.assertThrows;
import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
@@ -51,7 +53,6 @@ import org.onap.policy.common.endpoints.event.comm.TopicSink;
import org.onap.policy.common.endpoints.event.comm.TopicSource;
import org.onap.policy.common.endpoints.http.server.HttpServletServer;
import org.onap.policy.common.endpoints.http.server.HttpServletServerFactory;
-import org.onap.policy.common.utils.test.PolicyAssert.RunnableWithEx;
import org.onap.policy.drools.controller.DroolsController;
import org.onap.policy.drools.features.PolicyControllerFeatureAPI;
import org.onap.policy.drools.features.PolicyEngineFeatureAPI;
@@ -398,7 +399,7 @@ public class PolicyEngineManagerTest {
// null properties - nothing should be invoked
setUp();
Properties nullProps = null;
- assertThrows(IllegalArgumentException.class, () -> mgr.configure(nullProps));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.configure(nullProps));
verify(prov1, never()).beforeConfigure(mgr, properties);
verify(prov1, never()).afterConfigure(mgr);
@@ -422,10 +423,10 @@ public class PolicyEngineManagerTest {
// invalid params
PdpdConfiguration nullConfig = null;
- assertThrows(IllegalArgumentException.class, () -> mgr.configure(nullConfig));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.configure(nullConfig));
pdpConfig.setEntity("unknown-entity");
- assertThrows(IllegalArgumentException.class, () -> mgr.configure(pdpConfig));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.configure(pdpConfig));
// source list of size 1
setUp();
@@ -482,7 +483,7 @@ public class PolicyEngineManagerTest {
// mismatching name in properties - nothing should happen besides exception
setUp();
properties.setProperty(DroolsProperties.PROPERTY_CONTROLLER_NAME, "mistmatched-name");
- assertThrows(IllegalStateException.class, () -> mgr.createPolicyController(MY_NAME, properties));
+ assertThatIllegalStateException().isThrownBy(() -> mgr.createPolicyController(MY_NAME, properties));
verify(contProv1, never()).beforeCreate(MY_NAME, properties);
// first provider generates controller - stops after first provider
@@ -543,29 +544,29 @@ public class PolicyEngineManagerTest {
verify(engine).createPolicyController(CONTROLLER3, properties);
// invalid parameters
- assertThrows(IllegalArgumentException.class, () -> mgr.updatePolicyController(null));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.updatePolicyController(null));
// invalid name
setUp();
config3.setName(null);
- assertThrows(IllegalArgumentException.class, () -> mgr.updatePolicyController(config3));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.updatePolicyController(config3));
config3.setName("");
- assertThrows(IllegalArgumentException.class, () -> mgr.updatePolicyController(config3));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.updatePolicyController(config3));
// invalid operation
setUp();
config3.setOperation(null);
- assertThrows(IllegalArgumentException.class, () -> mgr.updatePolicyController(config3));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.updatePolicyController(config3));
config3.setOperation("");
- assertThrows(IllegalArgumentException.class, () -> mgr.updatePolicyController(config3));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.updatePolicyController(config3));
config3.setOperation(ControllerConfiguration.CONFIG_CONTROLLER_OPERATION_LOCK);
- assertThrows(IllegalArgumentException.class, () -> mgr.updatePolicyController(config3));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.updatePolicyController(config3));
config3.setOperation(ControllerConfiguration.CONFIG_CONTROLLER_OPERATION_UNLOCK);
- assertThrows(IllegalArgumentException.class, () -> mgr.updatePolicyController(config3));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.updatePolicyController(config3));
// exception from get() - should create controller
setUp();
@@ -576,12 +577,12 @@ public class PolicyEngineManagerTest {
// null properties
setUp();
when(persist.getControllerProperties(CONTROLLER3)).thenReturn(null);
- assertThrows(IllegalArgumentException.class, () -> mgr.updatePolicyController(config3));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.updatePolicyController(config3));
// throw linkage error
setUp();
when(persist.getControllerProperties(CONTROLLER3)).thenThrow(new LinkageError(EXPECTED));
- assertThrows(IllegalStateException.class, () -> mgr.updatePolicyController(config3));
+ assertThatIllegalStateException().isThrownBy(() -> mgr.updatePolicyController(config3));
/*
* For remaining tests, the factory will return the controller instead of creating
@@ -629,7 +630,7 @@ public class PolicyEngineManagerTest {
// invalid operation
config3.setOperation("invalid-operation");
- assertThrows(IllegalArgumentException.class, () -> mgr.updatePolicyController(config3));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.updatePolicyController(config3));
}
@Test
@@ -669,7 +670,7 @@ public class PolicyEngineManagerTest {
setUp();
mgr.configure(properties);
mgr.lock();
- assertThrows(IllegalStateException.class, () -> mgr.start());
+ assertThatIllegalStateException().isThrownBy(() -> mgr.start());
verify(prov2).beforeStart(mgr);
verify(server2, never()).waitedStart(anyLong());
verify(source2, never()).start();
@@ -1152,13 +1153,13 @@ public class PolicyEngineManagerTest {
assertEquals(prov2, mgr.getFeatureProvider(FEATURE2));
// null feature
- assertThrows(IllegalArgumentException.class, () -> mgr.getFeatureProvider(null));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.getFeatureProvider(null));
// empty feature
- assertThrows(IllegalArgumentException.class, () -> mgr.getFeatureProvider(""));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.getFeatureProvider(""));
// unknown feature
- assertThrows(IllegalArgumentException.class, () -> mgr.getFeatureProvider("unknown-feature"));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.getFeatureProvider("unknown-feature"));
}
@Test
@@ -1186,20 +1187,20 @@ public class PolicyEngineManagerTest {
// invalid parameters
String nullStr = null;
- assertThrows(IllegalArgumentException.class, () -> mgr.deliver(nullStr, MY_EVENT));
- assertThrows(IllegalArgumentException.class, () -> mgr.deliver("", MY_EVENT));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.deliver(nullStr, MY_EVENT));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.deliver("", MY_EVENT));
Object nullObj = null;
- assertThrows(IllegalArgumentException.class, () -> mgr.deliver(MY_TOPIC, nullObj));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.deliver(MY_TOPIC, nullObj));
// locked
mgr.lock();
- assertThrows(IllegalStateException.class, () -> mgr.deliver(MY_TOPIC, MY_EVENT));
+ assertThatIllegalStateException().isThrownBy(() -> mgr.deliver(MY_TOPIC, MY_EVENT));
mgr.unlock();
// not running
mgr.stop();
- assertThrows(IllegalStateException.class, () -> mgr.deliver(MY_TOPIC, MY_EVENT));
+ assertThatIllegalStateException().isThrownBy(() -> mgr.deliver(MY_TOPIC, MY_EVENT));
// issues with topic
setUp();
@@ -1208,15 +1209,15 @@ public class PolicyEngineManagerTest {
// null sinks
when(endpoint.getTopicSinks(MY_TOPIC)).thenReturn(null);
- assertThrows(IllegalStateException.class, () -> mgr.deliver(MY_TOPIC, MY_EVENT));
+ assertThatIllegalStateException().isThrownBy(() -> mgr.deliver(MY_TOPIC, MY_EVENT));
// empty sinks
when(endpoint.getTopicSinks(MY_TOPIC)).thenReturn(Collections.emptyList());
- assertThrows(IllegalStateException.class, () -> mgr.deliver(MY_TOPIC, MY_EVENT));
+ assertThatIllegalStateException().isThrownBy(() -> mgr.deliver(MY_TOPIC, MY_EVENT));
// too many sinks
when(endpoint.getTopicSinks(MY_TOPIC)).thenReturn(sinks);
- assertThrows(IllegalStateException.class, () -> mgr.deliver(MY_TOPIC, MY_EVENT));
+ assertThatIllegalStateException().isThrownBy(() -> mgr.deliver(MY_TOPIC, MY_EVENT));
}
@Test
@@ -1230,24 +1231,24 @@ public class PolicyEngineManagerTest {
// invalid parameters
String nullStr = null;
- assertThrows(IllegalArgumentException.class, () -> mgr.deliver(nullStr, MY_TOPIC, MY_EVENT));
- assertThrows(IllegalArgumentException.class, () -> mgr.deliver("", MY_TOPIC, MY_EVENT));
- assertThrows(IllegalArgumentException.class, () -> mgr.deliver("unknown-bus-type", MY_TOPIC, MY_EVENT));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.deliver(nullStr, MY_TOPIC, MY_EVENT));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.deliver("", MY_TOPIC, MY_EVENT));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.deliver("unknown-bus-type", MY_TOPIC, MY_EVENT));
- assertThrows(IllegalArgumentException.class, () -> mgr.deliver(NOOP_STR, nullStr, MY_EVENT));
- assertThrows(IllegalArgumentException.class, () -> mgr.deliver(NOOP_STR, "", MY_EVENT));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.deliver(NOOP_STR, nullStr, MY_EVENT));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.deliver(NOOP_STR, "", MY_EVENT));
Object nullObj = null;
- assertThrows(IllegalArgumentException.class, () -> mgr.deliver(NOOP_STR, MY_TOPIC, nullObj));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.deliver(NOOP_STR, MY_TOPIC, nullObj));
// locked
mgr.lock();
- assertThrows(IllegalStateException.class, () -> mgr.deliver(NOOP_STR, MY_TOPIC, MY_EVENT));
+ assertThatIllegalStateException().isThrownBy(() -> mgr.deliver(NOOP_STR, MY_TOPIC, MY_EVENT));
mgr.unlock();
// not running
mgr.stop();
- assertThrows(IllegalStateException.class, () -> mgr.deliver(NOOP_STR, MY_TOPIC, MY_EVENT));
+ assertThatIllegalStateException().isThrownBy(() -> mgr.deliver(NOOP_STR, MY_TOPIC, MY_EVENT));
}
@Test
@@ -1263,27 +1264,28 @@ public class PolicyEngineManagerTest {
verify(sink1).send(MESSAGE);
// invalid parameters
- assertThrows(IllegalArgumentException.class, () -> mgr.deliver(CommInfrastructure.NOOP, null, MY_EVENT));
- assertThrows(IllegalArgumentException.class, () -> mgr.deliver(CommInfrastructure.NOOP, "", MY_EVENT));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.deliver(CommInfrastructure.NOOP, null, MY_EVENT));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.deliver(CommInfrastructure.NOOP, "", MY_EVENT));
Object nullObj = null;
- assertThrows(IllegalArgumentException.class, () -> mgr.deliver(CommInfrastructure.NOOP, MY_TOPIC, nullObj));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.deliver(CommInfrastructure.NOOP, MY_TOPIC, nullObj));
// locked
mgr.lock();
- assertThrows(IllegalStateException.class, () -> mgr.deliver(CommInfrastructure.NOOP, MY_TOPIC, MY_EVENT));
+ assertThatIllegalStateException().isThrownBy(() -> mgr.deliver(CommInfrastructure.NOOP, MY_TOPIC, MY_EVENT));
mgr.unlock();
// not started
mgr.stop();
- assertThrows(IllegalStateException.class, () -> mgr.deliver(CommInfrastructure.NOOP, MY_TOPIC, MY_EVENT));
+ assertThatIllegalStateException().isThrownBy(() -> mgr.deliver(CommInfrastructure.NOOP, MY_TOPIC, MY_EVENT));
// send() throws an exception
setUp();
mgr.configure(properties);
mgr.start();
when(sink1.send(any())).thenThrow(new ArithmeticException(EXPECTED));
- assertThrows(ArithmeticException.class, () -> mgr.deliver(CommInfrastructure.NOOP, MY_TOPIC, MY_EVENT));
+ assertThatThrownBy(() -> mgr.deliver(CommInfrastructure.NOOP, MY_TOPIC, MY_EVENT))
+ .isInstanceOf(ArithmeticException.class);
/*
* For remaining tests, have the controller handle delivery.
@@ -1321,7 +1323,7 @@ public class PolicyEngineManagerTest {
mgr.configure(properties);
// not started yet
- assertThrows(IllegalStateException.class, () -> mgr.deliver(CommInfrastructure.NOOP, MY_TOPIC, MESSAGE));
+ assertThatIllegalStateException().isThrownBy(() -> mgr.deliver(CommInfrastructure.NOOP, MY_TOPIC, MESSAGE));
// start it
mgr.start();
@@ -1331,19 +1333,20 @@ public class PolicyEngineManagerTest {
verify(sink2, never()).send(any());
// invalid parameters
- assertThrows(IllegalArgumentException.class, () -> mgr.deliver(CommInfrastructure.NOOP, null, MESSAGE));
- assertThrows(IllegalArgumentException.class, () -> mgr.deliver(CommInfrastructure.NOOP, "", MESSAGE));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.deliver(CommInfrastructure.NOOP, null, MESSAGE));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.deliver(CommInfrastructure.NOOP, "", MESSAGE));
String nullStr = null;
- assertThrows(IllegalArgumentException.class, () -> mgr.deliver(CommInfrastructure.NOOP, MY_TOPIC, nullStr));
- assertThrows(IllegalArgumentException.class, () -> mgr.deliver(CommInfrastructure.NOOP, MY_TOPIC, ""));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.deliver(CommInfrastructure.NOOP, MY_TOPIC, nullStr));
+ assertThatIllegalArgumentException().isThrownBy(() -> mgr.deliver(CommInfrastructure.NOOP, MY_TOPIC, ""));
// unknown topic
- assertThrows(IllegalStateException.class, () -> mgr.deliver(CommInfrastructure.NOOP, "unknown-topic", MESSAGE));
+ assertThatIllegalStateException()
+ .isThrownBy(() -> mgr.deliver(CommInfrastructure.NOOP, "unknown-topic", MESSAGE));
// locked
mgr.lock();
- assertThrows(IllegalStateException.class, () -> mgr.deliver(CommInfrastructure.NOOP, MY_TOPIC, MESSAGE));
+ assertThatIllegalStateException().isThrownBy(() -> mgr.deliver(CommInfrastructure.NOOP, MY_TOPIC, MESSAGE));
mgr.unlock();
}
@@ -1597,7 +1600,7 @@ public class PolicyEngineManagerTest {
verifyMiddle.run();
verifyAfter.accept(prov1);
- assertThrows(AssertionError.class, () -> verifyAfter.accept(prov2));
+ assertThatThrownBy(() -> verifyAfter.accept(prov2)).isInstanceOf(AssertionError.class);
}
/**
@@ -1635,12 +1638,12 @@ public class PolicyEngineManagerTest {
verifyBefore.accept(prov1);
// remaining methods should not have been invoked
- assertThrows(AssertionError.class, () -> verifyBefore.accept(prov2));
+ assertThatThrownBy(() -> verifyBefore.accept(prov2)).isInstanceOf(AssertionError.class);
- assertThrows(AssertionError.class, () -> verifyMiddle.run());
+ assertThatThrownBy(() -> verifyMiddle.run()).isInstanceOf(AssertionError.class);
- assertThrows(AssertionError.class, () -> verifyAfter.accept(prov1));
- assertThrows(AssertionError.class, () -> verifyAfter.accept(prov2));
+ assertThatThrownBy(() -> verifyAfter.accept(prov1)).isInstanceOf(AssertionError.class);
+ assertThatThrownBy(() -> verifyAfter.accept(prov2)).isInstanceOf(AssertionError.class);
}
/**
@@ -1739,4 +1742,9 @@ public class PolicyEngineManagerTest {
}
}
}
+
+ @FunctionalInterface
+ private static interface RunnableWithEx {
+ void run() throws Exception;
+ }
}
diff --git a/policy-management/src/test/java/org/onap/policy/drools/system/internal/AggregatedPolicyControllerTest.java b/policy-management/src/test/java/org/onap/policy/drools/system/internal/AggregatedPolicyControllerTest.java
index bb944fc9..83344486 100644
--- a/policy-management/src/test/java/org/onap/policy/drools/system/internal/AggregatedPolicyControllerTest.java
+++ b/policy-management/src/test/java/org/onap/policy/drools/system/internal/AggregatedPolicyControllerTest.java
@@ -2,7 +2,7 @@
* ============LICENSE_START=======================================================
* ONAP
* ================================================================================
- * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2018-2019 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -20,6 +20,8 @@
package org.onap.policy.drools.system.internal;
+import static org.assertj.core.api.Assertions.assertThatIllegalStateException;
+import static org.assertj.core.api.Assertions.assertThatThrownBy;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertNotNull;
@@ -30,7 +32,6 @@ import static org.mockito.Mockito.never;
import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;
-import static org.onap.policy.common.utils.test.PolicyAssert.assertThrows;
import java.util.Arrays;
import java.util.List;
@@ -159,7 +160,7 @@ public class AggregatedPolicyControllerTest {
@Override
protected DroolsControllerFactory getDroolsFactory() {
throw new RuntimeException(EXPECTED);
- }
+ }
};
}
@@ -169,7 +170,7 @@ public class AggregatedPolicyControllerTest {
@Override
protected DroolsControllerFactory getDroolsFactory() {
throw new LinkageError(EXPECTED);
- }
+ }
};
}
@@ -322,7 +323,7 @@ public class AggregatedPolicyControllerTest {
apc.lock();
// start it
- assertThrows(IllegalStateException.class, () -> apc.start());
+ assertThatIllegalStateException().isThrownBy(() -> apc.start());
assertFalse(apc.isAlive());
@@ -877,7 +878,7 @@ public class AggregatedPolicyControllerTest {
verifyMiddle.run();
verifyAfter.accept(prov1);
- assertThrows(AssertionError.class, () -> verifyAfter.accept(prov2));
+ assertThatThrownBy(() -> verifyAfter.accept(prov2)).isInstanceOf(AssertionError.class);
}
/**
@@ -914,14 +915,14 @@ public class AggregatedPolicyControllerTest {
verifyBefore.accept(prov1);
// remaining methods should not have been invoked
- assertThrows(AssertionError.class, () -> verifyBefore.accept(prov2));
+ assertThatThrownBy(() -> verifyBefore.accept(prov2)).isInstanceOf(AssertionError.class);
- assertThrows(AssertionError.class, () -> verifyMiddle.run());
+ assertThatThrownBy(() -> verifyMiddle.run()).isInstanceOf(AssertionError.class);
- assertThrows(AssertionError.class, () -> verifyAfter.accept(prov1));
- assertThrows(AssertionError.class, () -> verifyAfter.accept(prov2));
+ assertThatThrownBy(() -> verifyAfter.accept(prov1)).isInstanceOf(AssertionError.class);
+ assertThatThrownBy(() -> verifyAfter.accept(prov2)).isInstanceOf(AssertionError.class);
}
-
+
/**
* Controller with overrides.
*/
@@ -949,6 +950,6 @@ public class AggregatedPolicyControllerTest {
@Override
protected List<PolicyControllerFeatureAPI> getProviders() {
return providers;
- }
+ }
}
}