Contents

# !SLIDE :capture_code_output true
# Asynchronous beanstalkd service

require 'example_helper'
require 'asir/transport/beanstalk'
require 'asir/coder/zlib'
begin
  Email.asir.transport = t =
    ASIR::Transport::Beanstalk.new(:address => '127.0.0.1', :port => 30904)
  t.encoder =
    ASIR::Coder::Chain.new(:encoders =>
                           [ ASIR::Coder::Marshal.new,
                            ASIR::Coder::Zlib.new, ])
  t.start_conduit!; sleep 1
  pr Email.asir.send_email(:pdf_invoice,
                             :to => "[e-mail]", :customer => @customer)
  sleep 2
  server_process do
    t.prepare_server!
    t.run_server!
  end
rescue Object => err
  $stderr.puts "#{err.inspect}\n#{err.backtrace * "\n"}"
ensure
  t.close; sleep 3; server_kill; sleep 2
  t.stop_conduit!
end

# !SLIDE END
# EXPECT: : client process
# EXPECT: : server process
# EXPECT: : Email.send_mail :pdf_invoice
# EXPECT: : pr: nil

Version data entries

18 entries across 18 versions & 2 rubygems

Version	Path
asir_beanstalk-1.2.8	example/ex01.rb
asir_beanstalk-1.2.7	example/ex01.rb
asir_beanstalk-1.2.6	example/ex01.rb
asir_beanstalk-1.2.5	example/ex01.rb
asir_beanstalk-1.2.3	example/ex01.rb
asir_beanstalk-1.2.0	example/ex01.rb
asir_beanstalk-1.1.5	example/ex01.rb
asir_beanstalk-1.1.4	example/ex01.rb
asir_beanstalk-1.1.3	example/ex01.rb
asir_beanstalk-1.1.2	example/ex01.rb
asir_beanstalk-1.1.1	example/ex01.rb
asir-1.1.0	example/ex12.rb
asir-1.0.8	example/ex12.rb
asir-1.0.7	example/ex12.rb
asir-1.0.6	example/ex12.rb
asir-1.0.5	example/ex12.rb
asir-1.0.4	example/ex12.rb
asir-1.0.1	example/ex12.rb