summaryrefslogtreecommitdiffstats
path: root/docproc
diff options
context:
space:
mode:
authorHåvard Pettersen <havardpe@yahooinc.com>2023-05-09 17:07:31 +0200
committerHåvard Pettersen <havardpe@yahooinc.com>2023-05-09 17:07:31 +0200
commit0cd4a18534ff4828411d994c645b792438652a41 (patch)
treeb459c7ed8c758cf439985769a6ec44ff7d407792 /docproc
parentb427abd521814697515a6b050cf2f7f7240e95d5 (diff)
forward create flag
Diffstat (limited to 'docproc')
-rw-r--r--docproc/src/main/java/com/yahoo/docproc/jdisc/messagebus/ProcessingFactory.java1
1 files changed, 1 insertions, 0 deletions
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 592e201e33f..bf6c75584be 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
@@ -47,6 +47,7 @@ class ProcessingFactory {
PutDocumentMessage putMessage = (PutDocumentMessage) message;
DocumentPut putOperation = new DocumentPut(createPutDocument(putMessage));
putOperation.setCondition(putMessage.getCondition());
+ putOperation.setCreateIfNonExistent(putMessage.getCreateIfNonExistent());
processings.add(createProcessing(putOperation, message));
break;
}