Code coverage for File Carrier Plugin

- Increase code coverage for file carrier plugin in service engine

Issue-ID: POLICY-3092
Signed-off-by: arkadiusz.adamski <aadamski@est.tech>
Change-Id: I8c08ee55c9d31792e35a1acc79330c8eef42af56

5 files changed, 604 insertions, 2 deletions

diff --git a/model/basic-model/src/test/java/org/onap/policy/apex/model/basicmodel/handling/ApexSchemaGeneratorTest.java b/model/basic-model/src/test/java/org/onap/policy/apex/model/basicmodel/handling/ApexSchemaGeneratorTest.java
index 0b18abcb1..3385830e2 100644
--- a/model/basic-model/src/test/java/org/onap/policy/apex/model/basicmodel/handling/ApexSchemaGeneratorTest.java
+++ b/model/basic-model/src/test/java/org/onap/policy/apex/model/basicmodel/handling/ApexSchemaGeneratorTest.java
@@ -28,9 +28,16 @@ import java.io.FileDescriptor;
 import java.io.FileOutputStream;
 import java.io.IOException;
 import java.io.PrintStream;
+import org.junit.After;
 import org.junit.Test;
 
 public class ApexSchemaGeneratorTest {
+    private final PrintStream stdout = System.out;
+
+    @After
+    public void tearDown() throws Exception {
+        System.setOut(stdout);
+    }
 
     @Test
     public void test() throws IOException {
@@ -78,12 +85,11 @@ public class ApexSchemaGeneratorTest {
         System.setOut(new PrintStream(baos5));
 
         final File tempFile = File.createTempFile("ApexSchemaGeneratorTest", "xsd");
+        tempFile.deleteOnExit();
         final String[] args5 =
             { "org.onap.policy.apex.model.basicmodel.concepts.AxModel", tempFile.getCanonicalPath() };
 
         ApexSchemaGenerator.main(args5);
         assertTrue(tempFile.length() > 100);
-        System.setOut(new PrintStream(new FileOutputStream(FileDescriptor.out)));
-        tempFile.delete();
     }
 }
diff --git a/services/services-engine/src/test/java/org/onap/policy/apex/service/engine/event/impl/filecarrierplugin/FileCarrierTechnologyParametersTest.java b/services/services-engine/src/test/java/org/onap/policy/apex/service/engine/event/impl/filecarrierplugin/FileCarrierTechnologyParametersTest.java
new file mode 100644
index 000000000..609dc31c9
--- /dev/null
+++ b/services/services-engine/src/test/java/org/onap/policy/apex/service/engine/event/impl/filecarrierplugin/FileCarrierTechnologyParametersTest.java
@@ -0,0 +1,226 @@
+/*
+ *  ============LICENSE_START=======================================================
+ *  Copyright (C) 2021. Nordix Foundation.
+ *  ================================================================================
+ * 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.service.engine.event.impl.filecarrierplugin;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.assertj.core.api.Assertions.assertThatThrownBy;
+import static org.junit.Assume.assumeTrue;
+
+import java.io.File;
+import java.io.IOException;
+import java.net.URL;
+import java.util.Random;
+import org.apache.commons.lang3.RandomStringUtils;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+import org.onap.policy.common.parameters.ParameterRuntimeException;
+import org.onap.policy.common.parameters.ValidationResult;
+
+public class FileCarrierTechnologyParametersTest {
+    private final Random random = new Random();
+    private static final String APEX_RELATIVE_FILE_ROOT = "APEX_RELATIVE_FILE_ROOT";
+    private final String defaultApesRelativeFileRoot = System.getProperty(APEX_RELATIVE_FILE_ROOT);
+    private FileCarrierTechnologyParameters parameters;
+    private File tempFile;
+
+    @Before
+    public void setUp() throws Exception {
+        parameters = new FileCarrierTechnologyParameters();
+    }
+
+    /**
+     * Cleaning after testing.
+     */
+    @After
+    public void tearDown() {
+        if (tempFile != null) {
+            tempFile.delete();
+        }
+        if (defaultApesRelativeFileRoot != null) {
+            System.setProperty(APEX_RELATIVE_FILE_ROOT, defaultApesRelativeFileRoot);
+        } else {
+            System.clearProperty(APEX_RELATIVE_FILE_ROOT);
+        }
+    }
+
+    @Test
+    public void getSetFileName() {
+        final String fileName = RandomStringUtils.random(10);
+        parameters.setFileName(fileName);
+        assertThat(parameters.getFileName())
+            .isEqualTo(fileName);
+    }
+
+    @Test
+    public void isStandardIo() {
+        assertThat(parameters.isStandardIo()).isFalse();
+    }
+
+    @Test
+    public void isStandardError() {
+        assertThat(parameters.isStandardError()).isFalse();
+    }
+
+    @Test
+    public void isStreamingMode() {
+        assertThat(parameters.isStreamingMode()).isFalse();
+    }
+
+    @Test
+    public void setStandardIo() {
+        final boolean standardIo = random.nextBoolean();
+        parameters.setStandardIo(standardIo);
+        assertThat(parameters.isStandardIo()).isEqualTo(standardIo);
+    }
+
+    @Test
+    public void setStandardError() {
+        final boolean standardError = random.nextBoolean();
+        parameters.setStandardError(standardError);
+        assertThat(parameters.isStandardError()).isEqualTo(standardError);
+    }
+
+    @Test
+    public void getStartDelay() {
+        assertThat(parameters.getStartDelay()).isEqualTo(0L);
+    }
+
+    @Test
+    public void setStartDelay() {
+        final long delay = random.nextInt();
+        parameters.setStartDelay(delay);
+        assertThat(parameters.getStartDelay()).isEqualTo(delay);
+    }
+
+    @Test
+    public void getLabel() {
+        final String label = RandomStringUtils.random(10);
+        parameters.setLabel(label);
+        assertThat(parameters.getLabel()).isEqualTo(label);
+    }
+
+    @Test
+    public void setName() {
+        final String name = RandomStringUtils.random(10);
+        assertThatThrownBy(() -> parameters.setName(name)).isInstanceOf(ParameterRuntimeException.class);
+    }
+
+    @Test
+    public void getName() {
+        final String label = RandomStringUtils.random(10);
+        parameters.setLabel(label);
+        assertThat(parameters.getName()).isEqualTo(label);
+    }
+
+    @Test
+    public void getStreamingMode() {
+        assertThat(parameters.isStreamingMode()).isFalse();
+    }
+
+    @Test
+    public void setStreamingMode() {
+        final boolean streamingMode = random.nextBoolean();
+        parameters.setStreamingMode(streamingMode);
+        assertThat(parameters.isStreamingMode()).isEqualTo(streamingMode);
+    }
+
+    @Test
+    public void validateFileNameNull() {
+        final ValidationResult result = parameters.validate();
+        assertThat(result.isValid()).isFalse();
+    }
+
+    @Test
+    public void validateFileNameAbsolutePath() throws IOException {
+        tempFile = File.createTempFile("test_", ".tmp");
+        parameters.setFileName(tempFile.getAbsolutePath());
+        final ValidationResult result = parameters.validate();
+        assertThat(result.isValid()).isTrue();
+    }
+
+    @Test
+    public void validateFileNameAbsolutePathNotExisting() {
+        parameters.setFileName(RandomStringUtils.randomAlphabetic(5) + ".tmp");
+        System.setProperty(APEX_RELATIVE_FILE_ROOT, System.getProperty("user.home"));
+        final ValidationResult result = parameters.validate();
+        assertThat(result.isValid()).isTrue();
+    }
+
+    @Test
+    public void validateDirectoryName() {
+        parameters.setFileName(System.getProperty("user.dir"));
+        final ValidationResult result = parameters.validate();
+        assertThat(result.isValid()).isFalse();
+    }
+
+    @Test
+    public void validateParentNotDirectory() {
+        final URL resource = FileCarrierTechnologyParameters.class
+            .getResource("FileCarrierTechnologyParameters.class");
+        assumeTrue(resource != null && "file".equalsIgnoreCase(resource.getProtocol()));
+        final String fileParentPath = resource.getPath();
+        final String fileName = RandomStringUtils.randomAlphabetic(5);
+        final String absolutePath = new File(fileParentPath, fileName).getAbsolutePath();
+        parameters.setFileName(absolutePath);
+        final ValidationResult result = parameters.validate();
+        assertThat(result.isValid()).isFalse();
+    }
+
+    @Test
+    public void validateParentDoesNOtExists() {
+        final File fileParent = new File(System.getProperty("user.home"), RandomStringUtils.randomAlphabetic(6));
+        final String fileName = RandomStringUtils.randomAlphabetic(5);
+        final String absolutePath = new File(fileParent, fileName).getAbsolutePath();
+        parameters.setFileName(absolutePath);
+        final ValidationResult result = parameters.validate();
+        assertThat(result.isValid()).isFalse();
+    }
+
+    @Test
+    public void validateDirectorNoSystemVariableSet() {
+        final ValidationResult result = parameters.validate();
+        assertThat(result.isValid()).isFalse();
+    }
+
+    @Test
+    public void validateStandardIo() {
+        parameters.setStandardIo(true);
+        final ValidationResult result = parameters.validate();
+        assertThat(result.isValid()).isTrue();
+    }
+
+    @Test
+    public void validateStandardError() {
+        parameters.setStandardError(true);
+        final ValidationResult result = parameters.validate();
+        assertThat(result.isValid()).isTrue();
+    }
+
+    @Test
+    public void validateNegativeDelay() {
+        final long delay = random.nextInt() * -1;
+        parameters.setStartDelay(delay);
+        final ValidationResult result = parameters.validate();
+        assertThat(result.isValid()).isFalse();
+    }
+
+}
\ No newline at end of file
diff --git a/services/services-engine/src/test/java/org/onap/policy/apex/service/engine/event/impl/filecarrierplugin/consumer/ApexFileEventConsumerTest.java b/services/services-engine/src/test/java/org/onap/policy/apex/service/engine/event/impl/filecarrierplugin/consumer/ApexFileEventConsumerTest.java
new file mode 100644
index 000000000..91e705624
--- /dev/null
+++ b/services/services-engine/src/test/java/org/onap/policy/apex/service/engine/event/impl/filecarrierplugin/consumer/ApexFileEventConsumerTest.java
@@ -0,0 +1,103 @@
+/*
+ *  ============LICENSE_START=======================================================
+ *  Copyright (C) 2021. Nordix Foundation.
+ *  ================================================================================
+ * 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.service.engine.event.impl.filecarrierplugin.consumer;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.assertj.core.api.Assertions.assertThatCode;
+import static org.assertj.core.api.Assertions.assertThatThrownBy;
+
+import java.io.File;
+import org.apache.commons.lang3.RandomStringUtils;
+import org.junit.Before;
+import org.junit.Test;
+import org.onap.policy.apex.service.engine.event.ApexEventException;
+import org.onap.policy.apex.service.engine.event.impl.filecarrierplugin.FileCarrierTechnologyParameters;
+import org.onap.policy.apex.service.engine.parameters.dummyclasses.SuperDooperCarrierTechnologyParameters;
+import org.onap.policy.apex.service.engine.parameters.dummyclasses.SuperTokenDelimitedEventProtocolParameters;
+import org.onap.policy.apex.service.parameters.carriertechnology.CarrierTechnologyParameters;
+import org.onap.policy.apex.service.parameters.eventhandler.EventHandlerParameters;
+import org.onap.policy.apex.service.parameters.eventprotocol.EventProtocolTextTokenDelimitedParameters;
+
+public class ApexFileEventConsumerTest {
+    private ApexFileEventConsumer consumer;
+    private EventHandlerParameters handlerParameters;
+    private File tempFile;
+
+    /**
+     * Prepare tests.
+     *
+     * @throws Exception while file cannot be created
+     */
+    @Before
+    public void setUp() throws Exception {
+        consumer = new ApexFileEventConsumer();
+        handlerParameters = new EventHandlerParameters();
+        tempFile = File.createTempFile("afec", ".tmp");
+        tempFile.deleteOnExit();
+    }
+
+    @Test
+    public void initNoConsumerParameters() {
+        final String name = RandomStringUtils.randomAlphanumeric(4);
+        assertThatThrownBy(() -> consumer.init(name, null, null))
+            .isInstanceOf(ApexEventException.class);
+    }
+
+    @Test
+    public void initWrongCarrier() {
+        final String name = RandomStringUtils.randomAlphanumeric(4);
+        final CarrierTechnologyParameters technologyParameters = new SuperDooperCarrierTechnologyParameters();
+        handlerParameters.setCarrierTechnologyParameters(technologyParameters);
+
+        assertThatThrownBy(() -> consumer.init(name, handlerParameters, null))
+            .isInstanceOf(ApexEventException.class);
+    }
+
+    @Test
+    public void initWithoutReceiver() {
+        final String name = RandomStringUtils.randomAlphanumeric(4);
+        final EventHandlerParameters handlerParameters = new EventHandlerParameters();
+        final FileCarrierTechnologyParameters technologyParameters = new FileCarrierTechnologyParameters();
+        technologyParameters.setFileName(tempFile.getAbsolutePath());
+        final EventProtocolTextTokenDelimitedParameters params = new SuperTokenDelimitedEventProtocolParameters();
+
+        handlerParameters.setCarrierTechnologyParameters(technologyParameters);
+        handlerParameters.setEventProtocolParameters(params);
+
+        assertThatCode(() -> consumer.init(name, handlerParameters, null))
+            .doesNotThrowAnyException();
+    }
+
+    @Test
+    public void getName() throws ApexEventException {
+        final String name = RandomStringUtils.randomAlphabetic(5);
+        final EventHandlerParameters handlerParameters = new EventHandlerParameters();
+        final FileCarrierTechnologyParameters technologyParameters = new FileCarrierTechnologyParameters();
+        technologyParameters.setFileName(tempFile.getAbsolutePath());
+        final EventProtocolTextTokenDelimitedParameters params = new SuperTokenDelimitedEventProtocolParameters();
+
+        handlerParameters.setCarrierTechnologyParameters(technologyParameters);
+        handlerParameters.setEventProtocolParameters(params);
+
+        consumer.init(name, handlerParameters, null);
+        assertThat(consumer.getName()).isEqualTo(name);
+    }
+}
diff --git a/services/services-engine/src/test/java/org/onap/policy/apex/service/engine/event/impl/filecarrierplugin/consumer/HeaderDelimitedTextBlockReaderTest.java b/services/services-engine/src/test/java/org/onap/policy/apex/service/engine/event/impl/filecarrierplugin/consumer/HeaderDelimitedTextBlockReaderTest.java
new file mode 100644
index 000000000..6c595072f
--- /dev/null
+++ b/services/services-engine/src/test/java/org/onap/policy/apex/service/engine/event/impl/filecarrierplugin/consumer/HeaderDelimitedTextBlockReaderTest.java
@@ -0,0 +1,107 @@
+/*
+ *  ============LICENSE_START=======================================================
+ *  Copyright (C) 2021. Nordix Foundation.
+ *  ================================================================================
+ * 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.service.engine.event.impl.filecarrierplugin.consumer;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+import java.io.ByteArrayInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.nio.charset.StandardCharsets;
+import org.apache.commons.lang3.RandomStringUtils;
+import org.junit.Test;
+
+
+public class HeaderDelimitedTextBlockReaderTest {
+
+    @Test
+    public void readTextBlockWithDelimeter() throws IOException {
+        final String startToken = RandomStringUtils.randomAlphabetic(5);
+        final String endToken = RandomStringUtils.randomAlphabetic(6);
+        final boolean delimeter = true;
+        final String text = RandomStringUtils.randomAlphanumeric(20);
+        final String expected = startToken + text;
+        // Prepare the stream
+        final InputStream stream = new ByteArrayInputStream(expected.getBytes(StandardCharsets.UTF_8));
+
+        final HeaderDelimitedTextBlockReader reader =
+            new HeaderDelimitedTextBlockReader(startToken, endToken, delimeter);
+        reader.init(stream);
+
+        final TextBlock textBlock = reader.readTextBlock();
+        assertThat(textBlock.getText()).isEqualTo(expected);
+    }
+
+    @Test
+    public void readTextBlockWithEndTokenDelimeter() throws IOException {
+        final String startToken = RandomStringUtils.randomAlphabetic(5);
+        final String endToken = RandomStringUtils.randomAlphabetic(6);
+        final boolean delimeter = true;
+        final String text = RandomStringUtils.randomAlphanumeric(20);
+        final String input = startToken + "\n" + text + "\n" + endToken + "\n" + text;
+        final String expected = startToken + "\n" + text + "\n" + endToken;
+        // Prepare the stream
+        final InputStream stream = new ByteArrayInputStream(input.getBytes(StandardCharsets.UTF_8));
+
+        final HeaderDelimitedTextBlockReader reader =
+            new HeaderDelimitedTextBlockReader(startToken, endToken, delimeter);
+        reader.init(stream);
+
+        final TextBlock textBlock = reader.readTextBlock();
+        assertThat(textBlock.getText()).isEqualTo(expected);
+    }
+
+    @Test
+    public void readTextBlockWithoutDelimeter() throws IOException {
+        final String startToken = RandomStringUtils.randomAlphabetic(5);
+        final String endToken = RandomStringUtils.randomAlphabetic(6);
+        final boolean delimeter = false;
+        final String text = RandomStringUtils.randomAlphanumeric(20);
+        // Prepare the stream
+        final InputStream stream = new ByteArrayInputStream(text.getBytes(StandardCharsets.UTF_8));
+
+        final HeaderDelimitedTextBlockReader reader =
+            new HeaderDelimitedTextBlockReader(startToken, endToken, delimeter);
+        reader.init(stream);
+
+        final TextBlock textBlock = reader.readTextBlock();
+        assertThat(textBlock.getText()).isEqualTo(text);
+    }
+
+    @Test
+    public void readTextBlockWithEndTokenWithoutDelimeter() throws IOException {
+        final String startToken = RandomStringUtils.randomAlphabetic(5);
+        final String endToken = RandomStringUtils.randomAlphabetic(6);
+        final boolean delimeter = false;
+        final String text = RandomStringUtils.randomAlphanumeric(20);
+        final String input = startToken + "\n" + text + "\n" + endToken + "\n" + text;
+        final String expected = startToken + "\n" + text + "\n" + endToken;
+        // Prepare the stream
+        final InputStream stream = new ByteArrayInputStream(input.getBytes(StandardCharsets.UTF_8));
+
+        final HeaderDelimitedTextBlockReader reader =
+            new HeaderDelimitedTextBlockReader(startToken, endToken, delimeter);
+        reader.init(stream);
+
+        final TextBlock textBlock = reader.readTextBlock();
+        assertThat(textBlock.getText()).isEqualTo(expected);
+    }
+}
diff --git a/services/services-engine/src/test/java/org/onap/policy/apex/service/engine/event/impl/filecarrierplugin/producer/ApexFileEventProducerTest.java b/services/services-engine/src/test/java/org/onap/policy/apex/service/engine/event/impl/filecarrierplugin/producer/ApexFileEventProducerTest.java
new file mode 100644
index 000000000..1ac1cdd7c
--- /dev/null
+++ b/services/services-engine/src/test/java/org/onap/policy/apex/service/engine/event/impl/filecarrierplugin/producer/ApexFileEventProducerTest.java
@@ -0,0 +1,160 @@
+/*
+ *  ============LICENSE_START=======================================================
+ *  Copyright (C) 2021. Nordix Foundation.
+ *  ================================================================================
+ * 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.service.engine.event.impl.filecarrierplugin.producer;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.assertj.core.api.Assertions.assertThatCode;
+import static org.assertj.core.api.Assertions.assertThatThrownBy;
+
+import java.io.ByteArrayOutputStream;
+import java.io.PrintStream;
+import java.util.Random;
+import org.apache.commons.lang3.RandomStringUtils;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+import org.onap.policy.apex.service.engine.event.ApexEventException;
+import org.onap.policy.apex.service.engine.event.ApexEventRuntimeException;
+import org.onap.policy.apex.service.engine.event.impl.filecarrierplugin.FileCarrierTechnologyParameters;
+import org.onap.policy.apex.service.engine.parameters.dummyclasses.SuperDooperCarrierTechnologyParameters;
+import org.onap.policy.apex.service.parameters.eventhandler.EventHandlerParameters;
+
+public class ApexFileEventProducerTest {
+    private final PrintStream out = System.out;
+    private final Random random = new Random();
+    private ApexFileEventProducer eventProducer;
+    private EventHandlerParameters parameters;
+    private FileCarrierTechnologyParameters technologyParameters;
+
+    /**
+     * Prepare for testing.
+     */
+    @Before
+    public void setUp() {
+        eventProducer = new ApexFileEventProducer();
+        parameters = new EventHandlerParameters();
+        technologyParameters = new FileCarrierTechnologyParameters();
+    }
+
+    @After
+    public void tearDown() {
+        System.setOut(out);
+    }
+
+    @Test
+    public void initNullParams() {
+        final String name = RandomStringUtils.randomAlphabetic(5);
+        assertThatThrownBy(() -> eventProducer.init(name, null))
+            .isInstanceOf(ApexEventException.class);
+    }
+
+    @Test
+    public void initParamsInvalidCarrier() {
+        final String name = RandomStringUtils.randomAlphabetic(5);
+        parameters.setCarrierTechnologyParameters(new SuperDooperCarrierTechnologyParameters());
+        assertThatThrownBy(() -> eventProducer.init(name, parameters))
+            .isInstanceOf(ApexEventException.class);
+    }
+
+    @Test
+    public void initParamsWithStandardError() {
+        final String name = RandomStringUtils.randomAlphabetic(5);
+        technologyParameters.setStandardError(true);
+
+        parameters.setCarrierTechnologyParameters(technologyParameters);
+
+        assertThatCode(() -> eventProducer.init(name, parameters))
+            .doesNotThrowAnyException();
+    }
+
+    @Test
+    public void initParamsWithStandardIo() {
+        final String name = RandomStringUtils.randomAlphabetic(5);
+        technologyParameters.setStandardIo(true);
+
+        parameters.setCarrierTechnologyParameters(technologyParameters);
+        assertThatCode(() -> eventProducer.init(name, parameters))
+            .doesNotThrowAnyException();
+    }
+
+    @Test
+    public void initParamsWithFileIsDirectory() {
+        final String name = RandomStringUtils.randomAlphabetic(5);
+        final String fileName = System.getProperty("user.dir");
+
+        technologyParameters.setFileName(fileName);
+
+        parameters.setCarrierTechnologyParameters(technologyParameters);
+        assertThatThrownBy(() -> eventProducer.init(name, parameters))
+            .isInstanceOf(ApexEventException.class);
+    }
+
+    @Test
+    public void initParamsWithDelay() {
+        final String name = RandomStringUtils.randomAlphabetic(5);
+        technologyParameters.setStandardIo(true);
+        parameters.setCarrierTechnologyParameters(technologyParameters);
+
+        assertThatCode(() -> eventProducer.init(name, parameters))
+            .doesNotThrowAnyException();
+    }
+
+    @Test
+    public void sendEventWrongEvent() throws ApexEventException {
+        final long executionId = random.nextLong();
+        final String eventName = RandomStringUtils.randomAlphanumeric(4);
+        final String producerName = RandomStringUtils.randomAlphanumeric(5);
+        final Object event = new Object();
+
+        technologyParameters.setStandardIo(true);
+        final EventHandlerParameters parameters = new EventHandlerParameters();
+        parameters.setCarrierTechnologyParameters(technologyParameters);
+
+        ApexFileEventProducer apexFileEventProducer = new ApexFileEventProducer();
+        apexFileEventProducer.init(producerName, parameters);
+        assertThatThrownBy(() -> apexFileEventProducer.sendEvent(executionId, null, eventName, event))
+            .isInstanceOf(ApexEventRuntimeException.class);
+    }
+
+    @Test
+    public void sendEvent() throws ApexEventException {
+        // Prepare output stream to read data
+        final ByteArrayOutputStream outContent = new ByteArrayOutputStream();
+        System.setOut(new PrintStream(outContent));
+
+        // Prepare producer
+        final String producerName = RandomStringUtils.randomAlphanumeric(5);
+        technologyParameters.setStandardIo(true);
+        final EventHandlerParameters parameters = new EventHandlerParameters();
+        parameters.setCarrierTechnologyParameters(technologyParameters);
+        eventProducer.init(producerName, parameters);
+
+        // Prepare for sending
+        final long executionId = random.nextLong();
+        final String eventName = RandomStringUtils.randomAlphanumeric(4);
+        final String event = RandomStringUtils.randomAlphabetic(6);
+        eventProducer.sendEvent(executionId, null, eventName, event);
+
+        // Check results
+        assertThat(outContent.toString()).contains(event);
+    }
+
+}
\ No newline at end of file