Add Authenticator to the open() method params of ClusterStorage. Passed

in through the TransactionManager. This allows user-login to storages.
Fixes #192

1 files changed, 3 insertions, 2 deletions

diff --git a/src/main/java/com/c2kernel/persistency/TransactionManager.java b/src/main/java/com/c2kernel/persistency/TransactionManager.java
index d966eec..94b8123 100644
--- a/src/main/java/com/c2kernel/persistency/TransactionManager.java
+++ b/src/main/java/com/c2kernel/persistency/TransactionManager.java
@@ -7,6 +7,7 @@ import com.c2kernel.common.ObjectNotFoundException;
 import com.c2kernel.entity.C2KLocalObject;

 import com.c2kernel.entity.agent.JobList;

 import com.c2kernel.events.History;

+import com.c2kernel.process.auth.Authenticator;

 import com.c2kernel.utils.Logger;

 

 public class TransactionManager {

@@ -15,8 +16,8 @@ public class TransactionManager {
     HashMap<Object, ArrayList<TransactionEntry>> pendingTransactions;

     ClusterStorageManager storage;

 

-    public TransactionManager() throws ClusterStorageException {

-        storage = new ClusterStorageManager();

+    public TransactionManager(Authenticator auth) throws ClusterStorageException {

+        storage = new ClusterStorageManager(auth);

         locks = new HashMap<Integer, Object>();

         pendingTransactions = new HashMap<Object, ArrayList<TransactionEntry>>();

     }