Method: Messaging::Fixtures::Writer.get_data

Defined in:
lib/messaging/fixtures/writer.rb

.get_data(writer, message_class) ⇒ Object 



22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
 
# File 'lib/messaging/fixtures/writer.rb', line 22

def self.get_data(writer, message_class)
  sink = writer.sink

  records = sink.written_records.select do |record|
    record.data.message.class == message_class
  end

  if records.length > 1
    raise Error, "More than one message written (Message Class: #{message_class})"
  end

  if records.empty?
    return nil
  end

  records.first.data
end