   (info @server-state)
   (when (:http-server? @server-state)
     (run-server (site #'all-routes) {:port (:port @server-state) :join? false}))
-  (tweet-processor server-state)
+  (let [{:keys [follow track handler credentials]} (:app @server-state)]
+    (start-filter-stream follow track handler credentials))
   (when (:backup? @server-state)
     (start-executor (:backup-folder @server-state))))
 

            [ceres.collector :refer [store set-db] :as collector]
            [ceres.curator :refer [get-articles-count get-news-diffusion get-news-frequencies] :as curator]
            [ceres.executor :refer [start-executor]]
            [gezwitscher.core :refer [gezwitscher]]
            [clojure.java.io :as io]
            [clojure.core.async :refer [close! put! timeout sub chan <!! >!! <! >! go go-loop] :as async]
            [taoensso.timbre :as timbre]))


  (initialize server-state "opt/server-config-1.edn")

  (def stop-stream
    (let [{:keys [follow track handler credentials]} (:app @server-state)]
      (start-filter-stream follow track handler credentials)))
  (stop-stream)

  (def stop-server
    (do
