@Test
public void rejectConnectionWithEmptySourceAddress() {

    final Connection connection =
            ConnectivityModelFactory.newConnectionBuilder(CONNECTION_ID,
                    ConnectionType.AMQP_10, ConnectivityStatus.OPEN, "amqp://localhost:5671")
                    .sources(singletonList(
                            ConnectivityModelFactory.newSourceBuilder()
                                    .authorizationContext(Authorization.AUTHORIZATION_CONTEXT)
                                    .address("")
                                    .consumerCount(1)
                                    .index(0)
                                    .build()))
                    .build();
    final ConnectionValidator underTest = getConnectionValidator();
    assertThatExceptionOfType(ConnectionConfigurationInvalidException.class)
            .isThrownBy(() -> underTest.validate(connection, DittoHeaders.empty(), actorSystem));
}