class RFlow::Components::File::OutputRawToFiles

Component that receives +RFlow::Message+s of type RFlow::Message::Data::Raw and writes new files to disk whose contents are the raw bytes of the message.

Public Instance Methods

process_message(input_port, input_port_key, connection, message) click to toggle source

RFlow-called method when a message is received. @return [void]

# File lib/rflow/components/file/output_raw_to_files.rb, line 21
def process_message(input_port, input_port_key, connection, message)
  return unless message.data_type_name == 'RFlow::Message::Data::Raw'
  write_to_file(message.properties) {|file| file.write(message.data.raw) }
end