# File lib/amqp/channel.rb, line 797 def send(*args) conn.callback { |c| @_send_mutex.synchronize do args.each do |data| unless self.closed? data.ticket = @ticket if @ticket and data.respond_to? :ticket= log :sending, data c.send data, :channel => @channel else unless data.class == AMQP::Protocol::Channel::CloseOk raise ChannelClosedError.new(self) end end end end } end