- private Mono<A1Client> createA1Client(Ric ric, A1ProtocolType version) {
- if (version == A1ProtocolType.STD_V1) {
- return Mono.just(createStdA1ClientImpl(ric));
+ A1Client createClient(Ric ric, A1ProtocolType version) {
+ if (version == A1ProtocolType.STD_V1_1) {
+ return new StdA1ClientVersion1(ric.getConfig());
+ } else if (version == A1ProtocolType.OSC_V1) {
+ return new OscA1Client(ric.getConfig());
+ } else if (version == A1ProtocolType.SDNC_OSC) {
+ return new SdncOscA1Client(ric.getConfig(), appConfig.getA1ControllerBaseUrl(),
+ appConfig.getA1ControllerUsername(), appConfig.getA1ControllerPassword());
+ } else if (version == A1ProtocolType.SDNC_ONAP) {
+ return new SdncOnapA1Client(ric.getConfig(), appConfig.getA1ControllerBaseUrl(),
+ appConfig.getA1ControllerUsername(), appConfig.getA1ControllerPassword());
+ } else {
+ logger.error("Unhandled protocol: {}", version);
+ return null;