/*- * ============LICENSE_START======================================================= * ONAP * ================================================================================ * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved. * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * ============LICENSE_END========================================================= */ package org.onap.policy.controlloop.actorserviceprovider.impl; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import java.util.function.Function; import org.apache.commons.lang3.tuple.Pair; import org.onap.policy.common.endpoints.event.comm.client.BidirectionalTopicClientException; import org.onap.policy.controlloop.actorserviceprovider.Util; import org.onap.policy.controlloop.actorserviceprovider.parameters.BidirectionalTopicActorParams; import org.onap.policy.controlloop.actorserviceprovider.parameters.BidirectionalTopicParams; import org.onap.policy.controlloop.actorserviceprovider.topic.BidirectionalTopicHandler; import org.onap.policy.controlloop.actorserviceprovider.topic.BidirectionalTopicManager; /** * Actor that uses a bidirectional topic. The actor's operator parameters are expected to * be an {@link BidirectionalTopicParams}. * * @param
type of parameters */ public class BidirectionalTopicActor
extends ActorImpl implements BidirectionalTopicManager { /** * Class of parameters. */ private final Class
paramsClass;
/**
* Maps a pair of sink and source topic names to their bidirectional topic.
*/
private final Map paramsClass) {
super(name);
this.paramsClass = paramsClass;
}
@Override
protected void doStart() {
params2topic.values().forEach(BidirectionalTopicHandler::start);
super.doStart();
}
@Override
protected void doStop() {
params2topic.values().forEach(BidirectionalTopicHandler::stop);
super.doStop();
}
@Override
protected void doShutdown() {
params2topic.values().forEach(BidirectionalTopicHandler::shutdown);
params2topic.clear();
super.doShutdown();
}
@Override
public BidirectionalTopicHandler getTopicHandler(String sinkTopic, String sourceTopic) {
Pair