Contents

Bunny::Session.class_eval do
  def open?
    true
  end
  alias connected? open?

  def open_connection
    true
  end

  def create_channel(n = nil, consumer_pool_size = 1)
    Bunny::Channel.new(self, n, Bunny::ConsumerWorkPool.new(consumer_pool_size || 1))
  end

  def next_channel_id
    1
  end

  def release_channel_id(i)
    true
  end

  def register_channel(ch)
    @channels[ch.number] = ch
  end

  def unregister_channel(ch)
    n = ch.number

    self.release_channel_id(n)
    @channels.delete(ch.number)
  end

  def initialize_transport
    true
  end

end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
sarcastic_bunny-0.0.1	lib/sarcastic_bunny/bunny_ext/session.rb