* ============LICENSE_START=======================================================
* Copyright (C) 2018 Ericsson. All rights reserved.
* Modifications Copyright (C) 2021 AT&T Intellectual Property. All rights reserved.
+ * Modifications Copyright (C) 2021 Bell Canada. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
package org.onap.policy.distribution.main.rest;
+import lombok.Getter;
+import lombok.Setter;
+import lombok.ToString;
+
/**
* Class to represent statistics report of distribution service.
*
* @author Ram Krishna Verma (ram.krishna.verma@ericsson.com)
*/
+@ToString
+@Getter
+@Setter
public class StatisticsReport {
private int code;
private long totalDownloadCount;
private long downloadSuccessCount;
private long downloadFailureCount;
-
- /**
- * Returns the code of this {@link StatisticsReport} instance.
- *
- * @return the code
- */
- public int getCode() {
- return code;
- }
-
- /**
- * Set code in this {@link StatisticsReport} instance.
- *
- * @param code the code to set
- */
- public void setCode(final int code) {
- this.code = code;
- }
-
- /**
- * Returns the totalDistributionCount of this {@link StatisticsReport} instance.
- *
- * @return the totalDistributionCount
- */
- public long getTotalDistributionCount() {
- return totalDistributionCount;
- }
-
- /**
- * Set totalDistributionCount in this {@link StatisticsReport} instance.
- *
- * @param totalDistributionCount the totalDistributionCount to set
- */
- public void setTotalDistributionCount(final long totalDistributionCount) {
- this.totalDistributionCount = totalDistributionCount;
- }
-
- /**
- * Returns the distributionSuccessCount of this {@link StatisticsReport} instance.
- *
- * @return the distributionSuccessCount
- */
- public long getDistributionSuccessCount() {
- return distributionSuccessCount;
- }
-
- /**
- * Set distributionSuccessCount in this {@link StatisticsReport} instance.
- *
- * @param distributionSuccessCount the distributionSuccessCount to set
- */
- public void setDistributionSuccessCount(final long distributionSuccessCount) {
- this.distributionSuccessCount = distributionSuccessCount;
- }
-
- /**
- * Returns the distributionFailureCount of this {@link StatisticsReport} instance.
- *
- * @return the distributionFailureCount
- */
- public long getDistributionFailureCount() {
- return distributionFailureCount;
- }
-
- /**
- * Set distributionFailureCount in this {@link StatisticsReport} instance.
- *
- * @param distributionFailureCount the distributionFailureCount to set
- */
- public void setDistributionFailureCount(final long distributionFailureCount) {
- this.distributionFailureCount = distributionFailureCount;
- }
-
- /**
- * Returns the totalDownloadCount of this {@link StatisticsReport} instance.
- *
- * @return the totalDownloadCount
- */
- public long getTotalDownloadCount() {
- return totalDownloadCount;
- }
-
- /**
- * Set totalDownloadCount in this {@link StatisticsReport} instance.
- *
- * @param totalDownloadCount the totalDownloadCount to set
- */
- public void setTotalDownloadCount(final long totalDownloadCount) {
- this.totalDownloadCount = totalDownloadCount;
- }
-
- /**
- * Returns the downloadSuccessCount of this {@link StatisticsReport} instance.
- *
- * @return the downloadSuccessCount
- */
- public long getDownloadSuccessCount() {
- return downloadSuccessCount;
- }
-
- /**
- * Set downloadSuccessCount in this {@link StatisticsReport} instance.
- *
- * @param downloadSuccessCount the downloadSuccessCount to set
- */
- public void setDownloadSuccessCount(final long downloadSuccessCount) {
- this.downloadSuccessCount = downloadSuccessCount;
- }
-
- /**
- * Returns the downloadFailureCount of this {@link StatisticsReport} instance.
- *
- * @return the downloadFailureCount
- */
- public long getDownloadFailureCount() {
- return downloadFailureCount;
- }
-
- /**
- * Set downloadFailureCount in this {@link StatisticsReport} instance.
- *
- * @param downloadFailureCount the downloadFailureCount to set
- */
- public void setDownloadFailureCount(final long downloadFailureCount) {
- this.downloadFailureCount = downloadFailureCount;
- }
-
-
- /**
- * {@inheritDoc}.
- */
- @Override
- public String toString() {
- final var builder = new StringBuilder();
- builder.append("StatisticsReport [code=");
- builder.append(getCode());
- builder.append(", totalDistributionCount=");
- builder.append(getTotalDistributionCount());
- builder.append(", distributionSuccessCount=");
- builder.append(getDistributionSuccessCount());
- builder.append(", distributionFailureCount=");
- builder.append(getDistributionFailureCount());
- builder.append(", totalDownloadCount=");
- builder.append(getTotalDownloadCount());
- builder.append(", downloadSuccessCount=");
- builder.append(getDownloadSuccessCount());
- builder.append(", downloadFailureCount=");
- builder.append(getDownloadFailureCount());
- builder.append("]");
- return builder.toString();
- }
}
* Copyright (C) 2018 Ericsson. All rights reserved.
* Copyright (C) 2019 Nordix Foundation.
* Modifications Copyright (C) 2019-2020 AT&T Intellectual Property. All rights reserved.
+ * Modifications Copyright (C) 2021 Bell Canada. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
import java.util.HashMap;
import java.util.Map;
import java.util.Map.Entry;
+import lombok.Getter;
+import lombok.Setter;
import org.onap.policy.common.endpoints.http.server.RestServer;
import org.onap.policy.common.parameters.ParameterService;
import org.onap.policy.distribution.main.PolicyDistributionException;
private static final Logger LOGGER = LoggerFactory.getLogger(DistributionActivator.class);
// The parameters of this policy distribution activator
+ @Getter
private final DistributionParameterGroup distributionParameterGroup;
// The map of reception handlers initialized by this distribution activator
private final Map<String, AbstractReceptionHandler> receptionHandlersMap = new HashMap<>();
+ @Getter
+ @Setter
private static boolean alive = false;
private RestServer restServer;
}
}
- /**
- * Get the parameters used by the activator.
- *
- * @return the parameters of the activator
- */
- public DistributionParameterGroup getParameterGroup() {
- return distributionParameterGroup;
- }
-
/**
* Method to register the parameters to Common Parameter Service.
*
}
//@formatter:on
}
-
- /**
- * Returns the alive status of distribution service.
- *
- * @return the alive
- */
- public static boolean isAlive() {
- return alive;
- }
-
- /**
- * Change the alive status of distribution service.
- *
- * @param status the status
- */
- public static void setAlive(final boolean status) {
- alive = status;
- }
}
* Copyright (C) 2018 Ericsson. All rights reserved.
* Copyright (C) 2019 Nordix Foundation.
* Modifications Copyright (C) 2020-2021 AT&T Intellectual Property. All rights reserved.
- * Modifications Copyright (C) 2020 Bell Canada. All rights reserved.
+ * Modifications Copyright (C) 2020-2021 Bell Canada. All rights reserved.
* Modifications Copyright (C) 2021 Nordix Foundation.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
package org.onap.policy.distribution.main.startstop;
import java.util.Arrays;
+import lombok.Getter;
import org.onap.policy.common.utils.cmd.CommandLineException;
import org.onap.policy.common.utils.resources.MessageConstants;
import org.onap.policy.distribution.main.PolicyDistributionException;
private DistributionActivator activator;
// The parameters read in from JSON
- private DistributionParameterGroup parameterGroup;
+ @Getter
+ private DistributionParameterGroup distributionParameterGroup;
/**
* Instantiates the policy distribution service.
arguments.validate();
// Read the parameters
- parameterGroup = new DistributionParameterHandler().getParameters(arguments);
+ distributionParameterGroup = new DistributionParameterHandler().getParameters(arguments);
// Now, create the activator for the policy distribution service
- activator = new DistributionActivator(parameterGroup);
+ activator = new DistributionActivator(distributionParameterGroup);
// Start the activator
activator.initialize();
LOGGER.info(successMsg);
}
- /**
- * Get the parameters specified in JSON.
- *
- * @return the parameters
- */
- public DistributionParameterGroup getParameters() {
- return parameterGroup;
- }
-
/**
* Shut down Execution.
*
*/
public void shutdown() throws PolicyDistributionException {
// clear the parameterGroup variable
- parameterGroup = null;
+ distributionParameterGroup = null;
// clear the distribution activator
if (activator != null) {
* ============LICENSE_START=======================================================
* Copyright (C) 2018 Ericsson. All rights reserved.
* Modifications Copyright (C) 2020-2021 AT&T Intellectual Property. All rights reserved.
+ * Modifications Copyright (C) 2021 Bell Canada. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
final DistributionActivator activator = new DistributionActivator(parGroup);
activator.initialize();
- assertTrue(activator.getParameterGroup().isValid());
+ assertTrue(activator.getDistributionParameterGroup().isValid());
assertTrue(DistributionActivator.isAlive());
- assertEquals(CommonTestData.DISTRIBUTION_GROUP_NAME, activator.getParameterGroup().getName());
+ assertEquals(CommonTestData.DISTRIBUTION_GROUP_NAME, activator.getDistributionParameterGroup().getName());
assertEquals(CommonTestData.RECEPTION_HANDLER_TYPE,
- activator.getParameterGroup().getReceptionHandlerParameters()
+ activator.getDistributionParameterGroup().getReceptionHandlerParameters()
.get(CommonTestData.DUMMY_RECEPTION_HANDLER_KEY).getReceptionHandlerType());
assertEquals(CommonTestData.DECODER_TYPE,
- activator.getParameterGroup().getReceptionHandlerParameters()
+ activator.getDistributionParameterGroup().getReceptionHandlerParameters()
.get(CommonTestData.DUMMY_RECEPTION_HANDLER_KEY).getPluginHandlerParameters()
.getPolicyDecoders().get(CommonTestData.DUMMY_DECODER_KEY).getDecoderType());
assertEquals(CommonTestData.FORWARDER_TYPE,
- activator.getParameterGroup().getReceptionHandlerParameters()
+ activator.getDistributionParameterGroup().getReceptionHandlerParameters()
.get(CommonTestData.DUMMY_RECEPTION_HANDLER_KEY).getPluginHandlerParameters()
.getPolicyForwarders().get(CommonTestData.DUMMY_ENGINE_FORWARDER_KEY).getForwarderType());
assertEquals(DummyPolicyForwarderParameterGroup.class,
- activator.getParameterGroup().getPolicyForwarderConfigurationParameters()
+ activator.getDistributionParameterGroup().getPolicyForwarderConfigurationParameters()
.get(CommonTestData.FORWARDER_CONFIGURATION_PARAMETERS).getClass());
activator.terminate();
assertFalse(DistributionActivator.isAlive());
* Copyright (C) 2018 Ericsson. All rights reserved.
* Modifications Copyright (C) 2020-2021 AT&T Inc.
* Modifications Copyright (C) 2020 Bell Canada. All rights reserved.
+ * Modifications Copyright (C) 2021 Bell Canada. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
CommonTestData.makeConfigFile("parameters/DistributionConfigParameters.json");
final String[] distributionConfigParameters = { "-c", CommonTestData.CONFIG_FILE };
final Main main = new Main(distributionConfigParameters);
- assertTrue(main.getParameters().isValid());
- assertEquals(CommonTestData.DISTRIBUTION_GROUP_NAME, main.getParameters().getName());
+ assertTrue(main.getDistributionParameterGroup().isValid());
+ assertEquals(CommonTestData.DISTRIBUTION_GROUP_NAME, main.getDistributionParameterGroup().getName());
main.shutdown();
}
Code Review / policy / distribution.git / commitdiff