From d7359f7c72ff06889af594431baf4075e2b4da78 Mon Sep 17 00:00:00 2001 From: Harald Musum Date: Wed, 27 Jan 2021 08:53:21 +0100 Subject: Revert "Jonmv/document protocol super config" --- .../yahoo/vespa/http/server/FeedErrorMessage.java | 43 ++++++++++++++++++++++ 1 file changed, 43 insertions(+) create mode 100644 vespaclient-container-plugin/src/main/java/com/yahoo/vespa/http/server/FeedErrorMessage.java (limited to 'vespaclient-container-plugin') diff --git a/vespaclient-container-plugin/src/main/java/com/yahoo/vespa/http/server/FeedErrorMessage.java b/vespaclient-container-plugin/src/main/java/com/yahoo/vespa/http/server/FeedErrorMessage.java new file mode 100644 index 00000000000..1d7e8535909 --- /dev/null +++ b/vespaclient-container-plugin/src/main/java/com/yahoo/vespa/http/server/FeedErrorMessage.java @@ -0,0 +1,43 @@ +// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. +package com.yahoo.vespa.http.server; + +import com.yahoo.document.DocumentId; +import com.yahoo.messagebus.Message; +import com.yahoo.text.Utf8String; + +import java.util.Arrays; + +public class FeedErrorMessage extends Message { + + private long sequenceId; + + public FeedErrorMessage(String operationId) { + try { + DocumentId id = new DocumentId(operationId); + sequenceId = Arrays.hashCode(id.getGlobalId()); + } catch (Exception e) { + sequenceId = 0; + } + } + + @Override + public Utf8String getProtocol() { + return new Utf8String("vespa-feed-handler-internal-bogus-protocol"); + } + + @Override + public int getType() { + return 1234; + } + + @Override + public boolean hasSequenceId() { + return true; + } + + @Override + public long getSequenceId() { + return sequenceId; + } + +} -- cgit v1.2.3