Class: Cottontail::Consumer::Session

Inherits:
Object
  • Object
show all
Defined in:
lib/cottontail/consumer/session.rb

Overview

:nodoc:

Instance Method Summary collapse

Constructor Details

#initialize(consumer) ⇒ Session

Returns a new instance of Session.



6
7
8
9
10
# File 'lib/cottontail/consumer/session.rb', line 6

def initialize(consumer)
  @consumer = consumer
  @options, @block = @consumer.config.get(:session)
  @session = nil
end

Instance Method Details

#startObject



12
13
14
15
16
17
18
19
# File 'lib/cottontail/consumer/session.rb', line 12

def start
  stop unless @session.nil?

  @session = Bunny.new(@options)
  @session.start

  @consumer.instance_exec(@consumer, @session, &@block)
end

#stopObject



21
22
23
24
# File 'lib/cottontail/consumer/session.rb', line 21

def stop
  @session.stop if @session.respond_to?(:stop)
  @session = nil
end