lib/ruote/storage/base.rb in ruote-2.1.3 vs lib/ruote/storage/base.rb in ruote-2.1.4
- old
+ new
@@ -53,20 +53,22 @@
def put_msg (action, options)
# merge! is way faster than merge (no object creation probably)
+ t = Time.now
+ t = "#{t.to_i}.#{"%06d" % t.usec}"
+
msg = options.merge!(
'type' => 'msgs',
- '_id' => "#{$$}-#{Thread.current.object_id}-#{Time.now.to_f.to_s}",
+ '_id' => "#{$$}-#{Thread.current.object_id}-#{t}",
'action' => action)
msg.delete('_rev')
# in case of message replay
put(msg)
- #, :update_rev => true)
-
+ #put(msg, :update_rev => true)
#(@local_msgs ||= []) << options
end
#def get_local_msgs
# if @local_msgs