additional minor (formatting) changes

refactor trx event listeners #3222
metasfresh · Dec 18, 2017 · 8f6b727 · 8f6b727
1 parent ca4791c
commit 8f6b727
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 3 deletions.
diff --git a/de.metas.adempiere.adempiere/base/src/main/java-legacy/org/compiere/util/CacheMgt.java b/de.metas.adempiere.adempiere/base/src/main/java-legacy/org/compiere/util/CacheMgt.java
@@ -723,7 +723,8 @@ public static final RecordsToResetOnTrxCommitCollector getCreate(final ITrx trx)
 				final RecordsToResetOnTrxCommitCollector collector = new RecordsToResetOnTrxCommitCollector();
 
 				// Listens {@link ITrx}'s after-commit and fires enqueued cache invalidation requests
-				trx.getTrxListenerManager().newEventListener().timing(TrxEventTiming.AFTER_COMMIT)
+				trx.getTrxListenerManager()
+						.newEventListener().timing(TrxEventTiming.AFTER_COMMIT)
 						.handlingMethod(innerTrx -> {
 
 							final RecordsToResetOnTrxCommitCollector innerCollector = innerTrx.getProperty(TRX_PROPERTY);

diff --git a/...units.base/src/main/java/de/metas/handlingunits/trace/interceptor/TraceHUTrxListener.java b/...units.base/src/main/java/de/metas/handlingunits/trace/interceptor/TraceHUTrxListener.java
@@ -91,7 +91,8 @@ public void afterTrxProcessed(
 
 		final ITrxManager trxManager = Services.get(ITrxManager.class);
 		final ITrxListenerManager trxListenerManager = trxManager.getTrxListenerManager(ITrx.TRXNAME_ThreadInherited);
-		trxListenerManager.newEventListener().timing(TrxEventTiming.AFTER_COMMIT)
+		trxListenerManager
+				.newEventListener().timing(TrxEventTiming.AFTER_COMMIT)
 				.handlingMethod(innerTrx -> {
 
 					// do a brand new transaction in which we execute our things,

diff --git a/de.metas.storage/src/main/java/de/metas/storage/impl/StorageSegmentChangedExecutor.java b/de.metas.storage/src/main/java/de/metas/storage/impl/StorageSegmentChangedExecutor.java
@@ -64,7 +64,8 @@ private static final StorageSegmentChangedExecutor getCreate(final ITrx trx)
 
 			// register our listener: we will actually fire the storage segment changed when the transaction is commited
 			// Listens the {@link ITrx} and on commit actually fires the segment changed event
-			trx.getTrxListenerManager().newEventListener().timing(TrxEventTiming.AFTER_COMMIT)
+			trx.getTrxListenerManager()
+					.newEventListener().timing(TrxEventTiming.AFTER_COMMIT)
 					.handlingMethod(innerTrx -> {
 						final StorageSegmentChangedExecutor innerCollector = trx.getProperty(TRX_PROPERTYNAME);
 						if (innerCollector == null || innerCollector.isEmpty())