aboutsummaryrefslogtreecommitdiffstats
path: root/searchcore/src/apps/vespa-feed-bm/document_api_message_bus_bm_feed_handler.cpp
diff options
context:
space:
mode:
authorTor Egge <Tor.Egge@broadpark.no>2020-10-13 16:14:24 +0200
committerTor Egge <Tor.Egge@broadpark.no>2020-10-13 17:50:42 +0200
commita1d1b5078c979c936255e5f39757b6b0f36b2d8a (patch)
treebab3b5da82a7f62deb24a5735c608a3164f177ef /searchcore/src/apps/vespa-feed-bm/document_api_message_bus_bm_feed_handler.cpp
parentff2afad2393bf61e4cadf1bde7bd678e92a5b435 (diff)
Benchmark get operations.
Diffstat (limited to 'searchcore/src/apps/vespa-feed-bm/document_api_message_bus_bm_feed_handler.cpp')
-rw-r--r--searchcore/src/apps/vespa-feed-bm/document_api_message_bus_bm_feed_handler.cpp8
1 files changed, 8 insertions, 0 deletions
diff --git a/searchcore/src/apps/vespa-feed-bm/document_api_message_bus_bm_feed_handler.cpp b/searchcore/src/apps/vespa-feed-bm/document_api_message_bus_bm_feed_handler.cpp
index 7801c2e3986..e6502d14347 100644
--- a/searchcore/src/apps/vespa-feed-bm/document_api_message_bus_bm_feed_handler.cpp
+++ b/searchcore/src/apps/vespa-feed-bm/document_api_message_bus_bm_feed_handler.cpp
@@ -5,6 +5,7 @@
#include "pending_tracker.h"
#include <vespa/document/fieldvalue/document.h>
#include <vespa/document/update/documentupdate.h>
+#include <vespa/documentapi/messagebus/messages/getdocumentmessage.h>
#include <vespa/documentapi/messagebus/messages/putdocumentmessage.h>
#include <vespa/documentapi/messagebus/messages/removedocumentmessage.h>
#include <vespa/documentapi/messagebus/messages/updatedocumentmessage.h>
@@ -56,6 +57,13 @@ DocumentApiMessageBusBmFeedHandler::remove(const document::Bucket&, const Docume
}
void
+DocumentApiMessageBusBmFeedHandler::get(const document::Bucket&, vespalib::stringref field_set_string, const document::DocumentId& document_id, PendingTracker& tracker)
+{
+ auto msg = std::make_unique<documentapi::GetDocumentMessage>(document_id, field_set_string);
+ send_msg(std::move(msg), tracker);
+}
+
+void
DocumentApiMessageBusBmFeedHandler::attach_bucket_info_queue(PendingTracker&)
{
}