Contents

#!/usr/bin/env ruby
# frozen_string_literal: true

require 'ruby_rabbitmq_janus'

@t = RubyRabbitmqJanus::RRJ.new
@e = RubyRabbitmqJanus::Janus::Concurrencies::Event.instance

def case_event(data, jsep)
  puts "REASON : Event : #{data} -- #{jsep}"
end

def case_hangup(data)
  puts "REASON : Hangup : #{data}"
end

def case_error(data)
  puts "REASON : Error : #{data}"
end

def case_stop
  puts 'REASON : Stop'
  Thread.current.stop
end

events = lambda do |reason, data, jsep = nil|
  puts "Execute block code with reason : #{reason}"
  case reason
  when 'event' then case_event(data, jsep)
  when 'hangup' then case_hangup(data)
  when 'error' then case_error(data)
  when 'stop' then case_stop
  else
    puts 'REASON default'
  end
  puts " --\n\r"
end

puts '## Start listen Block'
@e.run(&events)
puts '## End listen block'

puts '## APPS RUNNING'
loop do
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
ruby_rabbitmq_janus-1.1.2	listen.rb