Class: RFlow::Components::File::OutputRawToFiles

Inherits:
RFlow::Component
  • Object
show all
Includes:
OutputToDisk
Defined in:
lib/rflow/components/file/output_raw_to_files.rb

Constant Summary

Constants included from OutputToDisk

RFlow::Components::File::OutputToDisk::DEFAULT_CONFIG

Instance Attribute Summary

Attributes included from OutputToDisk

#config, #directory_path, #file_name_prefix, #file_name_suffix

Instance Method Summary collapse

Methods included from OutputToDisk

#configure!, #write_to_file

Instance Method Details

#process_message(input_port, input_port_key, connection, message) ⇒ Object 



13
14
15
16
 
# File 'lib/rflow/components/file/output_raw_to_files.rb', line 13

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