Eventwired!

(TODO: Review this commit for future improvements on Eventwire)

Gemfile

@@ -5,6 +5,8 @@ gem 'rails', '3.0.0'
 gem 'uuidtools'
 gem 'ohm'
 
+gem 'eventwire', :git => 'git://github.com/cavalle/eventwire.git'
+
 gem 'em-redis', :require => false
 
 gem 'bunny',    :require => false

Gemfile.lock

@@ -1,3 +1,10 @@
+GIT
+  remote: git://github.com/cavalle/eventwire.git
+  revision: 073cdf9e82f557779ea4e97c646ecae3b895df5a
+  specs:
+    eventwire (0.0.1)
+      json
+
 GEM
   remote: http://rubygems.org/
   specs:
@@ -67,6 +74,7 @@ GEM
       term-ansicolor (~> 1.0.5)
       thor (>= 0.13.6)
     i18n (0.4.2)
+    json (1.6.1)
     json_pure (1.5.0)
     launchy (0.3.7)
       configuration (>= 0.0.5)
@@ -167,6 +175,7 @@ DEPENDENCIES
   bunny
   capybara
   em-redis
+  eventwire!
   ffi-rzmq
   foreman
   launchy

Procfile

@@ -1,2 +1,2 @@
 web: bundle exec thin start 
-bus: bundle exec rake event_bus:start
+bus: bundle exec rake environment eventwire:work --trace

config/initializers/infrastructure.rb

@@ -1,5 +1,13 @@
 Rails.application.class.configure do
-  config.event_bus = 'EventBus::Redis'
-  config.event_subscribers = %w{ClientReport ClientDetailsReport AccountDetailsReport MoneyTransferSaga}
-  config.to_prepare { EventBus.init }
+  config.to_prepare do 
+    # Initialize Eventwire before each request so that using the InProcess driver 
+    # in development the event handlers are declared only once
+    Eventwire.driver = Rails.env.test? ? 'InProcess' : 'Redis'
+    Eventwire.on_error do |ex|
+      raise ex
+    end
+    ClientReport; ClientDetailsReport; AccountDetailsReport; MoneyTransferSaga
+  end
 end
+
+

lib/infrastructure/domain_repository.rb

@@ -1,6 +1,8 @@
 module DomainRepository
 
   class << self
+
+    include Eventwire::Publisher
 
     def aggregates
       Thread.current[:"DomainRepositoryCurrentStore"]
@@ -48,7 +50,7 @@ def save(event)
     end
 
     def publish(event)
-      EventBus.publish(event)
+      publish_event(event.name, {:data => event.data})
     end
 
   end

lib/infrastructure/event_handler.rb

@@ -1,13 +1,13 @@
 module EventHandler
+  include Eventwire::Subscriber::DSL
+
   def on(*events, &block)
     events.each do |event_name|
-      ::EventBus.subscribe(event_name, "#{name}:#{increment_handlers_count}:#{event_name}", &block)
+      super(event_name) do |event|
+        event.data = event.data.to_hash.symbolize_keys
+        block.call(event)
+      end
     end
   end
 
-  def increment_handlers_count
-    @handlers_count ||= 0
-    @handlers_count += 1
-  end
-
 end

lib/tasks/event_bus.rake

@@ -1,4 +1 @@
-desc "Start Event Bus"
-task "event_bus:start" => :environment do
-  EventBus.start
-end
+require 'eventwire/tasks'

spec/acceptance/acceptance_helper.rb

@@ -8,21 +8,18 @@
 
   config.before(:each) do
     Ohm.flush
-    EventBus.purge
-    @t = Thread.new { EventBus.start }
-    @t.abort_on_exception = true
   end
 
   config.after(:each) do
-    EventBus.stop
-    @t.join(1)
-    @t.kill
     Capybara.reset_sessions!
   end
 end
 
+Eventwire.on_error do |ex|
+  raise ex
+end
+
 Capybara.app = Proc.new { |env|
-  EventBus.wait_for_events
   Rails.application.call(env)
 }
 

spec/acceptance/support/commands.rb

@@ -28,7 +28,6 @@ def execute_command(*args)
     DomainRepository.begin
     result = "#{args.shift}_command_handler".camelize.constantize.new.execute(*args)
     DomainRepository.commit
-    EventBus.wait_for_events
     result
   end