File tree Expand file tree Collapse file tree 2 files changed +8
-3
lines changed
hibernate-reactive-core/src/test/java/org/hibernate/reactive Expand file tree Collapse file tree 2 files changed +8
-3
lines changed Original file line number Diff line number Diff line change 46
46
import jakarta .persistence .Table ;
47
47
48
48
import static org .hibernate .cfg .AvailableSettings .SHOW_SQL ;
49
+ import static org .hibernate .reactive .BaseReactiveTest .setDefaultProperties ;
50
+ import static org .hibernate .reactive .provider .Settings .POOL_CONNECT_TIMEOUT ;
49
51
50
52
/**
51
53
* This is a multi-threaded stress test, intentionally consuming some time.
@@ -95,10 +97,10 @@ public static void setupSessionFactory() {
95
97
vertxOptions .setBlockedThreadCheckIntervalUnit ( TimeUnit .MINUTES );
96
98
vertx = Vertx .vertx ( vertxOptions );
97
99
Configuration configuration = new Configuration ();
100
+ setDefaultProperties ( configuration );
98
101
configuration .addAnnotatedClass ( EntityWithGeneratedId .class );
99
- BaseReactiveTest .setDefaultProperties ( configuration );
100
102
configuration .setProperty ( SHOW_SQL , String .valueOf ( LOG_SQL ) );
101
- BaseReactiveTest . setDefaultProperties ( configuration );
103
+ configuration . setProperty ( POOL_CONNECT_TIMEOUT , String . valueOf ( TIMEOUT_MINUTES * 60 * 1000 ) );
102
104
StandardServiceRegistryBuilder builder = new ReactiveServiceRegistryBuilder ()
103
105
.applySettings ( configuration .getProperties () )
104
106
//Inject our custom vert.x instance:
Original file line number Diff line number Diff line change 36
36
import jakarta .persistence .Table ;
37
37
38
38
import static org .hibernate .cfg .AvailableSettings .SHOW_SQL ;
39
+ import static org .hibernate .reactive .BaseReactiveTest .setDefaultProperties ;
40
+ import static org .hibernate .reactive .provider .Settings .POOL_CONNECT_TIMEOUT ;
39
41
import static org .hibernate .reactive .util .impl .CompletionStages .loop ;
40
42
41
43
/**
@@ -101,9 +103,10 @@ public static void setupSessionFactory() {
101
103
vertxOptions .setBlockedThreadCheckIntervalUnit ( TimeUnit .MINUTES );
102
104
vertx = Vertx .vertx ( vertxOptions );
103
105
Configuration configuration = new Configuration ();
106
+ setDefaultProperties ( configuration );
104
107
configuration .addAnnotatedClass ( EntityWithGeneratedId .class );
105
- BaseReactiveTest .setDefaultProperties ( configuration );
106
108
configuration .setProperty ( SHOW_SQL , String .valueOf ( LOG_SQL ) );
109
+ configuration .setProperty ( POOL_CONNECT_TIMEOUT , String .valueOf ( TIMEOUT_MINUTES * 60 * 1000 ) );
107
110
StandardServiceRegistryBuilder builder = new ReactiveServiceRegistryBuilder ()
108
111
.applySettings ( configuration .getProperties () )
109
112
//Inject our custom vert.x instance:
You can’t perform that action at this time.
0 commit comments