         task_data = load_data filename
 
         manager = connect_to_server_node server
-        manager |> send {:register_task, self()}
-        manager |> send {:add_employer, task_data.employers}
+        send manager, {:register_task, self()}
+        send manager, {:add_employer, task_data.employers}
 
         # We sent all our employers to manager
         # So now we have zero employers

                         <> "(#{List.first task_data.employers} and"
                         <> " #{List.first other_data.employers})."
                if should_exchange?(task_data, other_data) do
                    {new, oth_new} = exchange(task_data, other_data)
                    send pid, {:go, self(), oth_new}
                    receive do
                        :done ->
                            Logger.info "Exchange finished."
                                     <> "Now me:    #{inspect new}"
                                     <> "Now other: #{inspect oth_new}"
                            check_offers_finally(new)
                    after 1_000 ->
                            Logger.info "Exchange timeout."

                Logger.info "Received :deal_finished.\n"
                         <> "List of empls: #{inspect empls}\n"
                         <> "Task: #{task_data.task} (#{coef})"
                updated = task_data |> Tasks.push_remaining_tasks(tasks)
                try_exchange(updated)
        end
    end

    def try_exchange task_data do
        Logger.info "try_exchange"
        r = task_data |> Tasks.pop_remaining_task
        if is_nil(r) do
            Logger.info "We tried all tasks!"
            check_offers_finally(task_data)
        else
            {t, without_task} = r
            Logger.info "Only #{length without_task.remaining_tasks} tasks left"
            if t != self() do
                send t, {:go_exchange, self(), without_task}
                wait_agreement = fn itself ->
