diff options
Diffstat (limited to 'docproc/src/main/java/com')
| -rw-r--r-- | docproc/src/main/java/com/yahoo/docproc/jdisc/messagebus/MbusRequestContext.java | 1 | ||||
| -rw-r--r-- | docproc/src/main/java/com/yahoo/docproc/jdisc/messagebus/ProcessingFactory.java | 7 |
2 files changed, 0 insertions, 8 deletions
diff --git a/docproc/src/main/java/com/yahoo/docproc/jdisc/messagebus/MbusRequestContext.java b/docproc/src/main/java/com/yahoo/docproc/jdisc/messagebus/MbusRequestContext.java index 0f3f3938701..187557791f3 100644 --- a/docproc/src/main/java/com/yahoo/docproc/jdisc/messagebus/MbusRequestContext.java +++ b/docproc/src/main/java/com/yahoo/docproc/jdisc/messagebus/MbusRequestContext.java @@ -168,7 +168,6 @@ public class MbusRequestContext implements RequestContext, ResponseHandler { case DocumentProtocol.MESSAGE_PUTDOCUMENT: case DocumentProtocol.MESSAGE_UPDATEDOCUMENT: case DocumentProtocol.MESSAGE_REMOVEDOCUMENT: - case DocumentProtocol.MESSAGE_BATCHDOCUMENTUPDATE: return true; } return false; diff --git a/docproc/src/main/java/com/yahoo/docproc/jdisc/messagebus/ProcessingFactory.java b/docproc/src/main/java/com/yahoo/docproc/jdisc/messagebus/ProcessingFactory.java index 044f86e93e6..49a6020d633 100644 --- a/docproc/src/main/java/com/yahoo/docproc/jdisc/messagebus/ProcessingFactory.java +++ b/docproc/src/main/java/com/yahoo/docproc/jdisc/messagebus/ProcessingFactory.java @@ -15,7 +15,6 @@ import com.yahoo.document.DocumentOperation; import com.yahoo.document.DocumentPut; import com.yahoo.document.DocumentRemove; import com.yahoo.document.DocumentUpdate; -import com.yahoo.documentapi.messagebus.protocol.BatchDocumentUpdateMessage; import com.yahoo.documentapi.messagebus.protocol.DocumentProtocol; import com.yahoo.documentapi.messagebus.protocol.PutDocumentMessage; import com.yahoo.documentapi.messagebus.protocol.RemoveDocumentMessage; @@ -67,12 +66,6 @@ class ProcessingFactory { processings.add(createProcessing(removeOperation, message)); break; } - case DocumentProtocol.MESSAGE_BATCHDOCUMENTUPDATE: { - for (DocumentUpdate update : ((BatchDocumentUpdateMessage) message).getUpdates()) { - processings.add(createProcessing(update, message)); - } - break; - } } return processings; } |