|
17 | 17 | import org.hibernate.internal.SessionCreationOptions;
|
18 | 18 | import org.hibernate.internal.SessionFactoryImpl;
|
19 | 19 | import org.hibernate.reactive.common.spi.Implementor;
|
20 |
| -import org.hibernate.reactive.common.spi.StageImplementor; |
21 | 20 | import org.hibernate.reactive.context.Context;
|
22 | 21 | import org.hibernate.reactive.context.impl.BaseKey;
|
23 | 22 | import org.hibernate.reactive.context.impl.MultitenantKey;
|
|
38 | 37 | * <p>
|
39 | 38 | * Obtained by calling {@link org.hibernate.SessionFactory#unwrap(Class)}.
|
40 | 39 | */
|
41 |
| -public class StageSessionFactoryImpl implements Stage.SessionFactory, Implementor, StageImplementor { |
| 40 | +public class StageSessionFactoryImpl implements Stage.SessionFactory, Implementor { |
42 | 41 |
|
43 | 42 | private final SessionFactoryImpl delegate;
|
44 | 43 | private final ReactiveConnectionPool connectionPool;
|
@@ -73,40 +72,6 @@ public Context getContext() {
|
73 | 72 | return context;
|
74 | 73 | }
|
75 | 74 |
|
76 |
| - @Override |
77 |
| - public Stage.Session newSession() { |
78 |
| - SessionCreationOptions options = options(); |
79 |
| - return new StageSessionImpl( |
80 |
| - new ReactiveSessionImpl( delegate, options, proxyConnection( options.getTenantIdentifier() ) ), |
81 |
| - this |
82 |
| - ); |
83 |
| - } |
84 |
| - |
85 |
| - @Override |
86 |
| - public Stage.Session newSession(String tenantId) { |
87 |
| - return new StageSessionImpl( |
88 |
| - new ReactiveSessionImpl( delegate, options( tenantId ), proxyConnection( tenantId ) ), |
89 |
| - this |
90 |
| - ); |
91 |
| - } |
92 |
| - |
93 |
| - @Override |
94 |
| - public Stage.StatelessSession newStatelessSession() { |
95 |
| - SessionCreationOptions options = options(); |
96 |
| - return new StageStatelessSessionImpl( |
97 |
| - new ReactiveStatelessSessionImpl( delegate, options, proxyConnection( options.getTenantIdentifier() ) ), |
98 |
| - this |
99 |
| - ); |
100 |
| - } |
101 |
| - |
102 |
| - @Override |
103 |
| - public Stage.StatelessSession newStatelessSession(String tenantId) { |
104 |
| - return new StageStatelessSessionImpl( |
105 |
| - new ReactiveStatelessSessionImpl( delegate, options( tenantId ), proxyConnection( tenantId ) ), |
106 |
| - this |
107 |
| - ); |
108 |
| - } |
109 |
| - |
110 | 75 | @Override
|
111 | 76 | public CompletionStage<Stage.Session> openSession() {
|
112 | 77 | SessionCreationOptions options = options();
|
|
0 commit comments