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