- @source.each do |offset, labels|
- m = Message.new :source => @source, :source_info => offset, :labels => labels
- Index.add_message m
- UpdateManager.relay :add, m
+ my_message = nil
+ @source.each do |thisoffset, theselabels|
+ m = Message.new :source => @source, :source_info => thisoffset, :labels => theselabels
+ Index.sync_message m
+ UpdateManager.relay self, :added, m
+ my_message = m if thisoffset == offset