Sha256: 2bf99c5132a66c960cde8eac00710455bc9a3c7298c3d7b37d1c0350a27c3cf1

Contents?: true

Size: 1.12 KB

Versions: 4

Compression:

Stored size: 1.12 KB

Contents

require File.join(File.dirname(__FILE__) + "/../socket_mocker")
require File.join(File.dirname(__FILE__) + "/../bdrb_test_helper")
require File.join(File.dirname(__FILE__) + "/../bdrb_client_test_helper")

context "For Actual BackgrounDRB connection" do
  setup do
    options = {:schedules => {
        :foo_worker => { :barbar=>{:trigger_args=>"*/5 * * * * * *"}}},
      :backgroundrb=>{:port=>11008, :ip=>"0.0.0.0", :environment=> "production"},
      :client => "localhost:11001,localhost:11002,localhost:11003"
    }
    BDRB_CONFIG.set(options)
    @cluster = mock()
    @foo_connection = BackgrounDRb::Connection.new('localhost',1267,"crap")
    @foo_connection.stubs(:close_connection)
    class << @foo_connection
      attr_accessor :outgoing_data
      def dump_object data
        @outgoing_data = data
      end
    end
  end

  specify "should return nil if ask_result returns nil" do
    a = @foo_connection.ask_result(:worker => 'foo_worker',:worker_key => 'bar',:job_key => 10)
    a.should == nil
    @foo_connection.outgoing_data.should == {:type=>:get_result, :job_key=>10, :worker=>"foo_worker", :worker_key=>"bar"}
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
backgroundrb-rails3-1.1.3 test/client/test_bdrb_connection.rb
backgroundrb-rails3-1.1.2 test/client/test_bdrb_connection.rb
backgroundrb-rails3-1.1.1 test/client/test_bdrb_connection.rb
backgroundrb-rails3-1.1 test/client/test_bdrb_connection.rb