@@ -207,6 +207,7 @@ module ReframeIt avail_thread = Thread.new do while true begin + avail_msg.update_timestamp debug { "sending availability message #{avail_msg.inspect}" } send_message(monitor_queue, avail_msg) rescue Exception => ex lib/ec2-discovery.rb @@ -56,6 +56,10 @@ module ReframeIt @timestamp = ts.to_i end + def update_timestamp + @timestamp = Time.now.to_i + end + def to_json(*a) data = {} self.class.serialized_attributes.each do |attr| lib/ec2-discovery/message.rb @@ -49,7 +49,10 @@ module ReframeIt def process(msg) clazz = msg.class - return if msg.respond_to?(:timestamp) && (msg.timestamp + @ignore_time < Time.now.to_i) + if msg.respond_to?(:timestamp) && (msg.timestamp + @ignore_time < Time.now.to_i) + info{ "Ignoring message #{msg.inspect} with timestamp #{Time.now.to_i - msg.timestamp} seconds ago" } + return + end # process all superclasses that are compatible with Message while clazz && clazz <= Message lib/ec2-discovery/queue_listener.rb a6945a97ea99ce8bd3291e572703de573c0445bf Ben Taitelbaum ben@reframeit.com http://github.com/reframeit/ec2-discovery/commit/8f172036c15001b42ff5e77f59b9cfbfcc29215c 8f172036c15001b42ff5e77f59b9cfbfcc29215c 2009-04-14T09:35:40-07:00 2009-04-14T09:35:40-07:00 we were ignoring all the availability messages c5257f00a1ed83d10e88f3f6f2e58cd0f59972eb Ben Taitelbaum ben@reframeit.com