reactor.rb in junkie-0.1.2

- old
+ new

@@ -25,11 +25,10 @@
       @config = Config.get_config(self)
 
       log.info("Starting Junkie #{Junkie::VERSION}")
 
       @channels = {
-          encrypted: EM::Channel.new,
           episodes: EM::Channel.new,
           notifications: EM::Channel.new,
           info: EM::Channel.new,
           push_episode_count: EM::Channel.new,
           push_registration: EM::Channel.new,
@@ -37,10 +36,11 @@
 
       @pyload_observer = Junkie::Pyload::Observer.new(@channels)
       @twitter_notification = Junkie::Notification::Twitter.new(@channels)
       @dumper = Junkie::Notification::Dumper.new(@channels)
       @push_endpoint = Junkie::Push::Endpoint.new(@channels)
+      @redirect_resolver = Junkie::Resolver::RedirectResolver.new(@channels)
 
       @found_episodes = Hash.new
       build_procs # has to be called here
     end
 
@@ -100,10 +100,10 @@
             identifier = "%s@%s" % [episode.id, episode.series]
 
             if not @found_episodes.has_key? identifier
               log.info("Found new episode '#{episode}'")
 
-              @channels[:encrypted].push(episode)
+              @channels[:episodes].push(episode)
               @found_episodes[identifier] = episode
             end
           end
 
           # send out the current time out of the websocket