|
1 | 1 | package io.quarkus.hibernate.reactive.runtime;
|
2 | 2 |
|
3 |
| -import java.lang.annotation.Annotation; |
4 | 3 | import java.util.Collections;
|
5 | 4 | import java.util.HashMap;
|
6 | 5 | import java.util.HashSet;
|
|
9 | 8 | import java.util.Optional;
|
10 | 9 | import java.util.Set;
|
11 | 10 |
|
12 |
| -import io.quarkus.reactive.datasource.runtime.ReactiveDataSourceUtil; |
13 | 11 | import jakarta.persistence.EntityManagerFactory;
|
14 | 12 | import jakarta.persistence.PersistenceException;
|
15 | 13 | import jakarta.persistence.spi.PersistenceProvider;
|
|
33 | 31 | import io.quarkus.arc.ClientProxy;
|
34 | 32 | import io.quarkus.arc.InjectableInstance;
|
35 | 33 | import io.quarkus.arc.InstanceHandle;
|
36 |
| -import io.quarkus.datasource.common.runtime.DataSourceUtil; |
37 | 34 | import io.quarkus.hibernate.orm.runtime.BuildTimeSettings;
|
38 | 35 | import io.quarkus.hibernate.orm.runtime.FastBootHibernatePersistenceProvider;
|
39 | 36 | import io.quarkus.hibernate.orm.runtime.HibernateOrmRuntimeConfig;
|
|
52 | 49 | import io.quarkus.hibernate.reactive.runtime.boot.registry.PreconfiguredReactiveServiceRegistryBuilder;
|
53 | 50 | import io.quarkus.hibernate.reactive.runtime.customized.QuarkusReactiveConnectionPoolInitiator;
|
54 | 51 | import io.quarkus.hibernate.reactive.runtime.customized.VertxInstanceInitiator;
|
55 |
| -import io.quarkus.reactive.datasource.ReactiveDataSource; |
| 52 | +import io.quarkus.reactive.datasource.runtime.ReactiveDataSourceUtil; |
56 | 53 | import io.vertx.core.Vertx;
|
57 | 54 | import io.vertx.sqlclient.Pool;
|
58 | 55 |
|
@@ -234,7 +231,7 @@ private StandardServiceRegistry rewireMetadataAndExtractServiceRegistry(String p
|
234 | 231 | persistenceUnitName, recordedState, puConfig);
|
235 | 232 |
|
236 | 233 | Optional<String> dataSourceName = recordedState.getBuildTimeSettings().getSource().getDataSource();
|
237 |
| - if(dataSourceName.isPresent()) { |
| 234 | + if (dataSourceName.isPresent()) { |
238 | 235 | registerVertxAndPool(persistenceUnitName, runtimeSettings, serviceRegistryBuilder, dataSourceName.get());
|
239 | 236 | }
|
240 | 237 |
|
|
0 commit comments