From 6e983c04748c24848aaa3631d167f953ae6519ff Mon Sep 17 00:00:00 2001
From: Alessandro Pieve <alessandro.pieve@isti.cnr.it>
Date: Fri, 17 Feb 2017 16:00:15 +0000
Subject: [PATCH] git-svn-id:
 https://svn.d4science.research-infrastructures.eu/gcube/trunk/accounting/accounting-insert-storage-se-plugin@142715
 82a268e6-3cf1-43bd-a215-b396298e98cf

---
 .../plugin/AccountingInsertStoragePlugin.java      | 14 ++++++++------
 1 file changed, 8 insertions(+), 6 deletions(-)

diff --git a/src/main/java/org/gcube/accounting/insert/storage/plugin/AccountingInsertStoragePlugin.java b/src/main/java/org/gcube/accounting/insert/storage/plugin/AccountingInsertStoragePlugin.java
index b9068ee..e24b825 100644
--- a/src/main/java/org/gcube/accounting/insert/storage/plugin/AccountingInsertStoragePlugin.java
+++ b/src/main/java/org/gcube/accounting/insert/storage/plugin/AccountingInsertStoragePlugin.java
@@ -55,7 +55,7 @@ public class AccountingInsertStoragePlugin extends Plugin<AccountingInsertStorag
 	public void launch(Map<String, Object> inputs) throws Exception {
 
 		String context=ScopeProvider.instance.get();
-		logger.debug("launch on context:{}",context);
+		logger.debug("AccountingInsertStoragePlugin: launch on context:{}",context);
 		String url=null;
 		String password =null;
 		String bucket=null;
@@ -68,10 +68,11 @@ public class AccountingInsertStoragePlugin extends Plugin<AccountingInsertStorag
 
 		}
 		catch (Exception e) {
-			logger.error("launch",e.getLocalizedMessage());
+			logger.error("AccountingInsertStoragePlugin: launch",e.getLocalizedMessage());
 			throw e;
 		}
 		Cluster cluster = CouchbaseCluster.create(ENV, url);
+		logger.debug("AccountingInsertStoragePlugin: create cluster");
 		Bucket accountingBucket = cluster.openBucket(bucket,password);
 
 		String urlService=null;
@@ -138,19 +139,20 @@ public class AccountingInsertStoragePlugin extends Plugin<AccountingInsertStorag
 				JsonDocument doc = JsonDocument.create(docId, content);
 
 				JsonDocument response = accountingBucket.upsert(doc);
-				logger.debug("upsert doc:{}",doc.toString());
+				logger.debug("AccountingInsertStoragePlugin: upsert doc:{}",doc.toString());
 				Thread.sleep(timeWait);
 
 
 			}
 			catch(Exception e){
-				logger.error("doc:{} not insert ({}), problem with exist bucket",document.id(),document.toString(),e);
-				logger.error("force insert into list for insert");		
+				logger.error("AccountingInsertStoragePlugin:  doc:{} not insert ({}), problem with exist bucket",document.id(),document.toString(),e);
+				logger.error("AccountingInsertStoragePlugin:  force insert into list for insert");		
 			}
 
 
 		}
 		cluster.disconnect();
+		logger.debug("AccountingInsertStoragePlugin:  insert complete");
 	}
 
 
@@ -160,7 +162,7 @@ public class AccountingInsertStoragePlugin extends Plugin<AccountingInsertStorag
 	/**{@inheritDoc}*/
 	@Override
 	protected void onStop() throws Exception {
-		logger.trace("{} onStop() function", this.getClass().getSimpleName());
+		logger.trace("AccountingInsertStoragePlugin: {} onStop() function", this.getClass().getSimpleName());
 		Thread.currentThread().interrupt();
 	}