Skip to content

Commit

Permalink
Add headers to reject message
Browse files Browse the repository at this point in the history
  • Loading branch information
Neloop committed Feb 15, 2019
1 parent 4355411 commit 4baa6ad
Showing 1 changed file with 5 additions and 3 deletions.
8 changes: 5 additions & 3 deletions src/handlers/broker_handler.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -150,13 +150,15 @@ void broker_handler::process_client_eval(

respond(message_container(broker_connect::KEY_CLIENTS, identity, {"accept"}));
} else {
std::string reject_message = "No worker available for given headers.";
respond(message_container(broker_connect::KEY_CLIENTS, identity, {"reject", reject_message}));
notify_monitor(job_id, "FAILED", respond);
std::string reject_message = "No worker available for given headers: ";
logger_->error("Request '{}' rejected. No worker available for headers:", job_id);
for (auto &header : headers) {
reject_message += header.first + "=" + header.second + "; ";
logger_->error(" - {}: {}", header.first, header.second);
}

respond(message_container(broker_connect::KEY_CLIENTS, identity, {"reject", reject_message}));
notify_monitor(job_id, "FAILED", respond);
}
}

Expand Down

0 comments on commit 4baa6ad

Please sign in to comment.