keep Time class untouched

Author: archfish

examples/producer.rb

@@ -15,15 +15,15 @@
   )
 )
 
-p_msg = PulsarSdk::Producer::Message.new("dang qian shi jian #{Time.now}")
+p_msg = PulsarSdk::Producer::Message.new("dang qian shi jian #{TimeX.now}")
 
 # ++======消息发送后等待系统响应======++
 producer.execute(base_cmd, p_msg)
 
 # ++======调用后立即返回，服务器可能还没收到消息======++
 producer.execute_async(base_cmd, p_msg)
 
-# ++======发送消息后需要获取消息回执，因为回执与producer_id和request_id有关必须要知道真实的producer才能获取到回执======++
+# ++======发送消息后需要获取消息回执，因为回执与producer_id和request_id有关必须要知道真实的producer才能获取到======++
 real_producer = producer.real_producer(p_msg)
 real_producer.execute(base_cmd, p_msg)
 real_producer.receipt
@@ -39,7 +39,7 @@
   )
 )
 # message will available in 10 second
-deliver_at = Time.now + 10
+deliver_at = TimeX.now + 10
 p_msg = PulsarSdk::Producer::Message.new(
   "dang qian shi jian publush at: #{now}, performat at: #{deliver_at}",
   Pulsar::Proto::MessageMetadata.new(deliver_at_time: deliver_at.timestamp)

lib/pulsar_sdk/connection.rb

@@ -18,7 +18,7 @@ def initialize(proxy_addr, broker_addr = nil, tls_options = nil, auth_provider =
       @tls_options = tls_options&.dup
       @auth_provider = auth_provider
       @socket = nil
-      @last_data_received_at = Time.now
+      @last_data_received_at = TimeX.now
       @state = Status.new
       self.operation_timeout = 30
       self.connection_timeout = 5
@@ -247,7 +247,7 @@ def handle_send_receipt(send_receipt)
     end
 
     def set_last_data_received
-      @last_data_received_at = Time.now
+      @last_data_received_at = TimeX.now
     end
 
     def handle_ping

lib/pulsar_sdk/producer/message.rb

@@ -8,7 +8,7 @@ def initialize(msg, metadata = nil)
 
         @metadata ||= Pulsar::Proto::MessageMetadata.new
         publish_time = @metadata.publish_time
-        @metadata.publish_time = publish_time.zero? ? Time.now.timestamp : publish_time
+        @metadata.publish_time = publish_time.zero? ? TimeX.now.timestamp : publish_time
       end
 
       def producer_name=(v)

lib/pulsar_sdk/producer/router.rb

@@ -17,7 +17,7 @@ def route(key, total, delay = 0)
 
         return (@handler.call(key) % total) unless key.to_s.empty?
 
-        Murmur3.int32_hash(Time.now.timestamp) % total
+        Murmur3.int32_hash(TimeX.now.timestamp) % total
       end
 
       # 将hash值限制在32位内，防止key过长导致过多内存占用

lib/pulsar_sdk/protocol/message.rb

@@ -14,7 +14,7 @@ class Message
         define_method "#{x}_at" do
           v = self.public_send("#{x}_time").to_i
           return if v.zero?
-          Time.at_timestamp(v)
+          TimeX.at_timestamp(v)
         end
       end
 

lib/pulsar_sdk/tweaks.rb

@@ -6,4 +6,3 @@
 
 # 扩展type的判断方法，方便书写，统一以 typeof_ 开头
 Pulsar::Proto::BaseCommand.prepend PulsarSdk::Tweaks::BaseCommand
-Time.prepend PulsarSdk::Tweaks::TimeAtMicrosecond

lib/pulsar_sdk/tweaks/time_at_microsecond.rb

@@ -14,9 +14,14 @@ def timestamp
       module ClassMethods
         def at_timestamp(v)
           second, micro = v.divmod(1000)
-          Time.at(second, micro * 1000)
+          self.at(second, micro * 1000)
         end
       end
     end
   end
 end
+
+# 扩展默认时间方法，增加毫秒时间戳相关处理
+class TimeX < Time
+  prepend PulsarSdk::Tweaks::TimeAtMicrosecond
+end

lib/pulsar_sdk/tweaks/timeout_queue.rb

@@ -28,8 +28,8 @@ def pop(timeout = nil)
               @received.wait(@mutex)
             end
           elsif @receive_queue.empty? && timeout != 0
-            timeout_at = Time.now.to_f + timeout
-            while @receive_queue.empty? && (res = timeout_at - Time.now.to_f) > 0
+            timeout_at = TimeX.now.to_f + timeout
+            while @receive_queue.empty? && (res = timeout_at - TimeX.now.to_f) > 0
               @received.wait(@mutex, res)
             end
           end

lib/pulsar_sdk/tweaks/wait_map.rb

@@ -45,8 +45,8 @@ def delete(id, timeout = nil)
               signal.wait(mutex)
             end
           elsif @responses.empty? && timeout != 0
-            timeout_at = Time.now.to_f + timeout
-            while @responses.empty? && (res = timeout_at - Time.now.to_f) > 0
+            timeout_at = TimeX.now.to_f + timeout
+            while @responses.empty? && (res = timeout_at - TimeX.now.to_f) > 0
               signal.wait(mutex, res)
             end
           end

lib/pulsar_sdk/version.rb

@@ -1,3 +1,3 @@
 module PulsarSdk
-  VERSION = "0.3.2"
+  VERSION = "0.4.1"
 end