- .expectNext(sdnrOnapA1ClientMock) //
- .verifyComplete();
-
- assertEquals(A1ProtocolType.SDNR_ONAP, ric.getProtocolVersion(), "Not correct protocol");
- }
-
- @Test
- public void createWithNoProtocol_error() {
- whenGetProtocolVersionSdnrOnapA1ClientThrowException();
- whenGetProtocolVersionSdncOscA1ClientThrowException();
- whenGetProtocolVersionOscA1ClientThrowException();
- whenGetProtocolVersionStdA1ClientThrowException();
-
- final ListAppender<ILoggingEvent> logAppender = LoggingUtils.getLogListAppender(A1ClientFactory.class);
- StepVerifier.create(factoryUnderTest.createA1Client(ric)) //
- .expectSubscription() //
- .expectErrorMatches(
- throwable -> throwable instanceof Exception && throwable.getMessage().equals(EXCEPTION_MESSAGE))