test/functional/ft_0_participant.rb in ruote-beanstalk-2.1.10 vs test/functional/ft_0_participant.rb in ruote-beanstalk-2.1.11
- old
+ new
@@ -30,11 +30,11 @@
class Watcher
attr_reader :jobs
- def initialize (port, tube=nil)
+ def initialize(port, tube=nil)
@connection = ::Beanstalk::Connection.new("127.0.0.1:#{port}", tube)
@jobs = []
@@ -54,11 +54,11 @@
def test_participant
@engine.register_participant(
:alpha,
- Ruote::Beanstalk::BsParticipant,
+ Ruote::Beanstalk::ParticipantProxy,
'beanstalk' => '127.0.0.1:11300')
watcher = Watcher.new(11300)
#@engine.context.logger.noisy = true
@@ -76,10 +76,10 @@
def test_participant_tube
@engine.register_participant(
:alpha,
- Ruote::Beanstalk::BsParticipant,
+ Ruote::Beanstalk::ParticipantProxy,
'beanstalk' => '127.0.0.1:11300',
'tube' => 'underground')
watcher0 = Watcher.new(11300)
watcher1 = Watcher.new(11300, 'underground')