lib/bbk/app/dispatcher.rb in bbk-app-1.1.0.204569 vs lib/bbk/app/dispatcher.rb in bbk-app-1.1.0.216998
- old
+ new
@@ -181,10 +181,10 @@
def send_results(incoming, results)
message_id = incoming.headers[:message_id]
answers, sended_messages = results.partition { _1.route.domain == ANSWER_DOMAIN }
# allowed only one answer message
- raise InvalidAnswersMessagesCountError.new("Get #{asnwers.size} on processing message with id=#{message_id}") if answers.size > 1
+ raise InvalidAnswersMessagesCountError.new("Get #{answers.size} on processing message with id=#{message_id}") if answers.size > 1
answer = answers.first
Concurrent::Promises.zip_futures(*sended_messages.map do |result|
publish_result(result)
end).then do |_successes|