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|