diff options
author | Jon Bratseth <bratseth@oath.com> | 2018-10-05 11:01:23 +0200 |
---|---|---|
committer | Jon Bratseth <bratseth@oath.com> | 2018-10-05 11:01:23 +0200 |
commit | 01919cf07dbaa36364869439bd518400f22c0053 (patch) | |
tree | 3e89bbe36797da639072936a81be8bb57c30058e /vespaclient-java | |
parent | 4cb5c6bd58939c3111d60f922b1ff1a92b75cd6c (diff) |
Nonfunctional changes only
Diffstat (limited to 'vespaclient-java')
-rw-r--r-- | vespaclient-java/src/main/java/com/yahoo/vespavisit/VdsVisit.java | 30 |
1 files changed, 21 insertions, 9 deletions
diff --git a/vespaclient-java/src/main/java/com/yahoo/vespavisit/VdsVisit.java b/vespaclient-java/src/main/java/com/yahoo/vespavisit/VdsVisit.java index d7017b2d8bd..16d860a1d98 100644 --- a/vespaclient-java/src/main/java/com/yahoo/vespavisit/VdsVisit.java +++ b/vespaclient-java/src/main/java/com/yahoo/vespavisit/VdsVisit.java @@ -28,11 +28,12 @@ import java.nio.charset.Charset; import java.util.Map; /** - * Example client using visiting + * Client using visiting, used by the vespa-visit command line tool. * - * @author <a href="mailto:einarmr@yahoo-inc.com">Einar M R Rosenvinge</a>, based on work by <a href="mailto:humbe@yahoo-inc.com">Håkon Humberset</a> + * @author Einar M R Rosenvinge */ public class VdsVisit { + private VdsVisitParameters params; private MessageBusParams mbparams = new MessageBusParams(new LoadTypeSet()); private VisitorSession session; @@ -42,19 +43,26 @@ public class VdsVisit { private ShutdownHookRegistrar shutdownHookRegistrar; public interface ShutdownHookRegistrar { - public void registerShutdownHook(Thread thread); + + void registerShutdownHook(Thread thread); + } public interface VisitorSessionAccessor { - public VisitorSession createVisitorSession(VisitorParameters params) throws ParseException; - public void shutdown(); + + VisitorSession createVisitorSession(VisitorParameters params) throws ParseException; + void shutdown(); + } public interface VisitorSessionAccessorFactory { - public VisitorSessionAccessor createVisitorSessionAccessor(); + + VisitorSessionAccessor createVisitorSessionAccessor(); + } private static class MessageBusVisitorSessionAccessor implements VisitorSessionAccessor { + private MessageBusDocumentAccess access; private MessageBusVisitorSessionAccessor(MessageBusParams mbparams) { @@ -69,9 +77,11 @@ public class VdsVisit { public void shutdown() { access.shutdown(); } + } private static class MessageBusVisitorSessionAccessorFactory implements VisitorSessionAccessorFactory { + MessageBusParams mbparams; private MessageBusVisitorSessionAccessorFactory(MessageBusParams mbparams) { @@ -82,13 +92,16 @@ public class VdsVisit { public VisitorSessionAccessor createVisitorSessionAccessor() { return new MessageBusVisitorSessionAccessor(mbparams); } + } private static class JvmRuntimeShutdownHookRegistrar implements ShutdownHookRegistrar { + @Override public void registerShutdownHook(Thread thread) { Runtime.getRuntime().addShutdownHook(thread); } + } public VdsVisit() { @@ -96,9 +109,7 @@ public class VdsVisit { this.shutdownHookRegistrar = new JvmRuntimeShutdownHookRegistrar(); } - public VdsVisit(VisitorSessionAccessorFactory sessionAccessorFactory, - ShutdownHookRegistrar shutdownHookRegistrar) - { + public VdsVisit(VisitorSessionAccessorFactory sessionAccessorFactory, ShutdownHookRegistrar shutdownHookRegistrar) { this.sessionAccessorFactory = sessionAccessorFactory; this.shutdownHookRegistrar = shutdownHookRegistrar; } @@ -350,6 +361,7 @@ public class VdsVisit { } public static class VdsVisitParameters { + private VisitorParameters visitorParameters; /** If not specified in options, will get form cluster list */ private String cluster = null; |