Sha256: 08ad405a4d5da91b3bbc63c06369390c4d95fc9b5d1f25ad78535e533b176134
Contents?: true
Size: 1.05 KB
Versions: 3
Compression:
Stored size: 1.05 KB
Contents
# -*- coding: utf-8 -*- require File.expand_path(File.dirname(__FILE__) + '/../../spec_helper') require 'amqp' config_filepath = File.expand_path("../../mq_config.yml", File.dirname(__FILE__)) if File.exist?(config_filepath) && (ENV['TENGINE_EVENT_MQ_TEST'] =~ /true|on/i) describe "Tengine::Mq::Suite" do before do # キューをsubscribeすることで、キューを作ります @config = YAML.load_file(config_filepath) EM.run_test do @mq_suite = Tengine::Mq::Suite.new(@config) @mq_suite.queue.subscribe do |metadata, msg| # 何もしません end EM.add_timer(1) do @mq_suite.connection.close{ EM.stop_event_loop } end end end it "EM.run{...} を複数回実行できる" do EM.run_test{ @mq_suite.exchange.publish("foo"){ @mq_suite.connection.close{ EM.stop_event_loop } } } EM.run_test{ @mq_suite.exchange.publish("foo"){ @mq_suite.connection.close{ EM.stop_event_loop } } } end end end
Version data entries
3 entries across 3 versions & 1 rubygems
Version | Path |
---|---|
tengine_event-1.2.2 | spec/tengine/mq/connect_actually_spec.rb |
tengine_event-1.2.1 | spec/tengine/mq/connect_actually_spec.rb |
tengine_event-1.2.0 | spec/tengine/mq/connect_actually_spec.rb |