Module: Promiscuous::Subscriber::Lint::AMQP

Extended by:
ActiveSupport::Concern
Defined in:
lib/promiscuous/subscriber/lint/amqp.rb

Instance Method Summary collapse

Instance Method Details

#lint ⇒ Object 



12
13
14
15
16
17
18
 
# File 'lib/promiscuous/subscriber/lint/amqp.rb', line 12

def lint
  super

  if check_publisher
    raise "No publisher found for #{publisher}" if publisher.nil?
  end
end

#publisher ⇒ Object 



4
5
6
7
8
9
10
 
# File 'lib/promiscuous/subscriber/lint/amqp.rb', line 4

def publisher
  publishers.
    select { |pub| pub.superclass == Promiscuous::Publisher::Mock }.
    select { |pub| pub.to == from }.
    tap { |pubs| raise "#{from} has multiple publishers: #{pubs}" if pubs.size > 1 }.
    first
end