Class: Freddy::Adapters::MarchHareAdapter

Inherits:
Object
  • Object
show all
Defined in:
lib/freddy/adapters/march_hare_adapter.rb

Defined Under Namespace

Classes: Channel, Queue

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(hare) ⇒ MarchHareAdapter

Returns a new instance of MarchHareAdapter.



11
12
13
 
# File 'lib/freddy/adapters/march_hare_adapter.rb', line 11

def initialize(hare)
  @hare = hare
end

Class Method Details

.connect(config) ⇒ Object 



6
7
8
9
 
# File 'lib/freddy/adapters/march_hare_adapter.rb', line 6

def self.connect(config)
  hare = MarchHare.connect(config)
  new(hare)
end

Instance Method Details

#close ⇒ Object 



21
22
23
 
# File 'lib/freddy/adapters/march_hare_adapter.rb', line 21

def close
  @hare.close
end

#create_channel(prefetch: nil) ⇒ Object 



15
16
17
18
19
 
# File 'lib/freddy/adapters/march_hare_adapter.rb', line 15

def create_channel(prefetch: nil)
  hare_channel = @hare.create_channel
  hare_channel.basic_qos(prefetch) if prefetch
  Channel.new(hare_channel)
end