* 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=========================================================
*/
public static final String DEFINITIONS = "definitions";
- private CliEditorContants() {}
+ private CliEditorContants() {
+ // Private constructor to prevent subclassing
+ }
}
*/
public abstract class RestUtils {
// Regular expressions for checking input types
- private static final String XML_INPUT_TYPE_REGEXP = "^\\s*<\\?xml.*>\\s*"; //starts with <?xml...>
+ private static final String XML_INPUT_TYPE_REGEXP = "^\\s*<\\?xml.*>\\s*"; // starts with <?xml...>
/**
* starts with some kind of bracket [ or ( or {, then has something, then has bracket.
*/
/**
* Constructor, block inheritance.
*/
- private RestUtils() {}
+ private RestUtils() {
+ // Private constructor to block subclassing
+ }
/**
* HTTP POST requests can't send nulls so we interpret blanks as nulls.
}
/**
- * Apex HTTP PUT requests send simple single level JSON strings, this method reads those strings
- * into a map.
+ * Apex HTTP PUT requests send simple single level JSON strings, this method reads those strings into a map.
*
* @param jsonString the incoming JSON string
* @return a map of the JSON strings
}
/**
- * Apex HTTP PUT requests send simple single level JSON strings, this method reads those strings
- * into a map.
+ * Apex HTTP PUT requests send simple single level JSON strings, this method reads those strings into a map.
*
* @param <C> the generic type
* @param jsonString the incoming JSON string
* {@inheritDoc}.
*/
@Override
- public void setParameters(final ExecutorParameters parameters) {}
+ public void setParameters(final ExecutorParameters parameters) {
+ // Not used
+ }
}
* {@inheritDoc}.
*/
@Override
- public void setParameters(final ExecutorParameters parameters) {}
+ public void setParameters(final ExecutorParameters parameters) {
+ // Not used
+ }
}
@Override
public final void executePost(final boolean returnValue) throws StateMachineException {
if (!returnValue) {
- String errorMessage =
- "execute-post: task selection logic failed on state \"" + axState.getKey().getId() + "\"";
+ String errorMessage = "execute-post: task selection logic failed on state \"" + axState.getKey().getId()
+ + "\"";
if (executionContext.getMessage() != null) {
errorMessage += ", user message: " + executionContext.getMessage();
}
* {@inheritDoc}.
*/
@Override
- public void setParameters(final ExecutorParameters parameters) {}
+ public void setParameters(final ExecutorParameters parameters) {
+ // Not used
+ }
}
/**
* Private constructor used to prevent sub class instantiation.
*/
- private ClassUtils() {}
+ private ClassUtils() {
+ // Private constructor to block subclassing
+ }
/**
* Get the class names of all classes on the class path. WARNING: This is a heavy call, use sparingly
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Enumeration;
+
import org.slf4j.ext.XLogger;
import org.slf4j.ext.XLoggerFactory;
/**
- * The Class MessagingUtils is a class with static methods used in IPC messaging for finding free
- * ports, translating host names to addresses, serializing objects and flushing object streams.
+ * The Class MessagingUtils is a class with static methods used in IPC messaging for finding free ports, translating
+ * host names to addresses, serializing objects and flushing object streams.
*
* @author Sajeevan Achuthan (sajeevan.achuthan@ericsson.com)
*/
/**
* Private constructor used to prevent sub class instantiation.
*/
- private MessagingUtils() {}
+ private MessagingUtils() {
+ // Private constructor to block subclassing
+ }
/**
- * This method searches the availability of the port, if the requested port not available, this
- * method will throw an exception.
+ * This method searches the availability of the port, if the requested port not available, this method will throw an
+ * exception.
*
* @param port the port to check
* @return the port verified as being free
}
/**
- * This method searches the availability of the port, if the requested port not available,this
- * method will increment the port number and check the availability of that port, this process
- * will continue until it reaches max port range which is MAX_PORT_RANGE.
+ * This method searches the availability of the port, if the requested port not available,this method will increment
+ * the port number and check the availability of that port, this process will continue until it reaches max port
+ * range which is MAX_PORT_RANGE.
*
* @param port the first port to check
* @return the port that was found
}
/**
- * This method searches the availability of the port, if the requested port not available,this
- * method will increment the port number and check the availability, this process will continue
- * until it find port available.
+ * This method searches the availability of the port, if the requested port not available,this method will increment
+ * the port number and check the availability, this process will continue until it find port available.
*
* @param port the first port to check
* @return the port that was found
/**
* Private constructor to prevent sub-classing of this class.
*/
- private ThreadUtilities() {}
+ private ThreadUtilities() {
+ // Private constructor to prevent subclassing
+ }
/**
* Sleeps for the specified number of milliseconds, hiding interrupt handling.
// TODO: Auto-generated Javadoc
/**
* This class tests AADM use case.
+ *
* @author Sergey Sachkov (sergey.sachkov@ericsson.com)
*
*/
ParameterService.register(contextParameters.getDistributorParameters());
ParameterService.register(contextParameters.getLockManagerParameters());
ParameterService.register(contextParameters.getPersistorParameters());
-
+
engineParameters = new EngineParameters();
engineParameters.getExecutorParameterMap().put("MVEL", new MvelExecutorParameters());
ParameterService.register(engineParameters);
@After
public void afterTest() {
ParameterService.deregister(engineParameters);
-
+
ParameterService.deregister(contextParameters.getDistributorParameters());
ParameterService.deregister(contextParameters.getLockManagerParameters());
ParameterService.deregister(contextParameters.getPersistorParameters());
* Test vpn cleardown.
*/
@After
- public void testAadmCleardown() {}
+ public void testAadmCleardown() {
+ // Not used
+ }
/**
* Gets the trigger event.
/**
* Default constructor.
*/
- public AxConcept() {}
+ public AxConcept() {
+ // Default constructor
+ }
/**
* Copy constructor.
* Create an implementation of the Apex editor and model APIs.
*
* @param apexProperties The properties to use for the model
- * @param jsonMode set to true to return JSON strings in list and delete operations, otherwise
- * set to false
+ * @param jsonMode set to true to return JSON strings in list and delete operations, otherwise set to false
*/
public ApexModelImpl(final Properties apexProperties, final boolean jsonMode) {
this.apexProperties = apexProperties;
/**
* Constructor, prevents this class being sub-classed.
*/
- private ApexModelImpl() {}
+ private ApexModelImpl() {
+ // Private constructor to block subclassing
+ }
/**
* {@inheritDoc}.
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=========================================================
-->
<version>0.0.1</version>
</key>
<UUID>0ce9168c-e6df-414f-9646-6da464b6e000</UUID>
- <description><![CDATA[Generated description for concept referred to by key "ContextSchemas:0.0.1"]]></description>
+ <description><![CDATA[Description for concept with key "ContextSchemas:0.0.1"]]></description>
</value>
</entry>
<entry>
<version>0.0.1</version>
</key>
<UUID>0ce9168c-e6df-414f-9646-6da464b6e001</UUID>
- <description><![CDATA[Generated description for concept referred to by key "KeyInfoMapKey:0.0.1"]]></description>
+ <description><![CDATA[Description for concept with key "KeyInfoMapKey:0.0.1"]]></description>
</value>
</entry>
<entry>
<version>0.0.1</version>
</key>
<UUID>0ce9168c-e6df-414f-9646-6da464b6e002</UUID>
- <description><![CDATA[Generated description for concept referred to by key "MapType:0.0.1"]]></description>
+ <description><![CDATA[Description for concept with key "MapType:0.0.1"]]></description>
</value>
</entry>
<entry>
<version>0.0.1</version>
</key>
<UUID>0ce9168c-e6df-414f-9646-6da464b6e003</UUID>
- <description><![CDATA[Generated description for concept referred to by key "PolicyModel:0.0.1"]]></description>
+ <description><![CDATA[Description for concept with key "PolicyModel:0.0.1"]]></description>
</value>
</entry>
<entry>
<version>0.0.1</version>
</key>
<UUID>0ce9168c-e6df-414f-9646-6da464b6e004</UUID>
- <description><![CDATA[Generated description for concept referred to by key "StringType:0.0.1"]]></description>
+ <description><![CDATA[Description for concept with key "StringType:0.0.1"]]></description>
</value>
</entry>
<entry>
<version>0.0.1</version>
</key>
<UUID>0ce9168c-e6df-414f-9646-6da464b6e005</UUID>
- <description><![CDATA[Generated description for concept referred to by key "context:0.0.1"]]></description>
+ <description><![CDATA[Description for concept with key "context:0.0.1"]]></description>
</value>
</entry>
<entry>
<version>0.0.1</version>
</key>
<UUID>0ce9168c-e6df-414f-9646-6da464b6e006</UUID>
- <description><![CDATA[Generated description for concept referred to by key "contextAlbum0:0.0.1"]]></description>
+ <description><![CDATA[Description for concept with key "contextAlbum0:0.0.1"]]></description>
</value>
</entry>
<entry>
<version>0.0.1</version>
</key>
<UUID>0ce9168c-e6df-414f-9646-6da464b6e007</UUID>
- <description><![CDATA[Generated description for concept referred to by key "contextAlbum1:0.0.1"]]></description>
+ <description><![CDATA[Description for concept with key "contextAlbum1:0.0.1"]]></description>
</value>
</entry>
<entry>
<version>0.0.1</version>
</key>
<UUID>0ce9168c-e6df-414f-9646-6da464b6e008</UUID>
- <description><![CDATA[Generated description for concept referred to by key "eventContextItem0:0.0.1"]]></description>
+ <description><![CDATA[Description for concept with key "eventContextItem0:0.0.1"]]></description>
</value>
</entry>
<entry>
<version>0.0.1</version>
</key>
<UUID>0ce9168c-e6df-414f-9646-6da464b6e009</UUID>
- <description><![CDATA[Generated description for concept referred to by key "eventContextItem1:0.0.1"]]></description>
+ <description><![CDATA[Description for concept with key "eventContextItem1:0.0.1"]]></description>
</value>
</entry>
<entry>
<version>0.0.1</version>
</key>
<UUID>0ce9168c-e6df-414f-9646-6da464b6e010</UUID>
- <description><![CDATA[Generated description for concept referred to by key "events:0.0.1"]]></description>
+ <description><![CDATA[Description for concept with key "events:0.0.1"]]></description>
</value>
</entry>
<entry>
<version>0.0.1</version>
</key>
<UUID>0ce9168c-e6df-414f-9646-6da464b6e011</UUID>
- <description><![CDATA[Generated description for concept referred to by key "inEvent:0.0.1"]]></description>
+ <description><![CDATA[Description for concept with key "inEvent:0.0.1"]]></description>
</value>
</entry>
<entry>
<version>0.0.1</version>
</key>
<UUID>0ce9168c-e6df-414f-9646-6da464b6e012</UUID>
- <description><![CDATA[Generated description for concept referred to by key "outEvent0:0.0.1"]]></description>
+ <description><![CDATA[Description for concept with key "outEvent0:0.0.1"]]></description>
</value>
</entry>
<entry>
<version>0.0.1</version>
</key>
<UUID>0ce9168c-e6df-414f-9646-6da464b6e013</UUID>
- <description><![CDATA[Generated description for concept referred to by key "outEvent1:0.0.1"]]></description>
+ <description><![CDATA[Description for concept with key "outEvent1:0.0.1"]]></description>
</value>
</entry>
<entry>
<version>0.0.1</version>
</key>
<UUID>0ce9168c-e6df-414f-9646-6da464b6e014</UUID>
- <description><![CDATA[Generated description for concept referred to by key "policies:0.0.1"]]></description>
+ <description><![CDATA[Description for concept with key "policies:0.0.1"]]></description>
</value>
</entry>
<entry>
<version>0.0.1</version>
</key>
<UUID>0ce9168c-e6df-414f-9646-6da464b6e015</UUID>
- <description><![CDATA[Generated description for concept referred to by key "policy:0.0.1"]]></description>
+ <description><![CDATA[Description for concept with key "policy:0.0.1"]]></description>
</value>
</entry>
<entry>
<version>0.0.1</version>
</key>
<UUID>0ce9168c-e6df-414f-9646-6da464b6e016</UUID>
- <description><![CDATA[Generated description for concept referred to by key "task:0.0.1"]]></description>
+ <description><![CDATA[Description for concept with key "task:0.0.1"]]></description>
</value>
</entry>
<entry>
<version>0.0.1</version>
</key>
<UUID>0ce9168c-e6df-414f-9646-6da464b6e017</UUID>
- <description><![CDATA[Generated description for concept referred to by key "tasks:0.0.1"]]></description>
+ <description><![CDATA[Description for concept with key "tasks:0.0.1"]]></description>
</value>
</entry>
</keyInfoMap>
<version xmlns="http://www.onap.org/policy/apex-pdp">0.0.1</version>
</key>
<schemaFlavour>Java</schemaFlavour>
- <schemaDefinition>org.onap.policy.apex.model.policymodel.concepts.TestContextItem00A</schemaDefinition>
+ <schemaDefinition>org.onap.policy.apex.model.policymodel.concepts.TestContextItem00A
+ </schemaDefinition>
</value>
</entry>
<entry>
<version xmlns="http://www.onap.org/policy/apex-pdp">0.0.1</version>
</key>
<schemaFlavour>Java</schemaFlavour>
- <schemaDefinition>org.onap.policy.apex.model.policymodel.concepts.TestContextItem000</schemaDefinition>
+ <schemaDefinition>org.onap.policy.apex.model.policymodel.concepts.TestContextItem000
+ </schemaDefinition>
</value>
</entry>
<entry>
* 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=========================================================
*/
import org.slf4j.ext.XLoggerFactory;
/**
- * Helper class used to extract information from a policy model into a policy model that is a subset
- * of the original policy model.
+ * Helper class used to extract information from a policy model into a policy model that is a subset of the original
+ * policy model.
*
* @author Liam Fallon (liam.fallon@ericsson.com)
*/
/**
* Private constructor used to prevent sub class instantiation.
*/
- private PolicyModelSplitter() {}
+ private PolicyModelSplitter() {
+ // Private constructor to block subclassing
+ }
/**
- * Get a sub policy model with only the information required for the specified policies from a
- * larger policy model.
+ * Get a sub policy model with only the information required for the specified policies from a larger policy model.
*
* @param sourcePolicyModel the source Apex Model
* @param subPolicies the policies to include in sub policy model
}
/**
- * Get a sub policy model with only the information required for the specified policies from a
- * larger policy model.
+ * Get a sub policy model with only the information required for the specified policies from a larger policy model.
*
* @param sourcePolicyModel the source Apex Model
* @param subPolicies the policies to include in sub policy model
* 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=========================================================
*/
import java.util.NavigableMap;
/**
- * This class provides utility functions for tree maps. A function to find the nearest match in the
- * tree map to an input string is provided.
+ * This class provides utility functions for tree maps. A function to find the nearest match in the tree map to an input
+ * string is provided.
*
* @author Liam Fallon (liam.fallon@ericsson.com)
*/
/**
* This class is a utility class that can't be instantiated.
*/
- private TreeMapUtils() {}
+ private TreeMapUtils() {
+ // Private constructor to block subclassing
+ }
/**
- * Find the list of entries that matches a given word, for example "p" will match "put",
- * "policy", and "push".
+ * Find the list of entries that matches a given word, for example "p" will match "put", "policy", and "push".
*
* @param <T> the generic type for the value of the tree map
* @param searchMap the map that the method operates on
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=========================================================
-->
<persistence xmlns="http://java.sun.com/xml/ns/persistence" version="2.0">
- <persistence-unit name="org.onap.policy.apex.core.model.eclipselink.runtime" transaction-type="RESOURCE_LOCAL">
+ <persistence-unit name="org.onap.policy.apex.core.model.eclipselink.runtime"
+ transaction-type="RESOURCE_LOCAL">
<provider>org.eclipse.persistence.jpa.PersistenceProvider</provider>
<class>org.onap.policy.apex.core.basicmodel.dao.converters.UUID2String</class>
</properties>
</persistence-unit>
- <persistence-unit name="org.onap.policy.apex.core.model.eclipselink.test" transaction-type="RESOURCE_LOCAL">
+ <persistence-unit name="org.onap.policy.apex.core.model.eclipselink.test"
+ transaction-type="RESOURCE_LOCAL">
<provider>org.eclipse.persistence.jpa.PersistenceProvider</provider>
<class>org.onap.policy.apex.core.basicmodel.dao.converters.UUID2String</class>
<property name="hibernate.dialect" value="org.hibernate.dialect.PostgreSQL94Dialect" />
<property name="hibernate.hbm2ddl.auto" value="update" />
- <property name="hibernate.connection.provider_class" value="org.hibernate.connection.C3P0ConnectionProvider" />
+ <property name="hibernate.connection.provider_class"
+ value="org.hibernate.connection.C3P0ConnectionProvider" />
<property name="hibernate.temp.use_jdbc_metadata_defaults" value="false" />
<property name="hibernate.c3p0.max_size" value="100" />
<property name="hibernate.c3p0.min_size" value="0" />
<property name="javax.persistence.jdbc.password" value="postgres" />
<property name="hibernate.dialect" value="org.hibernate.dialect.PostgreSQL94Dialect" />
<property name="hibernate.hbm2ddl.auto" value="create" />
- <property name="hibernate.connection.provider_class" value="org.hibernate.connection.C3P0ConnectionProvider" />
+ <property name="hibernate.connection.provider_class"
+ value="org.hibernate.connection.C3P0ConnectionProvider" />
<property name="hibernate.temp.use_jdbc_metadata_defaults" value="false" />
<property name="hibernate.c3p0.max_size" value="100" />
<property name="hibernate.c3p0.min_size" value="0" />
* 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=========================================================
*/
/**
* This static final class contains utility methods for Avro schemas.
- *
+ *
* @author Liam Fallon (liam.fallon@ericsson.com)
*/
public final class AvroSchemaKeyTranslationUtilities {
/**
* Default constructor to avoid subclassing.
*/
- private AvroSchemaKeyTranslationUtilities() {}
+ private AvroSchemaKeyTranslationUtilities() {
+ // Private constructor to prevent subclassing
+ }
/**
- * Translate characters in JSON keys to values that are legal in Avro. Avro names must start
- * with [A-Za-z_] and subsequently contain only [A-Za-z0-9_]
+ * Translate characters in JSON keys to values that are legal in Avro. Avro names must start with [A-Za-z_] and
+ * subsequently contain only [A-Za-z0-9_]
*
* @param jsonString The JSON string to translate
* @param revert True if we want to revert the field names to their original values
}
// Create a JSON element for the incoming JSON string
- final JsonElement jsonElement =
- new GsonBuilder().serializeNulls().create().fromJson(jsonString, JsonElement.class);
+ final JsonElement jsonElement = new GsonBuilder().serializeNulls().create().fromJson(jsonString,
+ JsonElement.class);
final JsonElement translatedJsonElement = translateIllegalKeys(jsonElement, revert);
}
/**
- * Translate characters in JSON keys to values that are legal in Avro. Avro names must start
- * with [A-Za-z_] and subsequently contain only [A-Za-z0-9_]
+ * Translate characters in JSON keys to values that are legal in Avro. Avro names must start with [A-Za-z_] and
+ * subsequently contain only [A-Za-z0-9_]
*
* @param jsonElement The JSON element to translate
* @param revert True if we want to revert the field names to their original values
}
/**
- * Translate characters in JSON keys to values that are legal in Avro. Avro names must start
- * with [A-Za-z_] and subsequently contain only [A-Za-z0-9_]
+ * Translate characters in JSON keys to values that are legal in Avro. Avro names must start with [A-Za-z_] and
+ * subsequently contain only [A-Za-z0-9_]
*
* @param jsonObject The JSON object to translate
* @param revert True if we want to revert the field names to their original values
}
/**
- * Translate characters in JSON keys to values that are legal in Avro. Avro names must start
- * with [A-Za-z_] and subsequently contain only [A-Za-z0-9_]
+ * Translate characters in JSON keys to values that are legal in Avro. Avro names must start with [A-Za-z_] and
+ * subsequently contain only [A-Za-z0-9_]
*
* @param jsonArray The JSON array to translate
* @param revert True if we want to revert the field names to their original values
}
/**
- * Translate characters in a single JSON key to values that are legal in Avro. Avro names must
- * start with [A-Za-z_] and subsequently contain only [A-Za-z0-9_]
+ * Translate characters in a single JSON key to values that are legal in Avro. Avro names must start with [A-Za-z_]
+ * and subsequently contain only [A-Za-z0-9_]
*
* @param key The key to translate
* @param revert True if we want to revert the field names to their original values
* 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=========================================================
*/
/**
* Test for an empty parameter file.
- *
+ *
* @author Liam Fallon (liam.fallon@ericsson.com)
*/
public class ExecutorParameterTests {
@Test
public void noParamsTest() {
- final String[] args =
- { "-c", "src/test/resources/parameters/serviceExecutorNoParams.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/serviceExecutorNoParams.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
final ApexParameters parameters = new ApexParameterHandler().getParameters(arguments);
- assertEquals(0, parameters.getEngineServiceParameters().getEngineParameters().getExecutorParameterMap()
- .size());
+ assertEquals(0,
+ parameters.getEngineServiceParameters().getEngineParameters().getExecutorParameterMap().size());
} catch (final ParameterException e) {
fail("This test should not throw any exception: " + e.getMessage());
}
@Test
public void badParamsTest() {
- final String[] args =
- { "-c", "src/test/resources/parameters/serviceExecutorBadParams.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/serviceExecutorBadParams.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
fail("This test should throw an exception");
} catch (final ParameterException e) {
assertEquals("error reading parameters from "
- + "\"src/test/resources/parameters/serviceExecutorBadParams.json\"\n"
- + "(ParameterRuntimeException):value of \"executorParameters:ZOOBY\" entry is not "
- + "a parameter JSON object", e.getMessage());
+ + "\"src/test/resources/parameters/serviceExecutorBadParams.json\"\n"
+ + "(ParameterRuntimeException):value of \"executorParameters:ZOOBY\" entry is not "
+ + "a parameter JSON object", e.getMessage());
}
}
@Test
public void noExecutorParamsTest() {
- final String[] args =
- { "-c", "src/test/resources/parameters/serviceExecutorNoExecutorParams.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/serviceExecutorNoExecutorParams.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
fail("This test should throw an exception");
} catch (final ParameterException e) {
assertEquals("error reading parameters from "
- + "\"src/test/resources/parameters/serviceExecutorNoExecutorParams.json\"\n"
- + "(ParameterRuntimeException):no \"executorParameters\" entry found in parameters,"
- + " at least one executor parameter entry must be specified", e.getMessage());
+ + "\"src/test/resources/parameters/serviceExecutorNoExecutorParams.json\"\n"
+ + "(ParameterRuntimeException):no \"executorParameters\" entry found in parameters,"
+ + " at least one executor parameter entry must be specified", e.getMessage());
}
}
@Test
public void emptyParamsTest() {
- final String[] args =
- { "-c", "src/test/resources/parameters/serviceExecutorEmptyParams.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/serviceExecutorEmptyParams.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
fail("This test should throw an exception");
} catch (final ParameterException e) {
assertEquals("error reading parameters from "
- + "\"src/test/resources/parameters/serviceExecutorEmptyParams.json\"\n"
- + "(ParameterRuntimeException):could not find field \"parameterClassName\" "
- + "in \"executorParameters:ZOOBY\" entry", e.getMessage());
+ + "\"src/test/resources/parameters/serviceExecutorEmptyParams.json\"\n"
+ + "(ParameterRuntimeException):could not find field \"parameterClassName\" "
+ + "in \"executorParameters:ZOOBY\" entry", e.getMessage());
}
}
@Test
public void badPluginParamNameTest() {
- final String[] args =
- { "-c", "src/test/resources/parameters/serviceExecutorBadPluginNameParams.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/serviceExecutorBadPluginNameParams.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
fail("This test should throw an exception");
} catch (final ParameterException e) {
assertEquals("error reading parameters from "
- + "\"src/test/resources/parameters/serviceExecutorBadPluginNameParams.json\"\n"
- + "(ParameterRuntimeException):could not find field \"parameterClassName\" "
- + "in \"executorParameters:ZOOBY\" entry", e.getMessage());
+ + "\"src/test/resources/parameters/serviceExecutorBadPluginNameParams.json\"\n"
+ + "(ParameterRuntimeException):could not find field \"parameterClassName\" "
+ + "in \"executorParameters:ZOOBY\" entry", e.getMessage());
}
}
@Test
public void badPluginParamObjectTest() {
- final String[] args =
- { "-c", "src/test/resources/parameters/serviceExecutorBadPluginValueObjectParams.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/serviceExecutorBadPluginValueObjectParams.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
fail("This test should throw an exception");
} catch (final ParameterException e) {
assertEquals("error reading parameters from "
- + "\"src/test/resources/parameters/serviceExecutorBadPluginValueObjectParams.json\"\n"
- + "(ParameterRuntimeException):value for field \"parameterClassName\" "
- + "of \"executorParameters:LOOBY\" entry is not a plain string", e.getMessage());
+ + "\"src/test/resources/parameters/serviceExecutorBadPluginValueObjectParams.json\"\n"
+ + "(ParameterRuntimeException):value for field \"parameterClassName\" "
+ + "of \"executorParameters:LOOBY\" entry is not a plain string", e.getMessage());
}
}
@Test
public void badPluginParamBlankTest() {
- final String[] args =
- { "-c", "src/test/resources/parameters/serviceExecutorBadPluginValueBlankParams.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/serviceExecutorBadPluginValueBlankParams.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
fail("This test should throw an exception");
} catch (final ParameterException e) {
assertEquals("error reading parameters from "
- + "\"src/test/resources/parameters/serviceExecutorBadPluginValueBlankParams.json\"\n"
- + "(ParameterRuntimeException):value for field \"parameterClassName\" "
- + "in \"executorParameters:LOOBY\" entry is not specified or is blank", e.getMessage());
+ + "\"src/test/resources/parameters/serviceExecutorBadPluginValueBlankParams.json\"\n"
+ + "(ParameterRuntimeException):value for field \"parameterClassName\" "
+ + "in \"executorParameters:LOOBY\" entry is not specified or is blank", e.getMessage());
}
}
@Test
public void badPluginParamValueTest() {
- final String[] args =
- { "-c", "src/test/resources/parameters/serviceExecutorBadPluginValueParams.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/serviceExecutorBadPluginValueParams.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
fail("This test should throw an exception");
} catch (final ParameterException e) {
assertEquals("error reading parameters from"
- + " \"src/test/resources/parameters/serviceExecutorBadPluginValueParams.json\"\n"
- + "(ParameterRuntimeException):failed to deserialize the parameters "
- + "for \"executorParameters:LOOBY\" to parameter class \"helloworld\"\n"
- + "java.lang.ClassNotFoundException: helloworld", e.getMessage());
+ + " \"src/test/resources/parameters/serviceExecutorBadPluginValueParams.json\"\n"
+ + "(ParameterRuntimeException):failed to deserialize the parameters "
+ + "for \"executorParameters:LOOBY\" to parameter class \"helloworld\"\n"
+ + "java.lang.ClassNotFoundException: helloworld", e.getMessage());
}
}
@Test
public void goodParametersTest() {
- final String[] args =
- { "-c", "src/test/resources/parameters/goodParams.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/goodParams.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
@Test
public void relativeParametersTest() {
- final String[] args =
- { "-rfr", "src/test/resources", "-c", "src/test/resources/parameters/goodParamsRelative.json" };
+ // @formatter:off
+ final String[] args = {
+ "-rfr",
+ "src/test/resources",
+ "-c",
+ "src/test/resources/parameters/goodParamsRelative.json"
+ };
+ // @formatter:on
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
assertEquals(19, parameters.getEngineServiceParameters().getInstanceCount());
assertEquals(65522, parameters.getEngineServiceParameters().getDeploymentPort());
assertTrue(parameters.getEngineServiceParameters().getPolicyModelFileName()
- .endsWith("policymodels/SmallModel.json"));
+ .endsWith("policymodels/SmallModel.json"));
} catch (final ParameterException e) {
fail("This test should not throw any exception: " + e.getMessage());
}
public class ParameterTests {
@Test
public void invalidParametersNoFileTest() throws ParameterException {
- final String[] args = { "-c", "src/test/resources/parameters/invalidNoFile.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/invalidNoFile.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
@Test
public void invalidParametersEmptyTest() {
- final String[] args = { "-c", "src/test/resources/parameters/empty.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/empty.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
@Test
public void invalidParametersNoParamsTest() {
- final String[] args = { "-c", "src/test/resources/parameters/noParams.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/noParams.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
@Test
public void invalidParametersBlankParamsTest() {
- final String[] args = { "-c", "src/test/resources/parameters/blankParams.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/blankParams.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
@Test
public void invalidParametersTest() {
- final String[] args = { "-c", "src/test/resources/parameters/badParams.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/badParams.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
@Test
public void modelNotFileTest() {
- final String[] args = { "-c", "src/test/resources/parameters/badParamsModelNotFile.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/badParamsModelNotFile.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
@Test
public void goodParametersTest() {
- final String[] args = { "-c", "src/test/resources/parameters/goodParams.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/goodParams.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
@Test
public void superDooperParametersTest() {
- final String[] args = { "-c", "src/test/resources/parameters/superDooperParams.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/superDooperParams.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
assertEquals("some.key.deserailizer", superDooperParameters.getKeyDeserializer());
assertEquals("some.value.deserailizer", superDooperParameters.getValueDeserializer());
- final String[] consumerTopics = { "consumer-out-0", "consumer-out-1", "consumer-out-2" };
+ final String[] consumerTopics = {"consumer-out-0", "consumer-out-1", "consumer-out-2"};
assertEquals(Arrays.asList(consumerTopics), superDooperParameters.getConsumerTopicList());
} catch (final ParameterException e) {
fail("This test should not throw an exception");
public class ProducerConsumerTests {
@Test
public void goodParametersTest() {
- final String[] args =
- { "-c", "src/test/resources/parameters/goodParams.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/goodParams.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
assertEquals(19, parameters.getEngineServiceParameters().getInstanceCount());
assertEquals(65522, parameters.getEngineServiceParameters().getDeploymentPort());
assertEquals("FILE", parameters.getEventOutputParameters().get("FirstProducer")
- .getCarrierTechnologyParameters().getLabel());
- assertEquals("JSON", parameters.getEventOutputParameters().get("FirstProducer").getEventProtocolParameters()
- .getLabel());
+ .getCarrierTechnologyParameters().getLabel());
+ assertEquals("JSON",
+ parameters.getEventOutputParameters().get("FirstProducer").getEventProtocolParameters().getLabel());
assertEquals("FILE", parameters.getEventOutputParameters().get("MyOtherProducer")
- .getCarrierTechnologyParameters().getLabel());
+ .getCarrierTechnologyParameters().getLabel());
assertEquals("JSON", parameters.getEventOutputParameters().get("MyOtherProducer")
- .getEventProtocolParameters().getLabel());
+ .getEventProtocolParameters().getLabel());
assertEquals("FILE", parameters.getEventInputParameters().get("TheFileConsumer1")
- .getCarrierTechnologyParameters().getLabel());
+ .getCarrierTechnologyParameters().getLabel());
assertEquals("JSON", parameters.getEventInputParameters().get("TheFileConsumer1")
- .getEventProtocolParameters().getLabel());
+ .getEventProtocolParameters().getLabel());
assertEquals("SUPER_DOOPER", parameters.getEventInputParameters().get("MySuperDooperConsumer1")
- .getCarrierTechnologyParameters().getLabel());
+ .getCarrierTechnologyParameters().getLabel());
assertEquals("SUPER_TOK_DEL", parameters.getEventInputParameters().get("MySuperDooperConsumer1")
- .getEventProtocolParameters().getLabel());
+ .getEventProtocolParameters().getLabel());
} catch (final ParameterException e) {
fail("This test should not throw an exception");
}
@Test
public void noCarrierTechnology() {
- final String[] args =
- { "-c", "src/test/resources/parameters/prodConsNoCT.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/prodConsNoCT.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
fail("This test should throw an exception");
} catch (final ParameterException e) {
assertEquals("validation error(s) on parameters from \"src/test/resources/parameters/prodConsNoCT.json\"\n"
- + "parameter group \"APEX_PARAMETERS\" type "
- + "\"org.onap.policy.apex.service.parameters.ApexParameters\" INVALID, "
- + "parameter group has status INVALID\n"
- + " parameter group map \"eventInputParameters\" INVALID, "
- + "parameter group map has status INVALID\n" + " parameter group \"aConsumer\" type "
- + "\"org.onap.policy.apex.service.parameters.eventhandler.EventHandlerParameters\" INVALID,"
- + " parameter group has status INVALID\n" + " parameter group \"UNDEFINED\" INVALID, "
- + "event handler carrierTechnologyParameters not specified or blank\n", e.getMessage());
+ + "parameter group \"APEX_PARAMETERS\" type "
+ + "\"org.onap.policy.apex.service.parameters.ApexParameters\" INVALID, "
+ + "parameter group has status INVALID\n"
+ + " parameter group map \"eventInputParameters\" INVALID, "
+ + "parameter group map has status INVALID\n" + " parameter group \"aConsumer\" type "
+ + "\"org.onap.policy.apex.service.parameters.eventhandler.EventHandlerParameters\" INVALID,"
+ + " parameter group has status INVALID\n" + " parameter group \"UNDEFINED\" INVALID, "
+ + "event handler carrierTechnologyParameters not specified or blank\n", e.getMessage());
}
}
@Test
public void noEventProcol() {
- final String[] args =
- { "-c", "src/test/resources/parameters/prodConsNoEP.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/prodConsNoEP.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
fail("This test should throw an exception");
} catch (final ParameterException e) {
assertEquals("validation error(s) on parameters from \"src/test/resources/parameters/prodConsNoEP.json\"\n"
- + "parameter group \"APEX_PARAMETERS\" type "
- + "\"org.onap.policy.apex.service.parameters.ApexParameters\" INVALID, "
- + "parameter group has status INVALID\n"
- + " parameter group map \"eventOutputParameters\" INVALID, "
- + "parameter group map has status INVALID\n" + " parameter group \"aProducer\" type "
- + "\"org.onap.policy.apex.service.parameters.eventhandler.EventHandlerParameters\" INVALID"
- + ", parameter group has status INVALID\n" + " parameter group \"UNDEFINED\" INVALID, "
- + "event handler eventProtocolParameters not specified or blank\n"
- + " parameter group map \"eventInputParameters\" INVALID, "
- + "parameter group map has status INVALID\n" + " parameter group \"aConsumer\" type "
- + "\"org.onap.policy.apex.service.parameters.eventhandler.EventHandlerParameters\" INVALID"
- + ", parameter group has status INVALID\n" + " parameter group \"FILE\" type "
- + "\"org.onap.policy.apex.service.engine.event.impl."
- + "filecarrierplugin.FileCarrierTechnologyParameters\" INVALID, "
- + "parameter group has status INVALID\n"
- + " field \"fileName\" type \"java.lang.String\" value \"null\" INVALID, "
- + "\"null\" invalid, must be specified as a non-empty string\n", e.getMessage());
+ + "parameter group \"APEX_PARAMETERS\" type "
+ + "\"org.onap.policy.apex.service.parameters.ApexParameters\" INVALID, "
+ + "parameter group has status INVALID\n"
+ + " parameter group map \"eventOutputParameters\" INVALID, "
+ + "parameter group map has status INVALID\n" + " parameter group \"aProducer\" type "
+ + "\"org.onap.policy.apex.service.parameters.eventhandler.EventHandlerParameters\" INVALID"
+ + ", parameter group has status INVALID\n" + " parameter group \"UNDEFINED\" INVALID, "
+ + "event handler eventProtocolParameters not specified or blank\n"
+ + " parameter group map \"eventInputParameters\" INVALID, "
+ + "parameter group map has status INVALID\n" + " parameter group \"aConsumer\" type "
+ + "\"org.onap.policy.apex.service.parameters.eventhandler.EventHandlerParameters\" INVALID"
+ + ", parameter group has status INVALID\n" + " parameter group \"FILE\" type "
+ + "\"org.onap.policy.apex.service.engine.event.impl."
+ + "filecarrierplugin.FileCarrierTechnologyParameters\" INVALID, "
+ + "parameter group has status INVALID\n"
+ + " field \"fileName\" type \"java.lang.String\" value \"null\" INVALID, "
+ + "\"null\" invalid, must be specified as a non-empty string\n", e.getMessage());
}
}
@Test
public void noCarrierTechnologyParClass() {
- final String[] args =
- { "-c", "src/test/resources/parameters/prodConsNoCTParClass.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/prodConsNoCTParClass.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
fail("This test should throw an exception");
} catch (final ParameterException e) {
assertEquals("error reading parameters from \"src/test/resources/parameters/prodConsNoCTParClass.json\"\n"
- + "(ParameterRuntimeException):carrier technology \"SUPER_DOOPER\" "
- + "parameter \"parameterClassName\" value \"null\" invalid in JSON file", e.getMessage());
+ + "(ParameterRuntimeException):carrier technology \"SUPER_DOOPER\" "
+ + "parameter \"parameterClassName\" value \"null\" invalid in JSON file", e.getMessage());
}
}
@Test
public void mismatchCarrierTechnologyParClass() {
- final String[] args =
- { "-c", "src/test/resources/parameters/prodConsMismatchCTParClass.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/prodConsMismatchCTParClass.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
fail("This test should throw an exception");
} catch (final ParameterException e) {
assertEquals("error reading parameters from "
- + "\"src/test/resources/parameters/prodConsMismatchCTParClass.json\"\n"
- + "(ParameterRuntimeException):carrier technology \"SUPER_LOOPER\" "
- + "does not match plugin \"SUPER_DOOPER\" in \"" + "org.onap.policy.apex.service.engine."
- + "parameters.dummyclasses.SuperDooperCarrierTechnologyParameters"
- + "\", specify correct carrier technology parameter plugin "
- + "in parameter \"parameterClassName\"", e.getMessage());
+ + "\"src/test/resources/parameters/prodConsMismatchCTParClass.json\"\n"
+ + "(ParameterRuntimeException):carrier technology \"SUPER_LOOPER\" "
+ + "does not match plugin \"SUPER_DOOPER\" in \"" + "org.onap.policy.apex.service.engine."
+ + "parameters.dummyclasses.SuperDooperCarrierTechnologyParameters"
+ + "\", specify correct carrier technology parameter plugin "
+ + "in parameter \"parameterClassName\"", e.getMessage());
}
}
@Test
public void wrongTypeCarrierTechnologyParClass() {
- final String[] args =
- { "-c", "src/test/resources/parameters/prodConsWrongTypeCTParClass.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/prodConsWrongTypeCTParClass.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
new ApexParameterHandler().getParameters(arguments);
fail("This test should throw an exception");
} catch (final ParameterException e) {
- assertEquals("error reading parameters from "
+ assertEquals(
+ "error reading parameters from "
+ "\"src/test/resources/parameters/prodConsWrongTypeCTParClass.json\"\n"
+ "(ParameterRuntimeException):could not create default parameters for carrier technology "
+ "\"SUPER_DOOPER\"\n" + "org.onap.policy.apex.service.engine.parameters.dummyclasses."
+ "SuperTokenDelimitedEventProtocolParameters cannot be cast to "
+ "org.onap.policy.apex.service.parameters.carriertechnology.CarrierTechnologyParameters",
- e.getMessage());
+ e.getMessage());
}
}
@Test
public void okFileNameCarrierTechnology() {
- final String[] args =
- { "-c", "src/test/resources/parameters/prodConsOKFileName.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/prodConsOKFileName.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
final ApexParameters parameters = new ApexParameterHandler().getParameters(arguments);
final FileCarrierTechnologyParameters fileParams = (FileCarrierTechnologyParameters) parameters
- .getEventOutputParameters().get("aProducer").getCarrierTechnologyParameters();
+ .getEventOutputParameters().get("aProducer").getCarrierTechnologyParameters();
assertTrue(fileParams.getFileName().endsWith("target/aaa.json"));
assertEquals(false, fileParams.isStandardError());
assertEquals(false, fileParams.isStandardIo());
@Test
public void badFileNameCarrierTechnology() {
- final String[] args =
- { "-c", "src/test/resources/parameters/prodConsBadFileName.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/prodConsBadFileName.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
fail("This test should throw an exception");
} catch (final ParameterException e) {
assertEquals("validation error(s) on parameters from "
- + "\"src/test/resources/parameters/prodConsBadFileName.json\"\n"
- + "parameter group \"APEX_PARAMETERS\" type "
- + "\"org.onap.policy.apex.service.parameters.ApexParameters\" INVALID, "
- + "parameter group has status INVALID\n"
- + " parameter group map \"eventOutputParameters\" INVALID, "
- + "parameter group map has status INVALID\n" + " parameter group \"aProducer\" type "
- + "\"org.onap.policy.apex.service.parameters.eventhandler.EventHandlerParameters\" "
- + "INVALID, parameter group has status INVALID\n" + " parameter group \"FILE\" type "
- + "\"org.onap.policy.apex.service.engine.event.impl."
- + "filecarrierplugin.FileCarrierTechnologyParameters\" INVALID, "
- + "parameter group has status INVALID\n" + " field \"fileName\" type "
- + "\"java.lang.String\" value \"null\" INVALID, "
- + "\"null\" invalid, must be specified as a non-empty string\n", e.getMessage());
+ + "\"src/test/resources/parameters/prodConsBadFileName.json\"\n"
+ + "parameter group \"APEX_PARAMETERS\" type "
+ + "\"org.onap.policy.apex.service.parameters.ApexParameters\" INVALID, "
+ + "parameter group has status INVALID\n"
+ + " parameter group map \"eventOutputParameters\" INVALID, "
+ + "parameter group map has status INVALID\n" + " parameter group \"aProducer\" type "
+ + "\"org.onap.policy.apex.service.parameters.eventhandler.EventHandlerParameters\" "
+ + "INVALID, parameter group has status INVALID\n" + " parameter group \"FILE\" type "
+ + "\"org.onap.policy.apex.service.engine.event.impl."
+ + "filecarrierplugin.FileCarrierTechnologyParameters\" INVALID, "
+ + "parameter group has status INVALID\n" + " field \"fileName\" type "
+ + "\"java.lang.String\" value \"null\" INVALID, "
+ + "\"null\" invalid, must be specified as a non-empty string\n", e.getMessage());
}
}
@Test
public void badEventProtocolParClass() {
- final String[] args =
- { "-c", "src/test/resources/parameters/prodConsBadEPParClass.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/prodConsBadEPParClass.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
new ApexParameterHandler().getParameters(arguments);
fail("This test should throw an exception");
} catch (final ParameterException e) {
- assertEquals("error reading parameters from \"src/test/resources/parameters/prodConsBadEPParClass.json\"\n"
+ assertEquals(
+ "error reading parameters from \"src/test/resources/parameters/prodConsBadEPParClass.json\"\n"
+ "(ParameterRuntimeException):event protocol \"SUPER_TOK_DEL\" "
+ "does not match plugin \"JSON\" in \"org.onap.policy.apex.service.engine.event.impl"
+ ".jsonprotocolplugin.JsonEventProtocolParameters"
+ "\", specify correct event protocol parameter plugin in parameter \"parameterClassName\"",
- e.getMessage());
+ e.getMessage());
}
}
@Test
public void noEventProtocolParClass() {
- final String[] args =
- { "-c", "src/test/resources/parameters/prodConsNoEPParClass.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/prodConsNoEPParClass.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
fail("This test should throw an exception");
} catch (final ParameterException e) {
assertEquals("error reading parameters from \"src/test/resources/parameters/prodConsNoEPParClass.json\"\n"
- + "(ParameterRuntimeException):event protocol \"SUPER_TOK_DEL\" parameter "
- + "\"parameterClassName\" value \"null\" invalid in JSON file", e.getMessage());
+ + "(ParameterRuntimeException):event protocol \"SUPER_TOK_DEL\" parameter "
+ + "\"parameterClassName\" value \"null\" invalid in JSON file", e.getMessage());
}
}
@Test
public void mismatchEventProtocolParClass() {
- final String[] args =
- { "-c", "src/test/resources/parameters/prodConsMismatchEPParClass.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/prodConsMismatchEPParClass.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
new ApexParameterHandler().getParameters(arguments);
fail("This test should throw an exception");
} catch (final ParameterException e) {
- assertEquals("error reading parameters from "
+ assertEquals(
+ "error reading parameters from "
+ "\"src/test/resources/parameters/prodConsMismatchEPParClass.json\"\n"
+ "(ParameterRuntimeException):event protocol \"SUPER_TOK_BEL\" "
+ "does not match plugin \"SUPER_TOK_DEL\" in "
+ "\"org.onap.policy.apex.service.engine.parameters.dummyclasses."
+ "SuperTokenDelimitedEventProtocolParameters\", "
+ "specify correct event protocol parameter plugin in parameter \"parameterClassName\"",
- e.getMessage());
+ e.getMessage());
}
}
@Test
public void wrongTypeEventProtocolParClass() {
- final String[] args =
- { "-c", "src/test/resources/parameters/prodConsWrongTypeEPParClass.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/prodConsWrongTypeEPParClass.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
fail("This test should throw an exception");
} catch (final ParameterException e) {
assertEquals("error reading parameters from "
- + "\"src/test/resources/parameters/prodConsWrongTypeEPParClass.json\"\n"
- + "(ParameterRuntimeException):could not create default parameters for event protocol "
- + "\"SUPER_TOK_DEL\"\n" + "org.onap.policy.apex.service.engine."
- + "parameters.dummyclasses.SuperDooperCarrierTechnologyParameters "
- + "cannot be cast to org.onap.policy.apex.service."
- + "parameters.eventprotocol.EventProtocolParameters", e.getMessage());
+ + "\"src/test/resources/parameters/prodConsWrongTypeEPParClass.json\"\n"
+ + "(ParameterRuntimeException):could not create default parameters for event protocol "
+ + "\"SUPER_TOK_DEL\"\n" + "org.onap.policy.apex.service.engine."
+ + "parameters.dummyclasses.SuperDooperCarrierTechnologyParameters "
+ + "cannot be cast to org.onap.policy.apex.service."
+ + "parameters.eventprotocol.EventProtocolParameters", e.getMessage());
}
}
}
public class SyncParameterTests {
@Test
public void syncBadNoSyncWithPeer() throws ParameterException {
- final String[] args = { "-c", "src/test/resources/parameters/syncBadParamsNoSyncWithPeer.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/syncBadParamsNoSyncWithPeer.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
@Test
public void syncBadNotSyncWithPeer() throws ParameterException {
- final String[] args = { "-c", "src/test/resources/parameters/syncBadParamsNotSyncWithPeer.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/syncBadParamsNotSyncWithPeer.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
@Test
public void syncBadSyncBadPeers() throws ParameterException {
- final String[] args = { "-c", "src/test/resources/parameters/syncBadParamsBadPeers.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/syncBadParamsBadPeers.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
@Test
public void syncBadSyncInvalidTimeout() throws ParameterException {
- final String[] args = { "-c", "src/test/resources/parameters/syncBadParamsInvalidTimeout.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/syncBadParamsInvalidTimeout.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
@Test
public void syncBadSyncBadTimeout() throws ParameterException {
- final String[] args = { "-c", "src/test/resources/parameters/syncBadParamsBadTimeout.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/syncBadParamsBadTimeout.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
@Test
public void syncBadSyncUnpairedTimeout() throws ParameterException {
- final String[] args = { "-c", "src/test/resources/parameters/syncBadParamsUnpairedTimeout.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/syncBadParamsUnpairedTimeout.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
@Test
public void syncGoodSyncGoodTimeoutProducer() throws ParameterException {
- final String[] args = { "-c", "src/test/resources/parameters/syncGoodParamsProducerTimeout.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/syncGoodParamsProducerTimeout.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
@Test
public void syncGoodSyncGoodTimeoutConsumer() throws ParameterException {
- final String[] args = { "-c", "src/test/resources/parameters/syncGoodParamsConsumerTimeout.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/syncGoodParamsConsumerTimeout.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
@Test
public void syncGoodSyncGoodTimeoutBoth() throws ParameterException {
- final String[] args = { "-c", "src/test/resources/parameters/syncGoodParamsBothTimeout.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/syncGoodParamsBothTimeout.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
@Test
public void syncUnusedConsumerPeers() throws ParameterException {
- final String[] args = { "-c", "src/test/resources/parameters/syncUnusedConsumerPeers.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/syncUnusedConsumerPeers.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
@Test
public void syncMismatchedPeers() throws ParameterException {
- final String[] args = { "-c", "src/test/resources/parameters/syncMismatchedPeers.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/syncMismatchedPeers.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
@Test
public void syncUnusedProducerPeers() throws ParameterException {
- final String[] args = { "-c", "src/test/resources/parameters/syncUnusedProducerPeers.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/syncUnusedProducerPeers.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
@Test
public void syncMismatchedTimeout() throws ParameterException {
- final String[] args = { "-c", "src/test/resources/parameters/syncMismatchedTimeout.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/syncMismatchedTimeout.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
@Test
public void syncGoodParametersTest() {
- final String[] args = { "-c", "src/test/resources/parameters/syncGoodParams.json" };
+ final String[] args = {"-c", "src/test/resources/parameters/syncGoodParams.json"};
final ApexCommandLineArguments arguments = new ApexCommandLineArguments(args);
try {
assertEquals("org.apache.superDooper.common.serialization.StringDeserializer",
superDooperParameters.getValueDeserializer());
- final String[] consumerTopics = { "apex-in" };
+ final String[] consumerTopics = {"apex-in"};
assertEquals(Arrays.asList(consumerTopics), superDooperParameters.getConsumerTopicList());
} catch (final ParameterException e) {
fail("This test should not throw an exception");
* Dummy state finalizer executor for testing.
*/
public class DummyStateFinalizerExecutor extends StateFinalizerExecutor {
- public DummyStateFinalizerExecutor() {}
+ public DummyStateFinalizerExecutor() {
+ // Default constructor
+ }
@Override
public String execute(final long executionId, final Properties executorProperties,
* Dummy task executor for testing.
*/
public class DummyTaskExecutor extends TaskExecutor {
- public DummyTaskExecutor() {}
+ public DummyTaskExecutor() {
+ // Default constructor
+ }
@Override
- public void prepare() throws StateMachineException {}
+ public void prepare() throws StateMachineException {
+ // Not used
+ }
@Override
public Map<String, Object> execute(final long executionId, final Properties executorProperties,
}
@Override
- public void cleanUp() throws StateMachineException {}
+ public void cleanUp() throws StateMachineException {
+ // Not used
+ }
}
* Dummy task selection executor for testing.
*/
public class DummyTaskSelectExecutor extends TaskSelectExecutor {
- public DummyTaskSelectExecutor() {}
+ public DummyTaskSelectExecutor() {
+ }
@Override
- public void prepare() throws StateMachineException {}
+ public void prepare() throws StateMachineException {
+ // Not used
+ }
@Override
public AxArtifactKey execute(final long executionId, final Properties executorProperties,
}
@Override
- public void cleanUp() throws StateMachineException {}
+ public void cleanUp() throws StateMachineException {
+ // Not used
+ }
}
* 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=========================================================
*/
private static final int DEFAULT_SESSION_TIMEOUT = 30000;
private static final String DEFAULT_PRODUCER_TOPIC = "apex-out";
private static final int DEFAULT_CONSUMER_POLL_TIME = 100;
- private static final String[] DEFAULT_CONSUMER_TOPIC_LIST =
- { "apex-in" };
+ private static final String[] DEFAULT_CONSUMER_TOPIC_LIST = {"apex-in"};
private static final String DEFAULT_KEYSERZER = "org.apache.superDooper.common.serialization.StringSerializer";
private static final String DEFAULT_VALSERZER = "org.apache.superDooper.common.serialization.StringSerializer";
private static final String DEFAULT_KEYDESZER = "org.apache.superDooper.common.serialization.StringDeserializer";
// Set the carrier technology properties for the FILE carrier technology
this.setLabel("SUPER_DOOPER");
this.setEventProducerPluginClass(
- "org.onap.policy.apex.service.engine.parameters.dummyclasses.SuperDooperEventProducer");
+ "org.onap.policy.apex.service.engine.parameters.dummyclasses.SuperDooperEventProducer");
this.setEventConsumerPluginClass(
- "org.onap.policy.apex.service.engine.parameters.dummyclasses.SuperDooperEventSubscriber");
+ "org.onap.policy.apex.service.engine.parameters.dummyclasses.SuperDooperEventSubscriber");
}
/**
if (bootstrapServers == null || bootstrapServers.trim().length() == 0) {
result.setResult("bootstrapServers", ValidationStatus.INVALID,
- "bootstrapServers not specified, must be specified as a string of form host:port");
+ "bootstrapServers not specified, must be specified as a string of form host:port");
}
if (acks == null || acks.trim().length() == 0) {
result.setResult("acks", ValidationStatus.INVALID,
- "acks not specified, must be specified as a string with values [0|1|all]");
+ "acks not specified, must be specified as a string with values [0|1|all]");
}
if (retries < 0) {
result.setResult("retries", ValidationStatus.INVALID,
- "[" + retries + "] invalid, must be specified as retries >= 0");
+ "[" + retries + "] invalid, must be specified as retries >= 0");
}
if (batchSize < 0) {
result.setResult("batchSize", ValidationStatus.INVALID,
- "[" + batchSize + "] invalid, must be specified as batchSize >= 0");
+ "[" + batchSize + "] invalid, must be specified as batchSize >= 0");
}
if (lingerTime < 0) {
result.setResult("lingerTime", ValidationStatus.INVALID,
- "[" + lingerTime + "] invalid, must be specified as lingerTime >= 0");
+ "[" + lingerTime + "] invalid, must be specified as lingerTime >= 0");
}
if (bufferMemory < 0) {
result.setResult("bufferMemory", ValidationStatus.INVALID,
- "[" + bufferMemory + "] invalid, must be specified as bufferMemory >= 0");
+ "[" + bufferMemory + "] invalid, must be specified as bufferMemory >= 0");
}
if (groupId == null || groupId.trim().length() == 0) {
if (autoCommitTime < 0) {
result.setResult("autoCommitTime", ValidationStatus.INVALID,
- "[" + autoCommitTime + "] invalid, must be specified as autoCommitTime >= 0");
+ "[" + autoCommitTime + "] invalid, must be specified as autoCommitTime >= 0");
}
if (sessionTimeout < 0) {
- result.setResult("sessionTimeout", ValidationStatus.INVALID, "sessionTimeout [" + sessionTimeout
- + "] invalid, must be specified as sessionTimeout >= 0");
+ result.setResult("sessionTimeout", ValidationStatus.INVALID,
+ "sessionTimeout [" + sessionTimeout + "] invalid, must be specified as sessionTimeout >= 0");
}
if (producerTopic == null || producerTopic.trim().length() == 0) {
result.setResult("producerTopic", ValidationStatus.INVALID,
- "producerTopic not specified, must be specified as a string");
+ "producerTopic not specified, must be specified as a string");
}
if (consumerPollTime < 0) {
result.setResult("consumerPollTime", ValidationStatus.INVALID,
- "[" + consumerPollTime + "] invalid, must be specified as consumerPollTime >= 0");
+ "[" + consumerPollTime + "] invalid, must be specified as consumerPollTime >= 0");
}
if (consumerTopicList == null || consumerTopicList.length == 0) {
result.setResult("consumerTopicList", ValidationStatus.INVALID,
- "not specified, must be specified as a list of strings");
+ "not specified, must be specified as a list of strings");
}
StringBuilder consumerTopicMessageBuilder = new StringBuilder();
for (final String consumerTopic : consumerTopicList) {
if (consumerTopic == null || consumerTopic.trim().length() == 0) {
consumerTopicMessageBuilder.append(" invalid consumer topic \"" + consumerTopic
- + "\" specified on consumerTopicList, consumer topics must be specified as strings");
+ + "\" specified on consumerTopicList, consumer topics must be specified as strings");
}
}
if (valueSerializer == null || valueSerializer.trim().length() == 0) {
result.setResult("valueSerializer", ValidationStatus.INVALID,
- "not specified, must be specified as a string");
+ "not specified, must be specified as a string");
}
if (keyDeserializer == null || keyDeserializer.trim().length() == 0) {
result.setResult("keyDeserializer", ValidationStatus.INVALID,
- "not specified, must be specified as a string");
+ "not specified, must be specified as a string");
}
if (valueDeserializer == null || valueDeserializer.trim().length() == 0) {
result.setResult("valueDeserializer", ValidationStatus.INVALID,
- "not specified, must be specified as a string");
+ "not specified, must be specified as a string");
}
return result;
private String name;
- public SuperDooperEventProducer() {}
+ public SuperDooperEventProducer() {
+ // Default constructor
+ }
/**
* {@inheritDoc}.
* {@inheritDoc}.
*/
@Override
- public void setPeeredReference(final EventHandlerPeeredMode peeredMode, final PeeredReference peeredReference) {}
+ public void setPeeredReference(final EventHandlerPeeredMode peeredMode, final PeeredReference peeredReference) {
+ // Not used
+ }
/**
* {@inheritDoc}.
@Override
public void sendEvent(final long executionId, final Properties executionProperties, final String eventName,
final Object event) {
- LOGGER.info("Sending Event: " + this.getClass().getName() + ":" + this.name + " ... event ("
- + eventName + ") : " + event);
+ LOGGER.info("Sending Event: " + this.getClass().getName() + ":" + this.name + " ... event (" + eventName
+ + ") : " + event);
}
/**
* {@inheritDoc}.
*/
@Override
- public void stop() {}
+ public void stop() {
+ // Not used
+ }
}
@Override
public void init(final String name, final EventHandlerParameters consumerParameters,
- final ApexEventReceiver apexEventReceiver) throws ApexEventException {
+ final ApexEventReceiver apexEventReceiver) throws ApexEventException {
this.name = name;
LOGGER.info("Initialising Apex Consumer: " + this.getClass().getName() + ":" + this.name);
}
@Override
public void start() {
- // TODO Auto-generated method stub
+ // Not used
}
@Override
public void stop() {
+ // Not used
}
}
* 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=========================================================
*/
}
@Override
- public void init(final EventProtocolParameters parameters) {}
+ public void init(final EventProtocolParameters parameters) {
+ // Not used
+ }
}
* 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=========================================================
*/
private static final String SUPER_TOKEN_DELIMITER = "SuperToken";
/**
- * Constructor to create a JSON event protocol parameter instance and register the instance with
- * the parameter service.
+ * Constructor to create a JSON event protocol parameter instance and register the instance with the parameter
+ * service.
*/
public SuperTokenDelimitedEventProtocolParameters() {
super();
import java.util.Map;
import java.util.Properties;
+
import org.onap.policy.apex.context.ContextException;
import org.onap.policy.apex.core.engine.executor.StateFinalizerExecutor;
import org.onap.policy.apex.core.engine.executor.exception.StateMachineException;
* Dummy state finalizer executor for testing.
*/
public class DummyStateFinalizerExecutor extends StateFinalizerExecutor {
- public DummyStateFinalizerExecutor() {}
+ public DummyStateFinalizerExecutor() {
+ // Default constructor
+ }
@Override
public String execute(final long executionId, final Properties executorProperties,
import java.util.Map;
import java.util.Properties;
+
import org.onap.policy.apex.context.ContextException;
import org.onap.policy.apex.core.engine.event.EnEvent;
import org.onap.policy.apex.core.engine.executor.TaskExecutor;
* Dummy task executor for testing.
*/
public class DummyTaskExecutor extends TaskExecutor {
- public DummyTaskExecutor() {}
+ public DummyTaskExecutor() {
+ // Default constructor
+ }
@Override
- public void prepare() throws StateMachineException {}
+ public void prepare() throws StateMachineException {
+ // Not used
+ }
@Override
public Map<String, Object> execute(final long executionId, final Properties executorProperties,
}
@Override
- public void cleanUp() throws StateMachineException {}
+ public void cleanUp() throws StateMachineException {
+ // Not used
+ }
}
package org.onap.policy.apex.services.onappf.parameters.dummyclasses;
import java.util.Properties;
+
import org.onap.policy.apex.context.ContextException;
import org.onap.policy.apex.core.engine.event.EnEvent;
import org.onap.policy.apex.core.engine.executor.TaskSelectExecutor;
* Dummy task selection executor for testing.
*/
public class DummyTaskSelectExecutor extends TaskSelectExecutor {
- public DummyTaskSelectExecutor() {}
+ public DummyTaskSelectExecutor() {
+ }
@Override
- public void prepare() throws StateMachineException {}
+ public void prepare() throws StateMachineException {
+ // Not used
+ }
@Override
public AxArtifactKey execute(final long executionId, final Properties executorProperties,
}
@Override
- public void cleanUp() throws StateMachineException {}
+ public void cleanUp() throws StateMachineException {
+ // Not used
+ }
}
/**
* The Constructor.
*/
- public TestContextBooleanItem() {}
+ public TestContextBooleanItem() {
+ // Default constructor
+ }
/**
* The Constructor.
/**
* The Constructor.
*/
- public TestContextByteItem() {}
+ public TestContextByteItem() {
+ // Default constructor
+ }
/**
* The Constructor.
/**
* The Constructor.
*/
- public TestContextDoubleItem() {}
+ public TestContextDoubleItem() {
+ // Default constructor
+ }
/**
* The Constructor.
/**
* The Constructor.
*/
- public TestContextFloatItem() {}
+ public TestContextFloatItem() {
+ // Default constructor
+ }
/**
* The Constructor.
/**
* The Constructor.
*/
- public TestContextIntItem() {}
+ public TestContextIntItem() {
+ // Default constructor
+ }
/**
* The Constructor.
/**
* The Constructor.
*/
- public TestContextLongItem() {}
+ public TestContextLongItem() {
+ // Default constructor
+ }
/**
* The Constructor.
/**
* The Constructor.
*/
- public TestContextLongObjectItem() {}
+ public TestContextLongObjectItem() {
+ // Default constructor
+ }
/**
* The Constructor.
/**
* The Constructor.
*/
- public TestContextStringItem() {}
+ public TestContextStringItem() {
+ // Default constructor
+ }
/**
* The Constructor.
/**
* The Constructor.
*/
- public TestContextTreeMapItem() {}
+ public TestContextTreeMapItem() {
+ // Default constructor
+ }
/**
* The Constructor.
/**
* The Constructor.
*/
- public TestContextTreeSetItem() {}
+ public TestContextTreeSetItem() {
+ // Default constructor
+ }
/**
* The Constructor.
/**
* Default constructor to prevent sub-classing.
*/
- private TestContextAlbumFactory() {}
+ private TestContextAlbumFactory() {
+ // Private constructor to block subclassing
+ }
/**
* Creates the policy context model.
/**
* Instantiates a new constants.
*/
- private Constants() {}
+ private Constants() {
+ // Private constructor to block subclassing
+ }
/**
* Gets the ax artifact key array.
/**
* Instantiates a new network utils.
*/
- private NetworkUtils() {}
+ private NetworkUtils() {
+ // Private constructor to block subclassing
+ }
/**
- * The JGroups IP address must be set to a real (not loopback) IP address for Infinispan to
- * work. In order to ensure that all the JVMs in a test pick up the same IP address, this
- * function sets the address to be the first non-loopback IPv4 address on a host
+ * The JGroups IP address must be set to a real (not loopback) IP address for Infinispan to work. In order to ensure
+ * that all the JVMs in a test pick up the same IP address, this function sets the address to be the first
+ * non-loopback IPv4 address on a host
*
* @return Set of IPv4 addresses
* @throws SocketException throw socket exception if error occurs
return ipAddressSet;
}
-
}
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=========================================================
-->
-<config xmlns="urn:org:jgroups"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="urn:org:jgroups http://www.jgroups.org/schema/jgroups-4.0.xsd">
- <UDP mcast_addr="${jgroups.udp.mcast_addr:228.6.7.8}"
+<config
+ xmlns="urn:org:jgroups"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="urn:org:jgroups http://www.jgroups.org/schema/jgroups-4.0.xsd">
+ <UDP
+ mcast_addr="${jgroups.udp.mcast_addr:228.6.7.8}"
mcast_port="${jgroups.udp.mcast_port:46655}"
bind_port="${jgroups.udp.mcast.bind_port:63005}"
bind_addr="${jgroups.udp.mcast.bind_addr:127.0.0.1}"
thread_pool.min_threads="${jgroups.thread_pool.min_threads:0}"
thread_pool.max_threads="${jgroups.thread_pool.max_threads:200}"
- thread_pool.keep_alive_time="60000"
- />
- <PING />
- <MERGE3 min_interval="10000"
- max_interval="30000"
- />
- <FD_SOCK />
- <FD_SOCK bind_addr="${jgroups.udp.mcast.bind_addr:127.0.0.1}" sock_conn_timeout="60000" start_port="${jgroups.udp.fd.sock.start_port:63010}" port_range="1000"/>
-
- <FD_ALL timeout="60000"
- interval="15000"
- timeout_check_interval="5000"
- />
- <VERIFY_SUSPECT timeout="5000" />
- <pbcast.NAKACK2 xmit_interval="100"
- xmit_table_num_rows="50"
- xmit_table_msgs_per_row="1024"
- xmit_table_max_compaction_time="30000"
- resend_last_seqno="true"
- />
- <UNICAST3 xmit_interval="100"
- xmit_table_num_rows="50"
- xmit_table_msgs_per_row="1024"
- xmit_table_max_compaction_time="30000"
- conn_expiry_timeout="0"
- />
- <pbcast.STABLE stability_delay="500"
- desired_avg_gossip="5000"
- max_bytes="1M"
- />
- <pbcast.GMS print_local_addr="false"
- install_view_locally_first="true"
- join_timeout="${jgroups.join_timeout:5000}"
- />
- <UFC max_credits="2m"
- min_threshold="0.40"
- />
- <MFC max_credits="2m"
- min_threshold="0.40"
- />
- <FRAG3 frag_size="8000"/>
+ thread_pool.keep_alive_time="60000" />
+ <PING />
+ <MERGE3
+ min_interval="10000"
+ max_interval="30000" />
+ <FD_SOCK />
+ <FD_SOCK
+ bind_addr="${jgroups.udp.mcast.bind_addr:127.0.0.1}"
+ sock_conn_timeout="60000"
+ start_port="${jgroups.udp.fd.sock.start_port:63010}"
+ port_range="1000" />
+
+ <FD_ALL
+ timeout="60000"
+ interval="15000"
+ timeout_check_interval="5000" />
+ <VERIFY_SUSPECT timeout="5000" />
+ <pbcast.NAKACK2
+ xmit_interval="100"
+ xmit_table_num_rows="50"
+ xmit_table_msgs_per_row="1024"
+ xmit_table_max_compaction_time="30000"
+ resend_last_seqno="true" />
+ <UNICAST3
+ xmit_interval="100"
+ xmit_table_num_rows="50"
+ xmit_table_msgs_per_row="1024"
+ xmit_table_max_compaction_time="30000"
+ conn_expiry_timeout="0" />
+ <pbcast.STABLE
+ stability_delay="500"
+ desired_avg_gossip="5000"
+ max_bytes="1M" />
+ <pbcast.GMS
+ print_local_addr="false"
+ install_view_locally_first="true"
+ join_timeout="${jgroups.join_timeout:5000}" />
+ <UFC
+ max_credits="2m"
+ min_threshold="0.40" />
+ <MFC
+ max_credits="2m"
+ min_threshold="0.40" />
+ <FRAG3 frag_size="8000" />
</config>
@Before
public void beforeTest() {
schemaParameters = new SchemaParameters();
-
+
schemaParameters.setName(ContextParameterConstants.SCHEMA_GROUP_NAME);
schemaParameters.getSchemaHelperParameterMap().put("JAVA", new JavaSchemaHelperParameters());
ParameterService.register(schemaParameters);
-
+
contextParameters = new ContextParameters();
contextParameters.setName(ContextParameterConstants.MAIN_GROUP_NAME);
ParameterService.register(contextParameters.getDistributorParameters());
ParameterService.register(contextParameters.getLockManagerParameters());
ParameterService.register(contextParameters.getPersistorParameters());
-
+
engineParameters = new EngineParameters();
engineParameters.getExecutorParameterMap().put("MVEL", new MvelExecutorParameters());
ParameterService.register(engineParameters);
@After
public void afterTest() {
ParameterService.deregister(engineParameters);
-
+
ParameterService.deregister(contextParameters.getDistributorParameters());
ParameterService.deregister(contextParameters.getLockManagerParameters());
ParameterService.deregister(contextParameters.getPersistorParameters());
* Test context update model after.
*/
@After
- public void testContextUpdateModelAfter() {}
+ public void testContextUpdateModelAfter() {
+ // Not used
+ }
/**
* Send event.
* @throws ContextException the context exception
*/
private void sendEvent(final ApexEngine apexEngine, final TestApexActionListener listener, final String eventName,
- final boolean shouldWork) throws ContextException {
+ final boolean shouldWork) throws ContextException {
final Date aDate = new Date(1433453067123L);
final Map<String, Object> eventDataMap = new HashMap<String, Object>();
eventDataMap.put("TestSlogan", "This is a test slogan");
* {@inheritDoc}.
*/
@Override
- public void bind(final Name name, final Object obj) throws NamingException {}
+ public void bind(final Name name, final Object obj) throws NamingException {
+ // Not used here
+ }
/**
* {@inheritDoc}.
*/
@Override
- public void bind(final String name, final Object obj) throws NamingException {}
+ public void bind(final String name, final Object obj) throws NamingException {
+ // Not used here
+ }
/**
* {@inheritDoc}.
*/
@Override
- public void rebind(final Name name, final Object obj) throws NamingException {}
+ public void rebind(final Name name, final Object obj) throws NamingException {
+ // Not used here
+ }
/**
* {@inheritDoc}.
*/
@Override
- public void rebind(final String name, final Object obj) throws NamingException {}
+ public void rebind(final String name, final Object obj) throws NamingException {
+ // Not used here
+ }
/**
* {@inheritDoc}.
*/
@Override
- public void unbind(final Name name) throws NamingException {}
+ public void unbind(final Name name) throws NamingException {
+ // Not used here
+ }
/**
* {@inheritDoc}.
*/
@Override
- public void unbind(final String name) throws NamingException {}
+ public void unbind(final String name) throws NamingException {
+ // Not used here
+ }
/**
* {@inheritDoc}.
*/
@Override
- public void rename(final Name oldName, final Name newName) throws NamingException {}
+ public void rename(final Name oldName, final Name newName) throws NamingException {
+ // Not used here
+ }
/**
* {@inheritDoc}.
*/
@Override
- public void rename(final String oldName, final String newName) throws NamingException {}
+ public void rename(final String oldName, final String newName) throws NamingException {
+ // Not used here
+ }
/**
* {@inheritDoc}.
* {@inheritDoc}.
*/
@Override
- public void destroySubcontext(final Name name) throws NamingException {}
+ public void destroySubcontext(final Name name) throws NamingException {
+ // Not used here
+ }
/**
* {@inheritDoc}.
*/
@Override
- public void destroySubcontext(final String name) throws NamingException {}
+ public void destroySubcontext(final String name) throws NamingException {
+ // Not used here
+ }
/**
* {@inheritDoc}.
* {@inheritDoc}.
*/
@Override
- public void close() throws NamingException {}
+ public void close() throws NamingException {
+ // Not used here
+ }
/**
* {@inheritDoc}.
* 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=========================================================
*/
*
* @throws NamingException the naming exception
*/
- public TestInitialContextFactory() throws NamingException {}
+ public TestInitialContextFactory() throws NamingException {
+ // Default constructor
+ }
/**
* {@inheritDoc}.
throw new ApexEventRuntimeException(message);
}
-
try {
executionProperties.store(new FileOutputStream(new File(dummyProducerProperties.getPropertyFileName())),
"");
* {@inheritDoc}.
*/
@Override
- public void stop() {}
+ public void stop() {
+ // Not used
+ }
}
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=========================================================
-->
<statusListener class="ch.qos.logback.core.status.OnConsoleStatusListener" />
<property name="LOG_DIR" value="${java.io.tmpdir}/apex_logging/" />
- <!-- USE FOR STD OUT ONLY -->
+ <!-- USE FOR STD OUT ONLY -->
<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<Pattern>%d %contextName [%t] %level %logger{36} - %msg%n</Pattern>
/**
* Private constructor to avoid instantiation.
*/
- private SchemaUtils() {}
+ private SchemaUtils() {
+ // Private constructor to block subclassing
+ }
/**
* Returns the schema for an event.
.desc("set the input policy model file").build();
/** A type option defining what type is used for events with "-t" and "--type". */
- public static final Option TYPE = Option.builder("t").hasArg().argName("TYPE").longOpt("type").desc(
- "set the event type for generation, one of: stimuli (trigger events), response (action events),"
- + " internal (events between states)")
+ public static final Option TYPE = Option.builder("t").hasArg().argName("TYPE").longOpt("type")
+ .desc("set the event type for generation, one of: stimuli (trigger events), response (action events),"
+ + " internal (events between states)")
.build();
/** A server option with "-s" and "--server". */
/** A skip validation option with "-sv" and "--skip-validation". */
public static final Option SKIPVALIDATION = Option.builder("sv").longOpt("skip-validation")
.desc("switch of validation of the input file").required(false).type(boolean.class).build();
-
+
/** Private constructor to prevent instantiation. */
- private CliOptions() {}
+ private CliOptions() {
+ // Private constructor to block subclassing
+ }
}
Code Review / policy / apex-pdp.git / commitdiff