lib/sequent/core/command_service.rb
# Executes the given commands in a single transactional block as implemented by the +transaction_provider+
#
# For each command:
#
# * All filters are executed. Any exception raised will rollback the transaction and propagate up
# * If the command is valid all +command_handlers+ that +handles_message?+ is invoked
# * The +repository+ commits the command and all uncommitted_events resulting from the command
Executes the given commands in a single transactional block as implemented by the +transaction_provider+
For each command.

All filters are executed.
Executes the given commands in a single transactional block as implemented by the + transaction_provider + For each command . All filters are executed .
def process_commands
        Sequent::Util.skip_if_already_processing(:command_service_process_commands) do
          begin
            transaction_provider.transactional do
              while(!command_queue.empty?) do
                process_command(command_queue.pop)
              end
            end
          ensure
            command_queue.clear
            repository.clear
          end
        end
      end
def process_commands Sequent :: Util . skip_if_already_processing ( :command_service_process_commands ) do begin transaction_provider . transactional do while ( ! command_queue . empty? ) do process_command ( command_queue . pop ) end end ensure command_queue . clear repository . clear end end end
Executes the given commands in a single transactional block as implemented by the +transaction_provider+
For each command:
Executes the given commands in a single transactional block as implemented by the + transaction_provider + For each command :