# File lib/amqp/channel.rb, line 1258 def self.default # TODO: clear this when connection is closed Thread.current[:mq] ||= AMQP::Channel.new end