commit 1343f7a86e48ed04d2df0f446568b038af5082ed
author k2la <mzq6mft9zz@gmail.com> Wed Apr 07 09:54:10 2021 +0900
committer GitHub <noreply@github.com> Wed Apr 07 09:54:10 2021 +0900
tree 6556ed94b05d31b059d832669429b65b535710ad
parent 04578bc71150528c46b1b2632ceebdccc5499c34

support disable replication (#149)

Co-authored-by: yfuruta <yfuruta@yahoo-corp.jp>

src/Message.cc

diff --git a/src/Message.cc b/src/Message.cc
index d93264e..fc0e82c 100644
--- a/src/Message.cc
+++ b/src/Message.cc
@@ -29,6 +29,7 @@
 static const std::string CFG_REPL_CLUSTERS = "replicationClusters";
 static const std::string CFG_DELIVER_AFTER = "deliverAfter";
 static const std::string CFG_DELIVER_AT = "deliverAt";
+static const std::string CFG_DISABLE_REPLICATION = "disableReplication";
 
 Napi::FunctionReference Message::constructor;
 
@@ -206,6 +207,13 @@
     Napi::Number deliverAt = conf.Get(CFG_DELIVER_AT).ToNumber();
     pulsar_message_set_deliver_at(cMessage, deliverAt.Int64Value());
   }
+
+  if (conf.Has(CFG_DISABLE_REPLICATION) && conf.Get(CFG_DISABLE_REPLICATION).IsBoolean()) {
+    Napi::Boolean disableReplication = conf.Get(CFG_DISABLE_REPLICATION).ToBoolean();
+    if (disableReplication.Value()) {
+      pulsar_message_disable_replication(cMessage, 1);
+    }
+  }
   return cMessage;
 }