summary |
shortlog |
log |
commit | commitdiff |
review |
tree
raw |
patch |
inline | side by side (from parent 1:
4861d87)
Issue-ID: POLICY-3399
Change-Id: I839f67ff02fdabcb4012a340f7a6a7528dc107e5
Signed-off-by: Ram Krishna Verma <ram_krishna.verma@bell.ca>
package org.onap.policy.pap.main.comm;
package org.onap.policy.pap.main.comm;
+import lombok.AllArgsConstructor;
import org.onap.policy.common.endpoints.event.comm.Topic.CommInfrastructure;
import org.onap.policy.common.endpoints.listeners.TypedMessageListener;
import org.onap.policy.models.pdp.concepts.PdpStatus;
import org.onap.policy.common.endpoints.event.comm.Topic.CommInfrastructure;
import org.onap.policy.common.endpoints.listeners.TypedMessageListener;
import org.onap.policy.models.pdp.concepts.PdpStatus;
*
* @author Ram Krishna Verma (ram.krishna.verma@est.tech)
*/
*
* @author Ram Krishna Verma (ram.krishna.verma@est.tech)
*/
public class PdpHeartbeatListener implements TypedMessageListener<PdpStatus> {
private final PdpParameters params;
private final boolean savePdpStatistics;
public class PdpHeartbeatListener implements TypedMessageListener<PdpStatus> {
private final PdpParameters params;
private final boolean savePdpStatistics;
- /**
- * Constructs the object.
- *
- * @param params PDP parameters
- */
- public PdpHeartbeatListener(PdpParameters params, boolean savePdpStatistics) {
- this.params = params;
- this.savePdpStatistics = savePdpStatistics;
- }
-
@Override
public void onTopicEvent(final CommInfrastructure infra, final String topic, final PdpStatus message) {
@Override
public void onTopicEvent(final CommInfrastructure infra, final String topic, final PdpStatus message) {
package org.onap.policy.pap.main.notification;
import java.util.Set;
package org.onap.policy.pap.main.notification;
import java.util.Set;
+import lombok.AllArgsConstructor;
import org.onap.policy.models.base.PfModelException;
import org.onap.policy.models.pap.concepts.PolicyNotification;
import org.onap.policy.models.provider.PolicyModelsProvider;
import org.onap.policy.models.base.PfModelException;
import org.onap.policy.models.pap.concepts.PolicyNotification;
import org.onap.policy.models.provider.PolicyModelsProvider;
/**
* Notifier for completion of policy updates.
*/
/**
* Notifier for completion of policy updates.
*/
public class PolicyNotifier {
private static final Logger logger = LoggerFactory.getLogger(PolicyNotifier.class);
public class PolicyNotifier {
private static final Logger logger = LoggerFactory.getLogger(PolicyNotifier.class);
private final PolicyModelsProviderFactoryWrapper daoFactory;
private final PolicyModelsProviderFactoryWrapper daoFactory;
-
- /**
- * Constructs the object. Loads all deployed policies into the internal cache.
- *
- * @param publisher notification publisher
- * @param daoFactory factory used to load policy deployment data from the DB
- */
- public PolicyNotifier(Publisher<PolicyNotification> publisher, PolicyModelsProviderFactoryWrapper daoFactory) {
-
- this.publisher = publisher;
- this.daoFactory = daoFactory;
- }
-
/**
* Processes a response from a PDP.
*
/**
* Processes a response from a PDP.
*
*
* @author Ram Krishna Verma (ram.krishna.verma@est.tech)
*/
*
* @author Ram Krishna Verma (ram.krishna.verma@est.tech)
*/
@ToString
public class StatisticsReport {
@ToString
public class StatisticsReport {
private long totalPdpCount;
private long totalPdpCount;
private long totalPdpGroupCount;
private long totalPdpGroupCount;
private long totalPolicyDeployCount;
private long totalPolicyDeployCount;
private long policyDeploySuccessCount;
private long policyDeploySuccessCount;
private long policyDeployFailureCount;
private long policyDeployFailureCount;
private long totalPolicyDownloadCount;
private long totalPolicyDownloadCount;
private long policyDownloadSuccessCount;
private long policyDownloadSuccessCount;
private long policyDownloadFailureCount;
}
private long policyDownloadFailureCount;
}