import org.junit.Test;
import org.mockito.Mock;
import org.mockito.MockitoAnnotations;
-import org.onap.policy.controlloop.actorserviceprovider.Operation;
import org.onap.policy.controlloop.actorserviceprovider.Util;
import org.onap.policy.controlloop.actorserviceprovider.parameters.BidirectionalTopicConfig;
import org.onap.policy.controlloop.actorserviceprovider.parameters.BidirectionalTopicParams;
AtomicReference<BidirectionalTopicConfig> configRef = new AtomicReference<>();
// @formatter:off
- @SuppressWarnings("rawtypes")
- OperationMaker<BidirectionalTopicConfig, BidirectionalTopicOperation> maker =
+ OperationMaker<BidirectionalTopicConfig, BidirectionalTopicOperation<?, ?>> maker =
(params, config) -> {
paramsRef.set(params);
configRef.set(config);
ControlLoopOperationParams params2 = ControlLoopOperationParams.builder().build();
- // not running yet
- assertThatIllegalStateException().isThrownBy(() -> oper2.buildOperation(params2));
-
// configure and start it
params = BidirectionalTopicParams.builder().sourceTopic(MY_SOURCE).sinkTopic(MY_SINK).timeoutSec(TIMEOUT_SEC)
.build();
oper2.configure(Util.translateToMap(OPERATION, params));
+
+ // not running yet
+ assertThatIllegalStateException().isThrownBy(() -> oper2.buildOperation(params2));
+
oper2.start();
assertSame(operation, oper2.buildOperation(params2));
}
@Override
- public Operation buildOperation(ControlLoopOperationParams params) {
+ public BidirectionalTopicOperation<?, ?> buildOperation(ControlLoopOperationParams params) {
return null;
}
}