diff options
author | Arnstein Ressem <aressem@gmail.com> | 2020-09-21 12:37:40 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-09-21 12:37:40 +0200 |
commit | 7b03effca945dea607ed7a3c3debebda303992ab (patch) | |
tree | d83a49d4af8dcdc4c1f6cb9c73d5f169e4369cb6 /container-core | |
parent | b8e79b130ce75292ca398afda54eef76aa932a16 (diff) |
Revert "Jonmv/async document v1"
Diffstat (limited to 'container-core')
2 files changed, 0 insertions, 60 deletions
diff --git a/container-core/src/main/java/com/yahoo/container/core/documentapi/MessageBusDocumentAccessProvider.java b/container-core/src/main/java/com/yahoo/container/core/documentapi/MessageBusDocumentAccessProvider.java deleted file mode 100644 index c3cd78e4da9..00000000000 --- a/container-core/src/main/java/com/yahoo/container/core/documentapi/MessageBusDocumentAccessProvider.java +++ /dev/null @@ -1,55 +0,0 @@ -package com.yahoo.container.core.documentapi; - -import com.google.inject.Inject; -import com.yahoo.component.AbstractComponent; -import com.yahoo.container.di.componentgraph.Provider; -import com.yahoo.document.config.DocumentmanagerConfig; -import com.yahoo.documentapi.DocumentAccess; -import com.yahoo.documentapi.messagebus.MessageBusDocumentAccess; -import com.yahoo.documentapi.messagebus.MessageBusParams; -import com.yahoo.documentapi.messagebus.loadtypes.LoadTypeSet; -import com.yahoo.vespa.config.content.LoadTypeConfig; - -/** - * Has a lazily populated reference to a {@link MessageBusDocumentAccess}. - * - * @author jonmv - */ -public class MessageBusDocumentAccessProvider extends AbstractComponent implements Provider<DocumentAccess> { - - private final DocumentmanagerConfig documentmanagerConfig; - private final LoadTypeConfig loadTypeConfig; - private final Object monitor = new Object(); - private boolean shutDown = false; - private DocumentAccess access = null; - - @Inject - public MessageBusDocumentAccessProvider(DocumentmanagerConfig documentmanagerConfig, LoadTypeConfig loadTypeConfig) { - this.documentmanagerConfig = documentmanagerConfig; - this.loadTypeConfig = loadTypeConfig; - } - - @Override - public DocumentAccess get() { - synchronized (monitor) { - if (access == null) { - access = new MessageBusDocumentAccess((MessageBusParams) new MessageBusParams(new LoadTypeSet(loadTypeConfig)).setDocumentmanagerConfig(documentmanagerConfig)); - if (shutDown) - access.shutdown(); - } - return access; - } - } - - @Override - public void deconstruct() { - synchronized (monitor) { - if ( ! shutDown) { - shutDown = true; - if (access != null) - access.shutdown(); - } - } - } - -} diff --git a/container-core/src/main/java/com/yahoo/container/core/documentapi/package-info.java b/container-core/src/main/java/com/yahoo/container/core/documentapi/package-info.java deleted file mode 100644 index de524237499..00000000000 --- a/container-core/src/main/java/com/yahoo/container/core/documentapi/package-info.java +++ /dev/null @@ -1,5 +0,0 @@ -// Copyright 2020 Oath Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. -@ExportPackage -package com.yahoo.container.core.documentapi; - -import com.yahoo.osgi.annotation.ExportPackage; |