Register notification in all processes, not just server

ringpiano/lib/ringpiano.rb

@@ -10,12 +10,3 @@ module RingPiano
 end
 
 require 'ringpiano/server'
-
-if $0 == __FILE__
-  server = RingPiano::Server.new
-  if defined?(JRUBY_VERSION)
-    RingPiano::Soundboard.new(server)
-    RingPiano::Keyboard.new(server)
-  end
-  DRb.thread.join
-end

ringpiano/lib/ringpiano/keyboard.rb

@@ -48,7 +48,6 @@ def initialize(server = nil)
 
     def register
       @server.register(:Keyboard, DRbObject.new(self), @server.name)
-      LOG.info "Registered Keyboard: #{@server.name}"
     end
 
     def key_to_note(event)

ringpiano/lib/ringpiano/server.rb

@@ -48,12 +48,6 @@ def start_ring_server
       ts = Rinda::TupleSpace.new
       @ring_server = Rinda::RingServer.new(ts)
       LOG.info "Started Ring server with primary: #{ts}"
-      Thread.new do
-        ts.notify('write', [:name, nil, nil, nil]).each do |event,tuple|
-          LOG.info "Registered service: #{tuple[1]} #{tuple[3]}"
-        end
-        DRb.thread.join
-      end
     end
 
     def ring_finger
@@ -64,6 +58,16 @@ def ring_finger
           Rinda::RingFinger.finger.lookup_ring_any
           Rinda::RingFinger.primary
         end
+        Thread.new do
+          @ring_finger.notify(nil, [:name, nil, nil, nil]).each do |event, tuple|
+            if event == 'write'
+              LOG.info "Registered service: #{tuple[1]} #{tuple[3]}"
+            else
+              LOG.info "Unregistered service: #{tuple[1]} #{tuple[3]}"
+            end
+          end
+          DRb.thread.join
+        end
         LOG.info "Using primary #{@ring_finger}"
       rescue Exception => e
         LOG.debug e

ringpiano/lib/ringpiano/soundboard.rb

@@ -15,7 +15,6 @@ def initialize(server = nil)
 
     def register
       @server.register(:Soundboard, DRbObject.new(self), @server.name)
-      LOG.info "Registered Soundboard: #{@server.name}"
     end
 
     def note_on(note, volume)