[logs] changing levels

Author: matcdac

README.md

@@ -38,7 +38,7 @@ Add (class level) annotation to java bean configuration class of the MongoDB Con
 
 	@Configuration
 	@EnableMongoAuditing
-	@EnableReactiveMongoRepositories(value = { "open.source.exchange.repository.asynchronous", "<actual.application.base.package.containg.asynchronous.repositories>" })
+	@EnableReactiveMongoRepositories(value = { "open.source.exchange.repository.asynchronous", "${application.package.containing.asynchronous.repositories}" })
 	public class MongoReactiveConfig { }
 
 

src/main/java/open/source/exchange/repository/asynchronous/InformationExchangeRepoAsyncImpl.java

@@ -31,7 +31,7 @@ public <T> Mono<Boolean> updateAttribute(String identifier, String attributeName
 					boolean wasAcknowledged = updateResult.wasAcknowledged();
 					boolean isModifiedCountAvailable = updateResult.isModifiedCountAvailable();
 					long modifiedCount = updateResult.getModifiedCount();
-					log.info("update result -> (identifier) {} (attributeName) {} (matchedCount) {} (wasAcknowledged) {} (isModifiedCountAvailable) {} (modifiedCount) {}",
+					log.debug("update result -> (identifier) {} (attributeName) {} (matchedCount) {} (wasAcknowledged) {} (isModifiedCountAvailable) {} (modifiedCount) {}",
 							identifier, attributeName, matchedCount, wasAcknowledged, isModifiedCountAvailable, modifiedCount);
 					return Mono.just(true);
 				});

src/main/java/open/source/exchange/service/InformationExchangeService.java

@@ -57,7 +57,8 @@ public void onEntry(long startTimestamp, ServerWebExchange serverWebExchange, St
 			.flatMap(persistedInformationExchange -> {
 				MDC.put("requestId", requestId);
 				MDC.put("identifier", identifier);
-				log.info("persisted -> (informationExchange) {}", persistedInformationExchange);
+				log.info("created entry of api call -> (requestId) {} (informationExchangeId) {}", requestId, identifier);
+				log.debug("persisted -> (informationExchange) {}", persistedInformationExchange);
 				parserHelper.identifyAndPersist(serverWebExchange, ExchangeInformationType.attributes);
 				parserHelper.identifyAndPersist(serverWebExchange, ExchangeInformationType.logPrefix);
 				parserHelper.identifyAndPersist(serverWebExchange, ExchangeInformationType.notModifiedFlag);

src/main/java/open/source/exchange/service/ParserHelper.java

@@ -221,7 +221,7 @@ public void identifyAndPersist(ServerWebExchange serverWebExchange, ExchangeInfo
 					exApplicationContext.setDocumentId(documentId);
 					monoCall = exApplicationContextRepoAsync.insert(exApplicationContext)
 						.flatMap(persistedExApplicationContext -> {
-							log.info("persisted -> (exApplicationContext) {}", persistedExApplicationContext);
+							log.debug("persisted -> (exApplicationContext) {}", persistedExApplicationContext);
 							return Mono.just(true);
 						});
 				}

src/main/java/open/source/exchange/utility/asynchronous/MonoCallSynchronousExecutor.java

@@ -9,29 +9,43 @@
 @Log4j2
 public class MonoCallSynchronousExecutor {
 
+	private static final int THRESHOLD_SECONDS = 5;
+
 	private static Thread getHelperThread(Disposable disposable, String descriptor, long perodicCheckMilliSecondsTime) {
 
 		Object requestId = MDC.get("requestId");
 		String id = (null != requestId) ? (String) requestId : "";
 		Thread helperThread = new Thread() {
 
+			private void checkThresholdCrossed(int sleptTimes, long perodicCheckMilliSeconds) {
+
+				int sleptDurationInSeconds = (int) ((perodicCheckMilliSeconds * sleptTimes) / 1000);
+				if (sleptDurationInSeconds > 0 && 0 == sleptDurationInSeconds % THRESHOLD_SECONDS ) {
+					log.warn("{} -> (disposed) {} (eachSleepMilliSecondDuration) {} (sleptTimes) {} (sleptDurationInSeconds) {}",
+							descriptor, false, perodicCheckMilliSeconds, sleptTimes, sleptDurationInSeconds);
+				} else {
+					log.debug("{} -> (disposed) {} (eachSleepMilliSecondDuration) {} (sleptTimes) {}",
+							descriptor, false, perodicCheckMilliSeconds, sleptTimes);
+				}
+			}
+
 			@Override
 			public void run() {
 
 				MDC.put("requestId", id);
 				boolean disposed = false;
 				int sleptTimes = 0;
 				while (false == (disposed = disposable.isDisposed())) {
-					log.info("{} -> (disposed) {} (sleptTimes) {}", descriptor, disposed, sleptTimes);
 					try {
 						this.sleep(perodicCheckMilliSecondsTime);
 					} catch (InterruptedException e) {
 						log.error("InterruptedException -> {}", e.getMessage(), e);
 						break;
 					}
 					++sleptTimes;
+					checkThresholdCrossed(sleptTimes, perodicCheckMilliSecondsTime);
 				}
-				log.info("{} -> (disposed) {}", descriptor, disposed);
+				log.debug("{} -> (disposed) {}", descriptor, disposed);
 			}
 
 		};