package core

import akka.actor.{ActorSystem, Props}
import org.apache.log4j.BasicConfigurator

object Main extends App {
  BasicConfigurator.configure()

  val query = args.mkString(" ")
  println(s"Running with query: $query")

  val system = ActorSystem()
  val producer = system.actorOf(Props(new ProducerActor))
  val stream = system.actorOf(Props(
    new TweetStreamerActor(TweetStreamerActor.twitterUri, producer, query)))

  stream ! "filter"
}

package core

import java.net.URLEncoder

import akka.actor.{Props, ActorSystem}

object Main extends App {
  val query = args.mkString(" ")
  println(s"Running with query: $query")

  val system = ActorSystem()
  val producer = system.actorOf(Props(new ProducerActor))
  val stream = system.actorOf(Props(
    new TweetStreamerActor(TweetStreamerActor.twitterUri, producer, query)))

  stream ! "filter"
}

--- 
+++ 
@@ -1,10 +1,11 @@
 package core
 
-import java.net.URLEncoder
-
-import akka.actor.{Props, ActorSystem}
+import akka.actor.{ActorSystem, Props}
+import org.apache.log4j.BasicConfigurator
 
 object Main extends App {
+  BasicConfigurator.configure()
+
   val query = args.mkString(" ")
   println(s"Running with query: $query")
 
Initialize logging on startup and correctly split tweet stream into tweets
