Class: TranscodingMachine::Server::TranscodingEventListener

Inherits:
Object
  • Object
show all
Defined in:
lib/transcoding_machine/server/transcoding_event_listener.rb

Instance Method Summary collapse

Constructor Details

#initialize(message_properties) ⇒ TranscodingEventListener

Returns a new instance of TranscodingEventListener.



6
7
8
9
 
# File 'lib/transcoding_machine/server/transcoding_event_listener.rb', line 6

def initialize(message_properties)
  @message_properties = message_properties
  @result_queue = RightAws::SqsGen2.new.queue(message_properties[:result_queue])
end

Instance Method Details

#analyzed_source_file(source_file_attributes, source_media_format) ⇒ Object 



23
24
25
 
# File 'lib/transcoding_machine/server/transcoding_event_listener.rb', line 23

def analyzed_source_file(source_file_attributes, source_media_format)
  push_status(:analyzed, :media_format => source_media_format, :media_attributes => source_file_attributes)
end

#analyzing_source_file ⇒ Object 



19
20
21
 
# File 'lib/transcoding_machine/server/transcoding_event_listener.rb', line 19

def analyzing_source_file
  push_status(:analyzing)
end

#generated_thumbnail_file ⇒ Object 



31
32
33
 
# File 'lib/transcoding_machine/server/transcoding_event_listener.rb', line 31

def generated_thumbnail_file

end

#generating_thumbnail_file ⇒ Object 



27
28
29
 
# File 'lib/transcoding_machine/server/transcoding_event_listener.rb', line 27

def generating_thumbnail_file
  push_status(:creating_thumbnail)
end

#getting_source_file ⇒ Object 



11
12
13
 
# File 'lib/transcoding_machine/server/transcoding_event_listener.rb', line 11

def getting_source_file
  push_status(:downloading)
end

#got_source_file ⇒ Object 



15
16
17
 
# File 'lib/transcoding_machine/server/transcoding_event_listener.rb', line 15

def got_source_file

end

#push_status(status, options = {}) ⇒ Object 



51
52
53
54
55
56
 
# File 'lib/transcoding_machine/server/transcoding_event_listener.rb', line 51

def push_status(status, options = {})
  msg = @message_properties.clone
  msg[:status] = status
  msg.merge!(options)
  @result_queue.push(msg.to_yaml)
end

#put_destination_file(file_path, media_format) ⇒ Object 



47
48
49
 
# File 'lib/transcoding_machine/server/transcoding_event_listener.rb', line 47

def put_destination_file(file_path, media_format)
  push_status(:uploaded, :media_format => media_format, :destination_key => file_path)
end

#putting_destination_file(file_path, media_format) ⇒ Object 



43
44
45
 
# File 'lib/transcoding_machine/server/transcoding_event_listener.rb', line 43

def putting_destination_file(file_path, media_format)
  push_status(:uploading, :media_format => media_format, :destination_key => file_path)
end

#transcoded(media_format) ⇒ Object 



39
40
41
 
# File 'lib/transcoding_machine/server/transcoding_event_listener.rb', line 39

def transcoded(media_format)
  push_status(:transcoded, :media_format => media_format)
end

#transcoding(media_format) ⇒ Object 



35
36
37
 
# File 'lib/transcoding_machine/server/transcoding_event_listener.rb', line 35

def transcoding(media_format)
  push_status(:transcoding, :media_format => media_format)
end