lib/stream/fires.rb in Stream-0.2.2 vs lib/stream/fires.rb in Stream-0.2.3

@@ -29,17 +29,15 @@
               end
             end
             memo
           end
           
-          # create_options[:activity_type] = activity_type.to_s
-          
           activity = ActivityItem.create(create_options)
           
           if activity_type.to_s.eql?'new_message'
             activity.subject.recipient.activity_items << activity
           else
-            ([activity.actor] + activity.actor.contacts).each{|p| p.activity_items << activity }
+            ([activity.actor] + activity.actor.subscribed_contacts).each{|p| p.activity_items << activity }
           end
           
         end
 
         send(:"after_#{opts[:on]}", method_name, :if => opts[:if])