aboutsummaryrefslogtreecommitdiffstats
path: root/documentapi/src/main/java/com/yahoo/documentapi/messagebus
diff options
context:
space:
mode:
authorTor Brede Vekterli <vekterli@yahooinc.com>2022-05-16 13:20:56 +0200
committergjoranv <gv@verizonmedia.com>2022-06-08 11:45:22 +0200
commit4639be4f03d58a0b8df7b1ecb573e7d344a53ed5 (patch)
tree236d8b271e2e51c5e15df08bc19c4c97860ca16a /documentapi/src/main/java/com/yahoo/documentapi/messagebus
parent1e03a00cd6f69cf63d942885e97ff7582778c7f5 (diff)
Remove top-level <clients> element and LoadType concept
Load types have not been properly supported for some time, so remove the remaining API surfaces exposing them. Since load type config was the last remaining use of <clients> in services.xml, remove that one as well.
Diffstat (limited to 'documentapi/src/main/java/com/yahoo/documentapi/messagebus')
-rw-r--r--documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusDocumentAccess.java2
-rwxr-xr-xdocumentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusParams.java25
-rwxr-xr-xdocumentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java1
-rw-r--r--documentapi/src/main/java/com/yahoo/documentapi/messagebus/loadtypes/LoadType.java47
-rw-r--r--documentapi/src/main/java/com/yahoo/documentapi/messagebus/loadtypes/LoadTypeSet.java110
-rw-r--r--documentapi/src/main/java/com/yahoo/documentapi/messagebus/loadtypes/package-info.java5
-rwxr-xr-xdocumentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/DocumentMessage.java28
-rwxr-xr-xdocumentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/DocumentProtocol.java32
-rw-r--r--documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutableFactories60.java10
-rwxr-xr-xdocumentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutableFactory.java16
-rwxr-xr-xdocumentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutableRepository.java13
11 files changed, 16 insertions, 273 deletions
diff --git a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusDocumentAccess.java b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusDocumentAccess.java
index c2e6dde7f60..09b7cf8d9a9 100644
--- a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusDocumentAccess.java
+++ b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusDocumentAccess.java
@@ -59,7 +59,7 @@ public class MessageBusDocumentAccess extends DocumentAccess {
this.params = params;
try {
com.yahoo.messagebus.MessageBusParams mbusParams = new com.yahoo.messagebus.MessageBusParams(params.getMessageBusParams());
- mbusParams.addProtocol(new DocumentProtocol(getDocumentTypeManager(), params.getProtocolConfigId(), params.getLoadTypes()));
+ mbusParams.addProtocol(new DocumentProtocol(getDocumentTypeManager(), params.getProtocolConfigId()));
if (System.getProperty("vespa.local", "false").equals("true")) { // set by Application when running locally
LocalNetwork network = new LocalNetwork();
bus = new NetworkMessageBus(network, new MessageBus(network, mbusParams));
diff --git a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusParams.java b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusParams.java
index bb8c3a3b1b1..c0e5b80dbff 100755
--- a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusParams.java
+++ b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusParams.java
@@ -2,7 +2,6 @@
package com.yahoo.documentapi.messagebus;
import com.yahoo.documentapi.DocumentAccessParams;
-import com.yahoo.documentapi.messagebus.loadtypes.LoadTypeSet;
import com.yahoo.documentapi.messagebus.protocol.DocumentProtocol;
import com.yahoo.documentapi.messagebus.protocol.DocumentProtocolPoliciesConfig;
import com.yahoo.messagebus.SourceSessionParams;
@@ -14,7 +13,6 @@ import static java.util.Objects.requireNonNull;
/**
* @author Einar M R Rosenvinge
*/
-@SuppressWarnings("removal") // TODO: Remove on Vespa 8
public class MessageBusParams extends DocumentAccessParams {
private String routingConfigId = null;
@@ -27,29 +25,8 @@ public class MessageBusParams extends DocumentAccessParams {
private RPCNetworkParams rpcNetworkParams = new RPCNetworkParams();
private com.yahoo.messagebus.MessageBusParams mbusParams = new com.yahoo.messagebus.MessageBusParams();
private SourceSessionParams sourceSessionParams = new SourceSessionParams();
- private LoadTypeSet loadTypes; // TODO remove on Vespa 8
- public MessageBusParams() {
- this(new LoadTypeSet());
- }
-
- /**
- * @deprecated load types are deprecated. Use default constructor instead
- */
- @Deprecated(forRemoval = true) // TODO: Remove on Vespa 8
- public MessageBusParams(LoadTypeSet loadTypes) {
- this.loadTypes = loadTypes;
- }
-
- /**
- *
- * @return Returns the set of load types accepted by this Vespa installation
- * @deprecated load types are deprecated
- */
- @Deprecated(forRemoval = true) // TODO: Remove on Vespa 8
- public LoadTypeSet getLoadTypes() {
- return loadTypes;
- }
+ public MessageBusParams() {}
/**
* Returns the id to resolve to routing config.
diff --git a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java
index 5e4e87759cb..b50164aefc0 100755
--- a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java
+++ b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java
@@ -660,7 +660,6 @@ public class MessageBusVisitorSession implements VisitorSession {
msg.setParameters(params.getLibraryParameters());
msg.setRoute(params.getRoute());
msg.setMaxBucketsPerVisitor(params.getMaxBucketsPerVisitor());
- msg.setLoadType(params.getLoadType());
msg.setPriority(params.getPriority()); // TODO: remove on Vespa 8
msg.setRetryEnabled(false);
diff --git a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/loadtypes/LoadType.java b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/loadtypes/LoadType.java
deleted file mode 100644
index 133736a8542..00000000000
--- a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/loadtypes/LoadType.java
+++ /dev/null
@@ -1,47 +0,0 @@
-// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
-package com.yahoo.documentapi.messagebus.loadtypes;
-
-import com.yahoo.documentapi.messagebus.protocol.DocumentProtocol;
-
-/**
- * @deprecated load types are deprecated
- * @author thomasg
- */
-@Deprecated(forRemoval = true) // TODO: Remove on Vespa 8
-public class LoadType {
- private int id;
- private String name;
- private DocumentProtocol.Priority priority;
-
- public static LoadType DEFAULT = new LoadType(0, "default", DocumentProtocol.Priority.NORMAL_3);
-
- public LoadType(int id, String name, DocumentProtocol.Priority priority) {
- this.id = id;
- this.name = name;
- this.priority = priority;
- }
-
- @Override
- public boolean equals(Object other) {
- if (!(other instanceof LoadType)) {
- return false;
- }
-
- LoadType o = (LoadType)other;
-
- return name.equals(o.getName()) && id == o.getId() && priority == o.getPriority();
- }
-
- @Override
- public int hashCode() {
- return java.util.Objects.hash(name, id, priority);
- }
-
- public String getName() { return name; }
-
- public String toString() { return name + " (id " + id + ")"; }
-
- public DocumentProtocol.Priority getPriority() { return priority; }
-
- public int getId() { return id; }
-}
diff --git a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/loadtypes/LoadTypeSet.java b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/loadtypes/LoadTypeSet.java
deleted file mode 100644
index a3fbed472f0..00000000000
--- a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/loadtypes/LoadTypeSet.java
+++ /dev/null
@@ -1,110 +0,0 @@
-// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
-package com.yahoo.documentapi.messagebus.loadtypes;
-
-import com.yahoo.config.subscription.ConfigGetter;
-import com.yahoo.vespa.config.content.LoadTypeConfig;
-import com.yahoo.documentapi.messagebus.protocol.DocumentProtocol;
-import java.security.MessageDigest;
-import java.security.NoSuchAlgorithmException;
-import java.util.HashMap;
-import java.util.Map;
-import java.util.TreeMap;
-
-/**
- * This class keeps track of all configured load types.
- *
- * For production use, you should only use the String constructor,
- * and supply a valid config id. Only the load types configured will
- * be propagated throughout the system, so there is no point in using other
- * load types.
- *
- * For testing, you may want to use the empty constructor and add
- * load types yourself with addType().
- *
- * @deprecated load types are deprecated
- */
-@Deprecated(forRemoval = true) // TODO: Remove on Vespa 8
-@SuppressWarnings("removal") // TODO: Remove on Vespa 8
-public class LoadTypeSet {
-
- public static final LoadTypeSet EMPTY = new LoadTypeSet();
-
- class DualMap {
- Map<String, LoadType> nameMap = new TreeMap<String, LoadType>();
- Map<Integer, LoadType> idMap = new HashMap<Integer, LoadType>();
-
- void put(LoadType l) {
- if (nameMap.containsKey(l.getName()) || idMap.containsKey(l.getId())) {
- throw new IllegalArgumentException(
- "ID or name conflict when adding " + l);
- }
-
- nameMap.put(l.getName(), l);
- idMap.put(l.getId(), l);
- }
- }
-
- DualMap map;
-
- public LoadTypeSet() {
- map = new DualMap();
- map.put(LoadType.DEFAULT);
- }
-
- public LoadTypeSet(String configId) {
- configure(new ConfigGetter<>(LoadTypeConfig.class).getConfig(configId));
- }
-
- public LoadTypeSet(LoadTypeConfig loadTypeConfig) {
- configure(loadTypeConfig);
- }
-
- public Map<String, LoadType> getNameMap() {
- return map.nameMap;
- }
-
- public Map<Integer, LoadType> getIdMap() {
- return map.idMap;
- }
-
- /**
- * Used by config to generate priorities for a name, and add them to the load type set.
- */
- public void addType(String name, String priority) {
- try {
- MessageDigest algorithm = MessageDigest.getInstance("MD5");
- algorithm.reset();
- algorithm.update(name.getBytes());
- byte messageDigest[] = algorithm.digest();
-
- int id = 0;
- for (int i = 0; i < 4; i++) {
- int temp = ((int)messageDigest[i] & 0xff);
- id <<= 8;
- id |= temp;
- }
-
- map.put(new LoadType(id, name, DocumentProtocol.Priority.valueOf(priority != null ? priority : "NORMAL_3")));
- } catch (NoSuchAlgorithmException e) {
- throw new RuntimeException(e);
- }
- }
-
- public void addLoadType(int id, String name, DocumentProtocol.Priority priority) {
- map.put(new LoadType(id, name, priority));
- }
-
- public void configure(LoadTypeConfig config) {
- DualMap newMap = new DualMap();
-
- // Default should always be available.
- newMap.put(LoadType.DEFAULT);
-
- for (LoadTypeConfig.Type t : config.type()) {
- newMap.put(new LoadType(t.id(), t.name(), DocumentProtocol.Priority.valueOf(t.priority())));
- }
-
- map = newMap;
- }
-}
-
diff --git a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/loadtypes/package-info.java b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/loadtypes/package-info.java
deleted file mode 100644
index be0f91f0f29..00000000000
--- a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/loadtypes/package-info.java
+++ /dev/null
@@ -1,5 +0,0 @@
-// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
-@ExportPackage
-package com.yahoo.documentapi.messagebus.loadtypes;
-
-import com.yahoo.osgi.annotation.ExportPackage;
diff --git a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/DocumentMessage.java b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/DocumentMessage.java
index 21f7c243c6f..d4736c391f7 100755
--- a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/DocumentMessage.java
+++ b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/DocumentMessage.java
@@ -1,7 +1,6 @@
// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.documentapi.messagebus.protocol;
-import com.yahoo.documentapi.messagebus.loadtypes.LoadType;
import com.yahoo.messagebus.Message;
import com.yahoo.messagebus.Routable;
import com.yahoo.text.Utf8String;
@@ -13,7 +12,6 @@ import com.yahoo.text.Utf8String;
public abstract class DocumentMessage extends Message {
private DocumentProtocol.Priority priority = DocumentProtocol.Priority.NORMAL_3;
- private LoadType loadType = LoadType.DEFAULT; // TODO: Remove on Vespa 8
/**
* Constructs a new message with no content.
@@ -38,10 +36,6 @@ public abstract class DocumentMessage extends Message {
DocumentProtocol.Priority pri = this.priority;
this.priority = msg.priority;
msg.priority = pri;
-
- LoadType lt = this.loadType;
- this.loadType = msg.loadType;
- msg.loadType = lt;
}
}
@@ -66,28 +60,6 @@ public abstract class DocumentMessage extends Message {
this.priority = priority;
}
- /**
- * @deprecated load types are deprecated
- */
- @Deprecated(forRemoval = true) // TODO: Remove on Vespa 8
- @SuppressWarnings("removal") // TODO: Remove on Vespa 8
- public LoadType getLoadType() {
- return loadType;
- }
-
- /**
- * @deprecated load types are deprecated
- */
- @Deprecated(forRemoval = true) // TODO: Remove on Vespa 8
- @SuppressWarnings("removal") // TODO: Remove on Vespa 8
- public void setLoadType(LoadType loadType) {
- if (loadType != null) {
- this.loadType = loadType;
- } else {
- this.loadType = LoadType.DEFAULT;
- }
- }
-
@Override
public int getApproxSize() {
return 4 + 1; // type + priority // TODO update on Vespa 8 to not include deprecated fields
diff --git a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/DocumentProtocol.java b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/DocumentProtocol.java
index bab416389dd..0ff578b64d7 100755
--- a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/DocumentProtocol.java
+++ b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/DocumentProtocol.java
@@ -6,7 +6,6 @@ import com.yahoo.component.Version;
import com.yahoo.component.VersionSpecification;
import com.yahoo.document.DocumentTypeManager;
import com.yahoo.document.DocumentTypeManagerConfigurer;
-import com.yahoo.documentapi.messagebus.loadtypes.LoadTypeSet;
import com.yahoo.messagebus.ErrorCode;
import com.yahoo.messagebus.Protocol;
import com.yahoo.messagebus.Reply;
@@ -32,7 +31,6 @@ import static java.util.Objects.requireNonNull;
*
* @author Simon Thoresen Hult
*/
-@SuppressWarnings("removal") // TODO: Remove on Vespa 8
public class DocumentProtocol implements Protocol {
private static final Logger log = Logger.getLogger(DocumentProtocol.class.getName());
@@ -240,39 +238,21 @@ public class DocumentProtocol implements Protocol {
}
public DocumentProtocol(DocumentTypeManager docMan) {
- this(docMan, null, new LoadTypeSet());
- }
-
- public DocumentProtocol(DocumentTypeManager docMan, String configId) {
- this(docMan, configId, new LoadTypeSet());
+ this(docMan, null);
}
public DocumentProtocol(DocumentTypeManager documentTypeManager,
DocumentProtocolPoliciesConfig policiesConfig,
DistributionConfig distributionConfig) {
- this(requireNonNull(documentTypeManager), null, new LoadTypeSet(),
+ this(requireNonNull(documentTypeManager), null,
requireNonNull(policiesConfig), requireNonNull(distributionConfig));
}
- /**
- * @deprecated load types are deprecated. Use constructor without LoadTypeSet instead.
- */
- @Deprecated(forRemoval = true) // TODO: Remove on Vespa 8
- public DocumentProtocol(DocumentTypeManager documentTypeManager, LoadTypeSet loadTypes,
- DocumentProtocolPoliciesConfig policiesConfig, DistributionConfig distributionConfig) {
- this(requireNonNull(documentTypeManager), null, requireNonNull(loadTypes),
- requireNonNull(policiesConfig), requireNonNull(distributionConfig));
- }
-
- /**
- * @deprecated load types are deprecated. Use constructor without LoadTypeSet instead.
- */
- @Deprecated(forRemoval = true) // TODO: Remove on Vespa 8
- public DocumentProtocol(DocumentTypeManager docMan, String configId, LoadTypeSet set) {
- this(docMan, configId == null ? "client" : configId, set, null, null);
+ public DocumentProtocol(DocumentTypeManager docMan, String configId) {
+ this(docMan, configId == null ? "client" : configId, null, null);
}
- private DocumentProtocol(DocumentTypeManager docMan, String configId, LoadTypeSet set,
+ private DocumentProtocol(DocumentTypeManager docMan, String configId,
DocumentProtocolPoliciesConfig policiesConfig, DistributionConfig distributionConfig) {
if (docMan != null)
this.docMan = docMan;
@@ -280,7 +260,7 @@ public class DocumentProtocol implements Protocol {
this.docMan = new DocumentTypeManager();
DocumentTypeManagerConfigurer.configure(this.docMan, configId);
}
- this.routableRepository = new RoutableRepository(set);
+ this.routableRepository = new RoutableRepository();
// When adding factories to this list, please KEEP THEM ORDERED alphabetically like they are now.
putRoutingPolicyFactory("AND", new RoutingPolicyFactories.AndPolicyFactory());
diff --git a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutableFactories60.java b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutableFactories60.java
index 42172b04b90..e0d52ced318 100644
--- a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutableFactories60.java
+++ b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutableFactories60.java
@@ -9,7 +9,6 @@ import com.yahoo.document.DocumentUpdate;
import com.yahoo.document.TestAndSetCondition;
import com.yahoo.document.serialization.DocumentDeserializer;
import com.yahoo.document.serialization.DocumentSerializer;
-import com.yahoo.documentapi.messagebus.loadtypes.LoadTypeSet;
import com.yahoo.messagebus.Routable;
import com.yahoo.vdslib.DocumentSummary;
import com.yahoo.vdslib.SearchResult;
@@ -70,18 +69,17 @@ public abstract class RoutableFactories60 {
}
DocumentMessage msg = (DocumentMessage)obj;
out.putByte(null, (byte)(msg.getPriority().getValue())); // TODO: encode default value on Vespa 8
- out.putInt(null, msg.getLoadType().getId());
+ out.putInt(null, 0); // Ignored load type. 0 is legacy "default" load type ID.
return doEncode(msg, out);
}
@SuppressWarnings("removal") // TODO: Remove on Vespa 8
- public Routable decode(DocumentDeserializer in, LoadTypeSet loadTypes) {
+ public Routable decode(DocumentDeserializer in) {
byte pri = in.getByte(null); // TODO: ignore on Vespa 8
- int loadType = in.getInt(null);
+ in.getInt(null); // Ignored load type
DocumentMessage msg = doDecode(in);
if (msg != null) {
msg.setPriority(DocumentProtocol.getPriority(pri));
- msg.setLoadType(loadTypes.getIdMap().get(loadType)); // TODO: ignore on Vespa 8
}
return msg;
}
@@ -132,7 +130,7 @@ public abstract class RoutableFactories60 {
}
@SuppressWarnings("removal") // TODO: Remove on Vespa 8
- public Routable decode(DocumentDeserializer in, LoadTypeSet loadTypes) {
+ public Routable decode(DocumentDeserializer in) {
byte pri = in.getByte(null);
DocumentReply reply = doDecode(in);
if (reply != null) {
diff --git a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutableFactory.java b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutableFactory.java
index 7baa41e5c6a..bff6cac548e 100755
--- a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutableFactory.java
+++ b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutableFactory.java
@@ -3,7 +3,6 @@ package com.yahoo.documentapi.messagebus.protocol;
import com.yahoo.document.serialization.DocumentDeserializer;
import com.yahoo.document.serialization.DocumentSerializer;
-import com.yahoo.documentapi.messagebus.loadtypes.LoadTypeSet;
import com.yahoo.messagebus.Routable;
/**
@@ -12,7 +11,7 @@ import com.yahoo.messagebus.Routable;
* com.yahoo.component.VersionSpecification)} method. </p>
*
* <p>Notice that no routable type is passed to the
- * {@link #decode(DocumentDeserializer, com.yahoo.documentapi.messagebus.loadtypes.LoadTypeSet)} method, so
+ * {@link #decode(DocumentDeserializer)} method, so
* you may NOT share a factory across multiple routable types. To share serialization logic between factory use a common
* superclass or composition with a common serialization utility.</p>
*
@@ -32,21 +31,12 @@ public interface RoutableFactory {
boolean encode(Routable obj, DocumentSerializer out);
/**
- * <p>This method decodes the given byte bufer to a routable.</p> <p>Return false to signal failure.</p> <p>This
+ * <p>This method decodes the given byte buffer to a routable.</p> <p>Return false to signal failure.</p> <p>This
* method is NOT exception safe.</p>
*
* @param in The buffer to read from.
- * @param loadTypes The LoadTypeSet to inject into the Routable.
* @return The decoded routable.
- * @deprecated load types are deprecated. Use method without LoadTypeSet instead
*/
- @Deprecated(forRemoval = true) // TODO: Remove on Vespa 8
- @SuppressWarnings("removal") // TODO: Remove on Vespa 8
- Routable decode(DocumentDeserializer in, LoadTypeSet loadTypes);
-
- @SuppressWarnings("removal") // TODO: Remove on Vespa 8
- default Routable decode(DocumentDeserializer in) {
- return decode(in, LoadTypeSet.EMPTY);
- }
+ Routable decode(DocumentDeserializer in);
}
diff --git a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutableRepository.java b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutableRepository.java
index 2360cbe8bc3..eb6caf5d0f7 100755
--- a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutableRepository.java
+++ b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/protocol/RoutableRepository.java
@@ -9,7 +9,6 @@ import com.yahoo.document.serialization.DocumentDeserializer;
import com.yahoo.document.serialization.DocumentDeserializerFactory;
import com.yahoo.document.serialization.DocumentSerializer;
import com.yahoo.document.serialization.DocumentSerializerFactory;
-import com.yahoo.documentapi.messagebus.loadtypes.LoadTypeSet;
import com.yahoo.io.GrowableByteBuffer;
import java.util.logging.Level;
import com.yahoo.messagebus.Routable;
@@ -34,20 +33,10 @@ final class RoutableRepository {
private static final Logger log = Logger.getLogger(RoutableRepository.class.getName());
private final CopyOnWriteHashMap<Integer, VersionMap> factoryTypes = new CopyOnWriteHashMap<>();
private final CopyOnWriteHashMap<CacheKey, RoutableFactory> cache = new CopyOnWriteHashMap<>();
- private LoadTypeSet loadTypes; // TODO remove on Vespa 8
public RoutableRepository() {}
/**
- * @deprecated load types are deprecated. Use default constructor instead.
- */
- @Deprecated(forRemoval = true) // TODO: Remove on Vespa 8
- @SuppressWarnings("removal") // TODO: Remove on Vespa 8
- public RoutableRepository(LoadTypeSet set) {
- loadTypes = set;
- }
-
- /**
* Decodes a {@link Routable} from the given byte array. This uses the content of the byte array to dispatch the
* decode request to the appropriate {@link RoutableFactory} that was previously registered.
*
@@ -75,7 +64,7 @@ final class RoutableRepository {
log.log(Level.SEVERE,"No routable factory found for routable type " + type + " (version " + version + ").");
return null;
}
- Routable ret = factory.decode(in, loadTypes);
+ Routable ret = factory.decode(in);
if (ret == null) {
log.log(Level.SEVERE,"Routable factory " + factory.getClass().getName() + " failed to deserialize " +
"routable of type " + type + " (version " + version + ").\nData = " + Arrays.toString(data));