# File lib/nanite/streaming.rb, line 110
    def subscribe_to_files(domain='global', write=false, &blk)
      Nanite::Log.info "subscribing to file broadcasts for #{domain}"
      @files ||= {}
      amq.queue("files#{domain}").bind(amq.topic('file broadcast'), :key => "nanite.filepeer.#{domain}").subscribe do |packet|
        case msg = serializer.load(packet)
        when FileStart
          @files[msg.token] = FileState.new(msg.token, msg.dest, domain, write, blk)
        when FileChunk, FileEnd
          if file = @files[msg.token]
            file.handle_packet(msg)
          end
        end
      end
    end