gistfile1.txt

            receive_messages.map do |msg|
              if msg.message_attributes[PIPE_STR].string_value == KEEPALIVES_STR
                # causes bug -> EM.defer { @keepalives_callback.call(msg, msg.body) }
                @keepalives_callback.call(msg, msg.body)
              else
                # causes bug -> EM.defer { @results_callback.call(msg, msg.body) }
                @results_callback.call(msg, msg.body)
              end
            end