app/models/agents/email_agent.rb

@@ -33,8 +33,8 @@ module Agents

                 
              

                     def receive(incoming_events)
              

                       incoming_events.each do |event|
              

                -        log "Sending digest mail to #{user.email} with event #{event.id}"
              

                         recipients(event.payload).each do |recipient|
              

                +          log "Sending digest mail to #{recipient} with event #{event.id}"
              

                           SystemMailer.send_message(:to => recipient, :subject => interpolated(event)['subject'], :headline => interpolated(event)['headline'], :body => interpolated(event)['body'], :groups => [present(event.payload)]).deliver_later
              

                         end
              

                       end
              

app/models/agents/email_digest_agent.rb

@@ -40,8 +40,8 @@ module Agents

                       if self.memory['queue'] && self.memory['queue'].length > 0
              

                         ids = self.memory['events'].join(",")
              

                         groups = self.memory['queue'].map { |payload| present(payload) }
              

                -        log "Sending digest mail to #{user.email} with events [#{ids}]"
              

                         recipients.each do |recipient|
              

                +          log "Sending digest mail to #{recipient} with events [#{ids}]"
              

                           SystemMailer.send_message(:to => recipient, :subject => interpolated['subject'], :headline => interpolated['headline'], :groups => groups).deliver_later
              

                         end
              

                         self.memory['queue'] = []