1 files changed, 44 insertions, 0 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/session/RemoteSessionFactory.java b/configserver/src/main/java/com/yahoo/vespa/config/server/session/RemoteSessionFactory.java
new file mode 100644
index 00000000000..c44436740be
--- /dev/null
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/session/RemoteSessionFactory.java
@@ -0,0 +1,44 @@
+// Copyright 2016 Yahoo Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
+package com.yahoo.vespa.config.server.session;
+
+import com.yahoo.config.provision.TenantName;
+import com.yahoo.path.Path;
+import com.yahoo.config.model.api.ConfigDefinitionRepo;
+import com.yahoo.cloud.config.ConfigserverConfig;
+import com.yahoo.vespa.config.server.GlobalComponentRegistry;
+import com.yahoo.vespa.config.server.zookeeper.ConfigCurator;
+import com.yahoo.vespa.curator.Curator;
+
+/**
+ * @author lulf
+ * @since 5.1.24
+ */
+public class RemoteSessionFactory {
+
+    private final GlobalComponentRegistry componentRegistry;
+    private final Curator curator;
+    private final ConfigCurator configCurator;
+    private final Path sessionDirPath;
+    private final ConfigDefinitionRepo defRepo;
+    private final TenantName tenant;
+    private final ConfigserverConfig configserverConfig;
+
+    public RemoteSessionFactory(GlobalComponentRegistry componentRegistry,
+                                Path sessionsPath,
+                                TenantName tenant) {
+        this.componentRegistry = componentRegistry;
+        this.curator = componentRegistry.getCurator();
+        this.configCurator = componentRegistry.getConfigCurator();
+        this.sessionDirPath = sessionsPath;
+        this.tenant = tenant;
+        this.defRepo = componentRegistry.getConfigDefinitionRepo();
+        this.configserverConfig = componentRegistry.getConfigserverConfig();
+    }
+
+    public RemoteSession createSession(long sessionId) {
+        Path sessionPath = sessionDirPath.append(String.valueOf(sessionId));
+        SessionZooKeeperClient sessionZKClient = new SessionZooKeeperClient(curator, configCurator, sessionPath, defRepo, configserverConfig.serverId());
+        return new RemoteSession(tenant, sessionId, componentRegistry, sessionZKClient);
+    }
+
+}