From 00490b54adabecc1883f4cfacd34b81f6e296e5b Mon Sep 17 00:00:00 2001
From: Alessandro Pieve <alessandro.pieve@isti.cnr.it>
Date: Mon, 27 Feb 2017 09:38:00 +0000
Subject: [PATCH] git-svn-id:
 https://svn.d4science.research-infrastructures.eu/gcube/trunk/accounting/accounting-aggregator-se-plugin@144319
 82a268e6-3cf1-43bd-a215-b396298e98cf

---
 .../aggregator/plugin/AccountingAggregatorPlugin.java    | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git a/src/main/java/org/gcube/accounting/aggregator/plugin/AccountingAggregatorPlugin.java b/src/main/java/org/gcube/accounting/aggregator/plugin/AccountingAggregatorPlugin.java
index c5ae6d2..8447a58 100644
--- a/src/main/java/org/gcube/accounting/aggregator/plugin/AccountingAggregatorPlugin.java
+++ b/src/main/java/org/gcube/accounting/aggregator/plugin/AccountingAggregatorPlugin.java
@@ -378,7 +378,7 @@ public class AccountingAggregatorPlugin extends Plugin<AccountingAggregatorPlugi
 		} 
 		catch(InvalidValueException ex){
 			logger.warn("InvalidValueException - Record is not valid. Anyway, it will be persisted i:{}",i);
-			logger.warn("Runtime Exception exr",ex);
+			logger.warn("Runtime Exception ex",ex);
 			if ((i==5)&&(documentJson!=null)){
 				documentElaborate.add(documentJson);
 			}
@@ -467,7 +467,8 @@ public class AccountingAggregatorPlugin extends Plugin<AccountingAggregatorPlugi
 					countDelete ++;
 					try{
 						accountingBucket.remove(doc.id(),persisted,Constant.CONNECTION_TIMEOUT_BUCKET, TimeUnit.SECONDS);
-					}catch(Exception e){
+					}
+					catch(Exception e){
 						logger.warn("doc:{} not deleted retry:{} for error:{}",doc.id(),index,e);
 						Thread.sleep(1500);
 						try{
@@ -475,10 +476,10 @@ public class AccountingAggregatorPlugin extends Plugin<AccountingAggregatorPlugi
 								notDeletedTemp.add(doc);
 						}
 						catch(Exception ext){
-							logger.warn("doc:{} not verify for delete because timeout, retry:{}",doc.id(),index);
+							logger.warn("doc:{} not verify for delete because timeout, retry:{}",doc.id(),index,ext);
 							Thread.sleep(3000);
 							try{
-								if (!accountingBucket.exists(doc.id()))
+								if (accountingBucket.exists(doc.id()))
 									notDeletedTemp.add(doc);
 							}
 							catch(Exception ex)	{