ft_1_receiver.rb in ruote-beanstalk-2.1.11

- old
+ new

@@ -7,11 +7,11 @@
 #
 
 require File.join(File.dirname(__FILE__), 'base')
 
 
-class FtParticipantTest < Test::Unit::TestCase
+class FtReceiverTest < Test::Unit::TestCase
 
   def setup
 
     @bs_pid = Ruote::Beanstalk.fork(
       :address => '127.0.0.1',
@@ -29,11 +29,11 @@
     Process.kill(9, @bs_pid) if @bs_pid
   end
 
   class HelloServer
 
-    def initialize (port, tube_in, tube_out)
+    def initialize(port, tube_in, tube_out)
 
       @connection = ::Beanstalk::Connection.new("127.0.0.1:#{port}", tube_in)
 
       @thread = Thread.new do
         begin
@@ -57,15 +57,15 @@
 
   def test_participant_and_receiver
 
     @engine.register_participant(
       :alpha,
-      Ruote::Beanstalk::BsParticipant,
+      Ruote::Beanstalk::ParticipantProxy,
       'beanstalk' => '127.0.0.1:11300',
       'tube' => 'in')
 
-    Ruote::Beanstalk::BsReceiver.new(
+    Ruote::Beanstalk::Receiver.new(
       @engine, '127.0.0.1:11300', :tube => 'out')
 
     echo = HelloServer.new(11300, 'in', 'out')
 
     #@engine.context.logger.noisy = true
@@ -81,10 +81,10 @@
 
   def test_launchitem
 
     sp = @engine.register_participant '.+', Ruote::StorageParticipant
 
-    Ruote::Beanstalk::BsReceiver.new(
+    Ruote::Beanstalk::Receiver.new(
       @engine, '127.0.0.1:11300', :tube => 'launch')
 
     #@engine.context.logger.noisy = true
 
     pdef = Ruote.process_definition do