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