Method: MultipleMan::Connection.channel

Defined in:
lib/multiple_man/connection.rb

.channel ⇒ Object 



28
29
30
31
32
33
34
35
36
37
 
# File 'lib/multiple_man/connection.rb', line 28

def self.channel
  Thread.current.thread_variable_get(:multiple_man_current_channel) || begin
    channel = connection.create_channel
    channel_gc.push(channel)
    channel.confirm_select if MultipleMan.configuration.publisher_confirms
    Thread.current.thread_variable_set(:multiple_man_current_channel, channel)

    channel
  end
end