diff options
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.cpp | 8 |
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&) { } |