Contents

module Euston
  module CommandBus
    def self.publish headers, command
      aggregate = AggregateCommandMap.deliver_command headers, command
      raise "No aggregate found to handle command: #{headers} #{command}" if aggregate.nil?

      Repository.save aggregate
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
euston-1.1.0	lib/euston/command_bus.rb
euston-1.1.0-java	lib/euston/command_bus.rb
euston-1.0.1	lib/euston/command_bus.rb
euston-1.0.1-java	lib/euston/command_bus.rb
euston-1.0.0	lib/euston/command_bus.rb