Class: Promiscuous::AMQP::File::Subscriber::Metadata

Inherits:
Object
  • Object
show all
Defined in:
lib/promiscuous/amqp/file.rb

Instance Method Summary collapse

Constructor Details

#initialize(sub) ⇒ Metadata

Returns a new instance of Metadata.



69
70
71
# File 'lib/promiscuous/amqp/file.rb', line 69

def initialize(sub)
  @sub = sub
end

Instance Method Details

#ackObject



73
74
75
76
77
78
# File 'lib/promiscuous/amqp/file.rb', line 73

def ack
  @sub.lock.synchronize do
    @sub.num_pending -= 1
    @sub.prefetch_wait.signal
  end
end