@@ -110,10 +110,6 @@ public ReactiveMongoTransactionManager(ReactiveMongoDatabaseFactory databaseFact
110
110
this .options = options ;
111
111
}
112
112
113
- /*
114
- * (non-Javadoc)
115
- * @see org.springframework.transaction.reactive.AbstractReactiveTransactionManager#doGetTransaction(org.springframework.transaction.reactive.TransactionSynchronizationManager)
116
- */
117
113
@ Override
118
114
protected Object doGetTransaction (TransactionSynchronizationManager synchronizationManager )
119
115
throws TransactionException {
@@ -123,19 +119,11 @@ protected Object doGetTransaction(TransactionSynchronizationManager synchronizat
123
119
return new ReactiveMongoTransactionObject (resourceHolder );
124
120
}
125
121
126
- /*
127
- * (non-Javadoc)
128
- * @see org.springframework.transaction.reactive.AbstractReactiveTransactionManager#isExistingTransaction(java.lang.Object)
129
- */
130
122
@ Override
131
123
protected boolean isExistingTransaction (Object transaction ) throws TransactionException {
132
124
return extractMongoTransaction (transaction ).hasResourceHolder ();
133
125
}
134
126
135
- /*
136
- * (non-Javadoc)
137
- * @see org.springframework.transaction.reactive.AbstractReactiveTransactionManager#doBegin(org.springframework.transaction.reactive.TransactionSynchronizationManager, java.lang.Object, org.springframework.transaction.TransactionDefinition)
138
- */
139
127
@ Override
140
128
protected Mono <Void > doBegin (TransactionSynchronizationManager synchronizationManager , Object transaction ,
141
129
TransactionDefinition definition ) throws TransactionException {
@@ -175,10 +163,6 @@ protected Mono<Void> doBegin(TransactionSynchronizationManager synchronizationMa
175
163
});
176
164
}
177
165
178
- /*
179
- * (non-Javadoc)
180
- * @see org.springframework.transaction.reactive.AbstractReactiveTransactionManager#doSuspend(org.springframework.transaction.reactive.TransactionSynchronizationManager, java.lang.Object)
181
- */
182
166
@ Override
183
167
protected Mono <Object > doSuspend (TransactionSynchronizationManager synchronizationManager , Object transaction )
184
168
throws TransactionException {
@@ -192,21 +176,13 @@ protected Mono<Object> doSuspend(TransactionSynchronizationManager synchronizati
192
176
});
193
177
}
194
178
195
- /*
196
- * (non-Javadoc)
197
- * @see org.springframework.transaction.reactive.AbstractReactiveTransactionManager#doResume(org.springframework.transaction.reactive.TransactionSynchronizationManager, java.lang.Object, java.lang.Object)
198
- */
199
179
@ Override
200
180
protected Mono <Void > doResume (TransactionSynchronizationManager synchronizationManager , @ Nullable Object transaction ,
201
181
Object suspendedResources ) {
202
182
return Mono
203
183
.fromRunnable (() -> synchronizationManager .bindResource (getRequiredDatabaseFactory (), suspendedResources ));
204
184
}
205
185
206
- /*
207
- * (non-Javadoc)
208
- * @see org.springframework.transaction.reactive.AbstractReactiveTransactionManager#doCommit(org.springframework.transaction.reactive.TransactionSynchronizationManager, org.springframework.transaction.reactive.GenericReactiveTransaction)
209
- */
210
186
@ Override
211
187
protected final Mono <Void > doCommit (TransactionSynchronizationManager synchronizationManager ,
212
188
GenericReactiveTransaction status ) throws TransactionException {
@@ -243,10 +219,6 @@ protected Mono<Void> doCommit(TransactionSynchronizationManager synchronizationM
243
219
return transactionObject .commitTransaction ();
244
220
}
245
221
246
- /*
247
- * (non-Javadoc)
248
- * @see org.springframework.transaction.reactive.AbstractReactiveTransactionManager#doRollback(org.springframework.transaction.reactive.TransactionSynchronizationManager, org.springframework.transaction.reactive.GenericReactiveTransaction)
249
- */
250
222
@ Override
251
223
protected Mono <Void > doRollback (TransactionSynchronizationManager synchronizationManager ,
252
224
GenericReactiveTransaction status ) {
@@ -268,10 +240,6 @@ protected Mono<Void> doRollback(TransactionSynchronizationManager synchronizatio
268
240
});
269
241
}
270
242
271
- /*
272
- * (non-Javadoc)
273
- * @see org.springframework.transaction.reactive.AbstractReactiveTransactionManager#doSetRollbackOnly(org.springframework.transaction.reactive.TransactionSynchronizationManager, org.springframework.transaction.reactive.GenericReactiveTransaction)
274
- */
275
243
@ Override
276
244
protected Mono <Void > doSetRollbackOnly (TransactionSynchronizationManager synchronizationManager ,
277
245
GenericReactiveTransaction status ) throws TransactionException {
@@ -282,10 +250,6 @@ protected Mono<Void> doSetRollbackOnly(TransactionSynchronizationManager synchro
282
250
});
283
251
}
284
252
285
- /*
286
- * (non-Javadoc)
287
- * @see org.springframework.transaction.reactive.AbstractReactiveTransactionManager#doCleanupAfterCompletion(org.springframework.transaction.reactive.TransactionSynchronizationManager, java.lang.Object)
288
- */
289
253
@ Override
290
254
protected Mono <Void > doCleanupAfterCompletion (TransactionSynchronizationManager synchronizationManager ,
291
255
Object transaction ) {
@@ -340,10 +304,6 @@ public ReactiveMongoDatabaseFactory getDatabaseFactory() {
340
304
return databaseFactory ;
341
305
}
342
306
343
- /*
344
- * (non-Javadoc)
345
- * @see org.springframework.beans.factory.InitializingBean#afterPropertiesSet()
346
- */
347
307
@ Override
348
308
public void afterPropertiesSet () {
349
309
getRequiredDatabaseFactory ();
@@ -509,19 +469,11 @@ private ClientSession getRequiredSession() {
509
469
return session ;
510
470
}
511
471
512
- /*
513
- * (non-Javadoc)
514
- * @see org.springframework.transaction.support.SmartTransactionObject#isRollbackOnly()
515
- */
516
472
@ Override
517
473
public boolean isRollbackOnly () {
518
474
return this .resourceHolder != null && this .resourceHolder .isRollbackOnly ();
519
475
}
520
476
521
- /*
522
- * (non-Javadoc)
523
- * @see org.springframework.transaction.support.SmartTransactionObject#flush()
524
- */
525
477
@ Override
526
478
public void flush () {
527
479
throw new UnsupportedOperationException ("flush() not supported" );
0 commit comments