feat(message): add option deliver_at and deliver_after

Author: Philip Yu

ext/bindings/message.cpp

@@ -34,6 +34,10 @@ Message::Message(const std::string& data, Rice::Object arg = Rice::Object()) {
         mb.setPartitionKey(Rice::Object(it->value).to_s().str());
       } else if (key == "ordering_key") {
         mb.setOrderingKey(Rice::Object(it->value).to_s().str());
+      } else if (key == "deliver_after") {
+        mb.setDeliverAfter(std::chrono::milliseconds(from_ruby<uint64_t>(Rice::Object(it->value))));
+      } else if (key == "deliver_at") {
+        mb.setDeliverAt(from_ruby<uint64_t>(Rice::Object(it->value)));
       } else {
         throw Rice::Exception(rb_eArgError, "Unknown keyword argument: %s", key.c_str());
       }

spec/pulsar/message_spec.rb

@@ -31,6 +31,22 @@
       end
     end
 
+    describe "deliver_at" do
+      it "does not raise error" do
+        expect do
+          described_class.new("payload", deliver_at: 1000)
+        end.not_to raise_error
+      end
+    end
+
+    describe "deliver_after" do
+      it "does not raise error" do
+        expect do
+          described_class.new("payload", deliver_after: (Time.now.to_i + 5) * 1000)
+        end.not_to raise_error
+      end
+    end
+
     describe "properties" do
       it "takes properties" do
         m = described_class.new("payload", properties: {"a" => "1", "b" => "2"})
@@ -129,6 +145,18 @@
           described_class.new("payload", properties: [])
         end.to raise_exception(TypeError)
       end
+
+      it "rejects deliver at that is not an integer" do
+        expect do
+          described_class.new("payload", deliver_at: "x")
+        end.to raise_exception(TypeError)
+      end
+
+      it "rejects deliver after that is not an integer" do
+        expect do
+          described_class.new("payload", deliver_after: "x")
+        end.to raise_exception(TypeError)
+      end
     end
   end
 end