Add unit test for core events and context

This code is covered by feature testing but does not
show up in Sonar. These unit tests give coverage on engine
modules.

Issue-ID: POLICY-1034
Change-Id: Ib7a288bcb9729ec88346cc8047e38f3a58f9a97c
Signed-off-by: liamfallon <liam.fallon@ericsson.com>

7 files changed, 816 insertions, 0 deletions

diff --git a/core/core-engine/src/test/java/org/onap/policy/apex/core/engine/EngineParametersTest.java b/core/core-engine/src/test/java/org/onap/policy/apex/core/engine/EngineParametersTest.java
new file mode 100644
index 000000000..1b3489790
--- /dev/null
+++ b/core/core-engine/src/test/java/org/onap/policy/apex/core/engine/EngineParametersTest.java
@@ -0,0 +1,60 @@
+/*-
+ * ============LICENSE_START=======================================================
+ *  Copyright (C) 2018 Ericsson. 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.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * 
+ * SPDX-License-Identifier: Apache-2.0
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.apex.core.engine;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertTrue;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+import org.junit.Test;
+import org.onap.policy.apex.context.parameters.ContextParameters;
+import org.onap.policy.common.parameters.ParameterService;
+
+/**
+ * Test the executor parameters.
+ *
+ */
+public class EngineParametersTest {
+
+    @Test
+    public void test() {
+        EngineParameters pars = new EngineParameters();
+        pars.setName("Name");
+        assertEquals("Name", pars.getName());
+        
+        ContextParameters contextPars = new ContextParameters();
+
+        pars.setContextParameters(contextPars);
+        assertEquals(contextPars, pars.getContextParameters());
+        
+        Map<String, ExecutorParameters> executorParameterMap = new LinkedHashMap<>();
+        executorParameterMap.put("Executor", new ExecutorParameters());
+        pars.setExecutorParameterMap(executorParameterMap);
+        assertEquals(executorParameterMap, pars.getExecutorParameterMap());
+        
+        assertTrue(pars.validate().isValid());
+        
+        ParameterService.register(pars);
+        ParameterService.deregister(pars);
+    }
+}
diff --git a/core/core-engine/src/test/java/org/onap/policy/apex/core/engine/ExecutorParametersTest.java b/core/core-engine/src/test/java/org/onap/policy/apex/core/engine/ExecutorParametersTest.java
new file mode 100644
index 000000000..88c8c852d
--- /dev/null
+++ b/core/core-engine/src/test/java/org/onap/policy/apex/core/engine/ExecutorParametersTest.java
@@ -0,0 +1,57 @@
+/*-
+ * ============LICENSE_START=======================================================
+ *  Copyright (C) 2018 Ericsson. 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.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * 
+ * SPDX-License-Identifier: Apache-2.0
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.apex.core.engine;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertTrue;
+
+import org.junit.Test;
+import org.onap.policy.common.parameters.ParameterService;
+
+/**
+ * Test the executor parameters.
+ *
+ */
+public class ExecutorParametersTest {
+
+    @Test
+    public void test() {
+        ExecutorParameters pars = new ExecutorParameters();
+        pars.setName("Name");
+        assertEquals("Name", pars.getName());
+        pars.setStateFinalizerExecutorPluginClass("some.state.finalizer.plugin.class");
+        assertEquals("some.state.finalizer.plugin.class", pars.getStateFinalizerExecutorPluginClass());
+        pars.setTaskExecutorPluginClass("some.task.executor.plugin.class");
+        assertEquals("some.task.executor.plugin.class", pars.getTaskExecutorPluginClass());
+        pars.setTaskSelectionExecutorPluginClass("some.task.selection.executor.plugin.class");
+        assertEquals("some.task.selection.executor.plugin.class", pars.getTaskSelectionExecutorPluginClass());
+
+        assertEquals("ExecutorParameters [name=Name, taskExecutorPluginClass=some.task.executor.plugin.class, "
+                        + "taskSelectionExecutorPluginClass=some.task.selection.executor.plugin.class, "
+                        + "stateFinalizerExecutorPluginClass=some.state.finalizer.plugin.class]", pars.toString());
+        
+        assertTrue(pars.validate().isValid());
+        
+        
+        ParameterService.register(pars);
+        ParameterService.deregister(pars);
+    }
+}
diff --git a/core/core-engine/src/test/java/org/onap/policy/apex/core/engine/context/ApexInternalContextTest.java b/core/core-engine/src/test/java/org/onap/policy/apex/core/engine/context/ApexInternalContextTest.java
new file mode 100644
index 000000000..a75ad37f6
--- /dev/null
+++ b/core/core-engine/src/test/java/org/onap/policy/apex/core/engine/context/ApexInternalContextTest.java
@@ -0,0 +1,188 @@
+/*-
+ * ============LICENSE_START=======================================================
+ *  Copyright (C) 2018 Ericsson. 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.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * 
+ * SPDX-License-Identifier: Apache-2.0
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.apex.core.engine.context;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.fail;
+
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+import org.onap.policy.apex.context.ContextException;
+import org.onap.policy.apex.context.parameters.ContextParameterConstants;
+import org.onap.policy.apex.context.parameters.DistributorParameters;
+import org.onap.policy.apex.context.parameters.LockManagerParameters;
+import org.onap.policy.apex.context.parameters.PersistorParameters;
+import org.onap.policy.apex.context.parameters.SchemaParameters;
+import org.onap.policy.apex.model.basicmodel.concepts.AxArtifactKey;
+import org.onap.policy.apex.model.contextmodel.concepts.AxContextAlbum;
+import org.onap.policy.apex.model.contextmodel.concepts.AxContextSchema;
+import org.onap.policy.apex.model.policymodel.concepts.AxPolicyModel;
+import org.onap.policy.common.parameters.ParameterService;
+
+/**
+ * Test the Apex engine internal context class.
+ */
+public class ApexInternalContextTest {
+
+    private AxPolicyModel policyModel;
+    private AxPolicyModel newVersionPolicyModel;
+    private AxPolicyModel newPolicyModel;
+    private AxContextAlbum album;
+    private AxContextAlbum newAlbum;
+    private AxPolicyModel incompatiblePolicyModel;
+
+    /**
+     * Initialize parameters.
+     */
+    @Before
+    public void registerParameters() {
+        ParameterService.register(new SchemaParameters());
+        ParameterService.register(new DistributorParameters());
+        ParameterService.register(new LockManagerParameters());
+        ParameterService.register(new PersistorParameters());
+    }
+
+    /**
+     * Create policy model.
+     */
+    @Before
+    public void createPolicyModels() {
+        AxArtifactKey modelKey = new AxArtifactKey("PolicyModel:0.0.1");
+        policyModel = new AxPolicyModel(modelKey);
+
+        AxArtifactKey schemaKey = new AxArtifactKey("Schema:0.0.1");
+        AxContextSchema schema = new AxContextSchema(schemaKey, "Java", "java.lang.String");
+        policyModel.getSchemas().getSchemasMap().put(schemaKey, schema);
+
+        AxArtifactKey albumKey = new AxArtifactKey("Album:0.0.1");
+        album = new AxContextAlbum(albumKey, "Policy", true, schemaKey);
+
+        policyModel.getAlbums().getAlbumsMap().put(albumKey, album);
+
+        AxArtifactKey newVersionModelKey = new AxArtifactKey("PolicyModel:0.0.2");
+        newVersionPolicyModel = new AxPolicyModel(newVersionModelKey);
+
+        newVersionPolicyModel.getSchemas().getSchemasMap().put(schemaKey, schema);
+        AxContextAlbum compatibleAlbum = new AxContextAlbum(albumKey, "Global", true, schemaKey);
+        newVersionPolicyModel.getAlbums().getAlbumsMap().put(albumKey, compatibleAlbum);
+
+        AxArtifactKey anotherAlbumKey = new AxArtifactKey("AnotherAlbum:0.0.1");
+        AxContextAlbum anotherAlbum = new AxContextAlbum(anotherAlbumKey, "Policy", true, schemaKey);
+
+        newVersionPolicyModel.getAlbums().getAlbumsMap().put(anotherAlbumKey, anotherAlbum);
+
+        AxArtifactKey incompatibleModelKey = new AxArtifactKey("IncompatiblePolicyModel:0.0.2");
+        incompatiblePolicyModel = new AxPolicyModel(incompatibleModelKey);
+
+        AxArtifactKey incompatibleSchemaKey = new AxArtifactKey("IncompatibleSchema:0.0.1");
+        AxContextSchema incompatibleSchema = new AxContextSchema(incompatibleSchemaKey, "Java", "java.lang.Integer");
+        incompatiblePolicyModel.getSchemas().getSchemasMap().put(incompatibleSchemaKey, incompatibleSchema);
+
+        AxContextAlbum incompatibleAlbum = new AxContextAlbum(albumKey, "Policy", true, incompatibleSchemaKey);
+        incompatiblePolicyModel.getAlbums().getAlbumsMap().put(albumKey, incompatibleAlbum);
+
+        AxArtifactKey newModelKey = new AxArtifactKey("NewPolicyModel:0.0.1");
+        newPolicyModel = new AxPolicyModel(newModelKey);
+
+        AxArtifactKey newSchemaKey = new AxArtifactKey("NewSchema:0.0.1");
+        AxContextSchema newSchema = new AxContextSchema(newSchemaKey, "Java", "java.lang.Integer");
+        newPolicyModel.getSchemas().getSchemasMap().put(newSchemaKey, newSchema);
+
+        AxArtifactKey newAlbumKey = new AxArtifactKey("NewAlbum:0.0.1");
+        newAlbum = new AxContextAlbum(newAlbumKey, "Policy", true, newSchemaKey);
+
+        newPolicyModel.getAlbums().getAlbumsMap().put(newAlbumKey, newAlbum);
+    }
+
+    /**
+     * Deregister parameters.
+     */
+    @After
+    public void deregisterParameters() {
+        ParameterService.deregister(ContextParameterConstants.DISTRIBUTOR_GROUP_NAME);
+        ParameterService.deregister(ContextParameterConstants.LOCKING_GROUP_NAME);
+        ParameterService.deregister(ContextParameterConstants.PERSISTENCE_GROUP_NAME);
+        ParameterService.deregister(ContextParameterConstants.SCHEMA_GROUP_NAME);
+    }
+
+    @Test
+    public void testAlbumInit() throws ContextException {
+        try {
+            new ApexInternalContext(null);
+            fail("test should throw an exception");
+        } catch (ContextException ce) {
+            assertEquals("internal context update failed, supplied model is null", ce.getMessage());
+        }
+
+        ApexInternalContext context = new ApexInternalContext(policyModel);
+
+        assertEquals(policyModel.getKey(), context.getKey());
+        assertEquals(1, context.getContextAlbums().size());
+
+        AxArtifactKey albumKey = new AxArtifactKey("Album:0.0.1");
+        assertEquals(album.getId(), context.get(albumKey).getKey().getId());
+        assertEquals(album.getId(), context.get(albumKey.getName()).getKey().getId());
+        assertEquals(album.getId(), context.get(albumKey.getName(), albumKey.getVersion()).getKey().getId());
+        assertEquals(album.getId(), context.getAll(albumKey.getName()).iterator().next().getKey().getId());
+        assertEquals(album.getId(),
+                        context.getAll(albumKey.getName(), albumKey.getVersion()).iterator().next().getKey().getId());
+
+        context.clear();
+        assertEquals(1, context.getContextAlbums().size());
+
+        assertEquals("ApexInternalContext [contextAlbums={AxArtifactKey:(name=Album,version=0.0.1)",
+                        context.toString().substring(0, 76));
+    }
+
+    @Test
+    public void testAlbumUpdate() throws ContextException {
+        ApexInternalContext context = new ApexInternalContext(policyModel);
+
+        try {
+            context.update(null);
+            fail("test should throw an exception");
+        } catch (ContextException ce) {
+            assertEquals("internal context update failed, supplied model is null", ce.getMessage());
+        }
+
+        assertEquals(policyModel.getKey().getId(), context.getKey().getId());
+        assertEquals(1, context.getContextAlbums().size());
+
+        try {
+            context.update(incompatiblePolicyModel);
+            fail("test should throw an exception here");
+        } catch (ContextException ce) {
+            assertEquals("internal context update failed on context album \"Album:0.0.1\" "
+                            + "in model \"PolicyModel:0.0.1\", "
+                            + "schema \"Schema:0.0.1\" on existing context model does not equal "
+                            + "schema \"IncompatibleSchema:0.0.1\" on incoming model", ce.getMessage());
+        }
+
+        assertEquals(policyModel.getKey().getId(), context.getKey().getId());
+
+        context.update(newVersionPolicyModel);
+        assertEquals(newVersionPolicyModel.getKey().getId(), context.getKey().getId());
+
+        context.update(newPolicyModel);
+        assertEquals(newPolicyModel.getKey().getId(), context.getKey().getId());
+    }
+}
diff --git a/core/core-engine/src/test/java/org/onap/policy/apex/core/engine/event/DummyAxKey.java b/core/core-engine/src/test/java/org/onap/policy/apex/core/engine/event/DummyAxKey.java
new file mode 100644
index 000000000..0a86c070a
--- /dev/null
+++ b/core/core-engine/src/test/java/org/onap/policy/apex/core/engine/event/DummyAxKey.java
@@ -0,0 +1,163 @@
+/*-
+ * ============LICENSE_START=======================================================
+ *  Copyright (C) 2018 Ericsson. 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.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * 
+ * SPDX-License-Identifier: Apache-2.0
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.apex.core.engine.event;
+
+import java.util.List;
+
+import org.apache.commons.lang3.NotImplementedException;
+import org.onap.policy.apex.model.basicmodel.concepts.AxConcept;
+import org.onap.policy.apex.model.basicmodel.concepts.AxKey;
+import org.onap.policy.apex.model.basicmodel.concepts.AxValidationResult;
+
+/**
+ * Dummy Key Class.
+ */
+public class DummyAxKey extends AxKey {
+    private static final long serialVersionUID = 964899169013353800L;
+
+    /*
+     * (non-Javadoc)
+     * 
+     * @see java.lang.Comparable#compareTo(java.lang.Object)
+     */
+    @Override
+    public int compareTo(AxConcept concept) {
+        throw new NotImplementedException("Not implemented on dummy class");
+    }
+
+    /*
+     * (non-Javadoc)
+     * 
+     * @see org.onap.policy.apex.model.basicmodel.concepts.AxKey#getId()
+     */
+    @Override
+    public String getId() {
+        throw new NotImplementedException("Not implemented on dummy class");
+    }
+
+    /*
+     * (non-Javadoc)
+     * 
+     * @see org.onap.policy.apex.model.basicmodel.concepts.AxKey#getCompatibility(org.onap.policy.apex.model.basicmodel.
+     * concepts.AxKey)
+     */
+    @Override
+    public Compatibility getCompatibility(AxKey otherKey) {
+        throw new NotImplementedException("Not implemented on dummy class");
+    }
+
+    /*
+     * (non-Javadoc)
+     * 
+     * @see
+     * org.onap.policy.apex.model.basicmodel.concepts.AxKey#isCompatible(org.onap.policy.apex.model.basicmodel.concepts.
+     * AxKey)
+     */
+    @Override
+    public boolean isCompatible(AxKey otherKey) {
+        throw new NotImplementedException("Not implemented on dummy class");
+    }
+
+    /*
+     * (non-Javadoc)
+     * 
+     * @see org.onap.policy.apex.model.basicmodel.concepts.AxConcept#getKey()
+     */
+    @Override
+    public AxKey getKey() {
+        throw new NotImplementedException("Not implemented on dummy class");
+    }
+
+    /*
+     * (non-Javadoc)
+     * 
+     * @see org.onap.policy.apex.model.basicmodel.concepts.AxConcept#getKeys()
+     */
+    @Override
+    public List<AxKey> getKeys() {
+        throw new NotImplementedException("Not implemented on dummy class");
+    }
+
+    /*
+     * (non-Javadoc)
+     * 
+     * @see
+     * org.onap.policy.apex.model.basicmodel.concepts.AxConcept#validate(org.onap.policy.apex.model.basicmodel.concepts.
+     * AxValidationResult)
+     */
+    @Override
+    public AxValidationResult validate(AxValidationResult result) {
+        throw new NotImplementedException("Not implemented on dummy class");
+    }
+
+    /*
+     * (non-Javadoc)
+     * 
+     * @see org.onap.policy.apex.model.basicmodel.concepts.AxConcept#clean()
+     */
+    @Override
+    public void clean() {
+        throw new NotImplementedException("Not implemented on dummy class");
+
+    }
+
+    /*
+     * (non-Javadoc)
+     * 
+     * @see org.onap.policy.apex.model.basicmodel.concepts.AxConcept#equals(java.lang.Object)
+     */
+    @Override
+    public boolean equals(Object otherObject) {
+        throw new NotImplementedException("Not implemented on dummy class");
+    }
+
+    /*
+     * (non-Javadoc)
+     * 
+     * @see org.onap.policy.apex.model.basicmodel.concepts.AxConcept#toString()
+     */
+    @Override
+    public String toString() {
+        return "Dummy Key";
+    }
+
+    /*
+     * (non-Javadoc)
+     * 
+     * @see org.onap.policy.apex.model.basicmodel.concepts.AxConcept#hashCode()
+     */
+    @Override
+    public int hashCode() {
+        throw new NotImplementedException("Not implemented on dummy class");
+    }
+
+    /*
+     * (non-Javadoc)
+     * 
+     * @see
+     * org.onap.policy.apex.model.basicmodel.concepts.AxConcept#copyTo(org.onap.policy.apex.model.basicmodel.concepts.
+     * AxConcept)
+     */
+    @Override
+    public AxConcept copyTo(AxConcept target) {
+        throw new NotImplementedException("Not implemented on dummy class");
+    }
+}
diff --git a/core/core-engine/src/test/java/org/onap/policy/apex/core/engine/event/EnEventTest.java b/core/core-engine/src/test/java/org/onap/policy/apex/core/engine/event/EnEventTest.java
new file mode 100644
index 000000000..4fd9367ca
--- /dev/null
+++ b/core/core-engine/src/test/java/org/onap/policy/apex/core/engine/event/EnEventTest.java
@@ -0,0 +1,209 @@
+/*-
+ * ============LICENSE_START=======================================================
+ *  Copyright (C) 2018 Ericsson. 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.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * 
+ * SPDX-License-Identifier: Apache-2.0
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.apex.core.engine.event;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertNull;
+import static org.junit.Assert.assertTrue;
+import static org.junit.Assert.fail;
+
+import java.util.HashMap;
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+import org.onap.policy.apex.context.ContextRuntimeException;
+import org.onap.policy.apex.context.parameters.ContextParameterConstants;
+import org.onap.policy.apex.context.parameters.SchemaParameters;
+import org.onap.policy.apex.model.basicmodel.concepts.AxArtifactKey;
+import org.onap.policy.apex.model.basicmodel.concepts.AxConcept;
+import org.onap.policy.apex.model.basicmodel.concepts.AxReferenceKey;
+import org.onap.policy.apex.model.basicmodel.service.ModelService;
+import org.onap.policy.apex.model.contextmodel.concepts.AxContextSchema;
+import org.onap.policy.apex.model.contextmodel.concepts.AxContextSchemas;
+import org.onap.policy.apex.model.eventmodel.concepts.AxEvent;
+import org.onap.policy.apex.model.eventmodel.concepts.AxEvents;
+import org.onap.policy.apex.model.eventmodel.concepts.AxField;
+import org.onap.policy.common.parameters.ParameterService;
+
+/**
+ * Test the engine event class.
+ */
+public class EnEventTest {
+    /**
+     * Set up the services.
+     */
+    @Before
+    public void setupServices() {
+        ModelService.registerModel(AxContextSchemas.class, new AxContextSchemas());
+        ModelService.registerModel(AxEvents.class, new AxEvents());
+        ParameterService.register(new SchemaParameters());
+    }
+
+    /**
+     * Tear down the services.
+     */
+    @After
+    public void teardownServices() {
+        ModelService.deregisterModel(AxContextSchema.class);
+        ModelService.deregisterModel(AxEvents.class);
+        ParameterService.deregister(ContextParameterConstants.SCHEMA_GROUP_NAME);
+    }
+
+    @Test
+    public void testEnEvent() {
+        AxArtifactKey eventKey = new AxArtifactKey("Event:0.0.1");
+        try {
+            new EnEvent(eventKey);
+            fail("test should throw an exception here");
+        } catch (EnException ee) {
+            assertEquals("event definition is null or was not found in model service", ee.getMessage());
+        }
+
+        try {
+            new EnEvent((AxEvent) null);
+            fail("test should throw an exception here");
+        } catch (EnException ee) {
+            assertEquals("event definition is null or was not found in model service", ee.getMessage());
+        }
+
+        AxEvent axEvent = new AxEvent(eventKey, "a.name.space", "some source", "some target");
+        ModelService.getModel(AxEvents.class).getEventMap().put(eventKey, axEvent);
+
+        EnEvent event = new EnEvent(eventKey);
+        assertEquals(eventKey, event.getKey());
+        assertEquals("Event:0.0.1", event.getId());
+        assertEquals("Event", event.getName());
+        assertEquals(axEvent, event.getAxEvent());
+        event.setExecutionId(123454321L);
+        assertEquals(123454321L, event.getExecutionId());
+        event.setExceptionMessage("Something happened");
+        assertEquals("Something happened", event.getExceptionMessage());
+        AxConcept[] usedArtifactStackArray =
+            { eventKey };
+        event.setUserArtifactStack(usedArtifactStackArray);
+        assertEquals(usedArtifactStackArray.length, event.getUserArtifactStack().length);
+        assertEquals("EnEvent [axEvent=AxEvent:(key=AxArtifactKey:(name=Event,version=0.0.1),nameSpace=a.name.space,"
+                        + "source=some source,target=some target,parameter={}), "
+                        + "userArtifactStack=[AxArtifactKey:(name=Event,version=0.0.1)], map={}]", event.toString());
+        try {
+            event.put(null, null);
+            fail("test should throw an exception here");
+        } catch (EnException ee) {
+            assertEquals("null keys are illegal on method parameter \"key\"", ee.getMessage());
+        }
+
+        try {
+            event.put("NonField", null);
+            fail("test should throw an exception here");
+        } catch (EnException ee) {
+            assertEquals("parameter with key \"NonField\" not defined on event \"Event\"", ee.getMessage());
+        }
+
+        AxReferenceKey fieldKey = new AxReferenceKey("Parent", "0.0.1", "MyParent", "MyField");
+        AxArtifactKey fieldSchemaKey = new AxArtifactKey("FieldSchema:0.0.1");
+        AxField axField = new AxField(fieldKey, fieldSchemaKey);
+
+        AxConcept[] usedArtifactStackArrayMultiple =
+            { eventKey, fieldKey, new DummyAxKey() };
+        event.setUserArtifactStack(usedArtifactStackArrayMultiple);
+
+        AxContextSchema schema = new AxContextSchema(fieldSchemaKey, "Java", "java.lang.Integer");
+        ModelService.getModel(AxContextSchemas.class).getSchemasMap().put(fieldSchemaKey, schema);
+
+        Map<String, AxField> parameterMap = new LinkedHashMap<>();
+        parameterMap.put("MyField", axField);
+        ModelService.getModel(AxEvents.class).get(eventKey).setParameterMap(parameterMap);
+
+        try {
+            event.put("MyField", null);
+        } catch (ContextRuntimeException cre) {
+            fail("test should throw an exception here");
+        }
+        assertNull(event.get("MyField"));
+
+        try {
+            event.put("MyField", "Hello");
+            fail("test should throw an exception here");
+        } catch (ContextRuntimeException cre) {
+            assertEquals("Parent:0.0.1:MyParent:MyField: object \"Hello\" of class \"java.lang.String\" "
+                            + "not compatible with class \"java.lang.Integer\"", cre.getMessage());
+        }
+
+        event.put("MyField", 123);
+        assertEquals(123, event.get("MyField"));
+
+        assertTrue(event.keySet().contains("MyField"));
+        assertTrue(event.values().contains(123));
+        assertEquals("MyField", event.entrySet().iterator().next().getKey());
+
+        event.putAll(event);
+
+        try {
+            event.get(null);
+            fail("test should throw an exception here");
+        } catch (EnException ee) {
+            assertEquals("null values are illegal on method parameter \"key\"", ee.getMessage());
+        }
+
+        try {
+            event.get("NonField");
+            fail("test should throw an exception here");
+        } catch (EnException ee) {
+            assertEquals("parameter with key NonField not defined on this event", ee.getMessage());
+        }
+
+        try {
+            event.remove(null);
+            fail("test should throw an exception here");
+        } catch (EnException ee) {
+            assertEquals("null keys are illegal on method parameter \"key\"", ee.getMessage());
+        }
+
+        try {
+            event.remove("NonField");
+            fail("test should throw an exception here");
+        } catch (EnException ee) {
+            assertEquals("parameter with key NonField not defined on this event", ee.getMessage());
+        }
+
+        event.remove("MyField");
+        assertNull(event.get("MyField"));
+
+        event.put("MyField", 123);
+        assertEquals(123, event.get("MyField"));
+        event.clear();
+        assertNull(event.get("MyField"));
+
+        assertTrue(event.hashCode() != 0);
+
+        assertTrue(event.equals(event));
+        assertFalse(event.equals(null));
+        Map<String, Object> hashMap = new HashMap<>();
+        assertFalse(event.equals(hashMap));
+
+        EnEvent otherEvent = new EnEvent(eventKey);
+        assertTrue(event.equals(otherEvent));
+    }
+}
diff --git a/core/core-engine/src/test/java/org/onap/policy/apex/core/engine/event/EnExceptionTest.java b/core/core-engine/src/test/java/org/onap/policy/apex/core/engine/event/EnExceptionTest.java
new file mode 100644
index 000000000..ee54fd959
--- /dev/null
+++ b/core/core-engine/src/test/java/org/onap/policy/apex/core/engine/event/EnExceptionTest.java
@@ -0,0 +1,42 @@
+/*-
+ * ============LICENSE_START=======================================================
+ *  Copyright (C) 2018 Ericsson. 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.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * 
+ * SPDX-License-Identifier: Apache-2.0
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.apex.core.engine.event;
+
+import static org.junit.Assert.assertEquals;
+
+import java.io.IOException;
+
+import org.junit.Test;
+
+/**
+ * Test the event exception class.
+ */
+public class EnExceptionTest {
+
+    @Test
+    public void testEnException() {
+        EnException ene = new EnException("Message");
+        assertEquals("Message", ene.getMessage());
+
+        ene = new EnException("Message", new IOException());
+        assertEquals("Message", ene.getMessage());
+    }
+}
diff --git a/core/core-engine/src/test/java/org/onap/policy/apex/core/engine/event/EnFieldTest.java b/core/core-engine/src/test/java/org/onap/policy/apex/core/engine/event/EnFieldTest.java
new file mode 100644
index 000000000..6228c6834
--- /dev/null
+++ b/core/core-engine/src/test/java/org/onap/policy/apex/core/engine/event/EnFieldTest.java
@@ -0,0 +1,97 @@
+/*-
+ * ============LICENSE_START=======================================================
+ *  Copyright (C) 2018 Ericsson. 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.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * 
+ * SPDX-License-Identifier: Apache-2.0
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.apex.core.engine.event;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertTrue;
+import static org.junit.Assert.fail;
+
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+import org.onap.policy.apex.context.parameters.ContextParameterConstants;
+import org.onap.policy.apex.context.parameters.SchemaParameters;
+import org.onap.policy.apex.model.basicmodel.concepts.AxArtifactKey;
+import org.onap.policy.apex.model.basicmodel.concepts.AxReferenceKey;
+import org.onap.policy.apex.model.basicmodel.service.ModelService;
+import org.onap.policy.apex.model.contextmodel.concepts.AxContextSchema;
+import org.onap.policy.apex.model.contextmodel.concepts.AxContextSchemas;
+import org.onap.policy.apex.model.eventmodel.concepts.AxField;
+import org.onap.policy.common.parameters.ParameterService;
+
+/**
+ * Test the EnField class.
+ */
+public class EnFieldTest {
+    /**
+     * Set up the services.
+     */
+    @Before
+    public void setupServices() {
+        AxContextSchemas schemas = new AxContextSchemas();
+        ModelService.registerModel(AxContextSchemas.class, schemas);
+        ParameterService.register(new SchemaParameters());
+    }
+
+    /**
+     * Tear down the services.
+     */
+    @After
+    public void teardownServices() {
+        ModelService.deregisterModel(AxContextSchemas.class);
+        ParameterService.deregister(ContextParameterConstants.SCHEMA_GROUP_NAME);
+    }
+
+    @Test
+    public void testEnField() {
+        AxReferenceKey fieldKey = new AxReferenceKey("Parent", "0.0.1", "MyParent", "MyField");
+        AxArtifactKey fieldSchemaKey = new AxArtifactKey("FieldSchema:0.0.1");
+        AxField axField = new AxField(fieldKey, fieldSchemaKey);
+
+        try {
+            new EnField(axField, null);
+            fail("test should throw an exception");
+        } catch (EnException ee) {
+            assertEquals("schema helper cannot be created for parameter with key \"Parent:0.0.1:MyParent:MyField\" "
+                            + "with schema \"AxArtifactKey:(name=FieldSchema,version=0.0.1)\"", ee.getMessage());
+        }
+
+        AxContextSchema schema = new AxContextSchema(fieldSchemaKey, "Java", "java.lang.Integer");
+        ModelService.getModel(AxContextSchemas.class).getSchemasMap().put(fieldSchemaKey, schema);
+        EnField field = new EnField(axField, 123);
+
+        assertEquals(axField, field.getAxField());
+        assertEquals(123, field.getValue());
+        assertEquals(fieldKey, field.getKey());
+        assertEquals("MyField", field.getName());
+        assertEquals("org.onap.policy.apex.context.impl.schema.java.JavaSchemaHelper",
+                        field.getSchemaHelper().getClass().getCanonicalName());
+        assertEquals(123, field.getAssignableValue());
+        assertEquals("EnField [axField=AxField:(key=AxReferenceKey:(parentKeyName=Parent,parentKeyVersion=0.0.1,"
+                        + "parentLocalName=MyParent,localName=MyField),fieldSchemaKey=AxArtifactKey:"
+                        + "(name=FieldSchema,version=0.0.1),optional=false), value=123]", field.toString());
+        assertTrue(field.isAssignableValue());
+
+        field = new EnField(axField, "Hello");
+        assertFalse(field.isAssignableValue());
+    }
+}