< 120

twitter-archive · Feb 24, 2011 · 85621c8 · 85621c8
1 parent fd4659f
commit 85621c8
Showing 1 changed file with 13 additions and 2 deletions.
diff --git a/src/main/scala/com/twitter/gizzard/GizzardServer.scala b/src/main/scala/com/twitter/gizzard/GizzardServer.scala
@@ -41,13 +41,24 @@ abstract class GizzardServer[S <: Shard, J <: JsonJob](config: ServerConfig) {
   }
 
   lazy val jobCodec     = new ReplicatingJsonCodec(nameServer.jobRelay, logUnparsableJob)
-  lazy val jobScheduler = new PrioritizingJobScheduler(jobPriorities.map(p => p -> config.jobQueues(p)(jobCodec)).toMap)
+  lazy val jobScheduler = new PrioritizingJobScheduler(jobPriorities map { p =>
+    p -> config.jobQueues(p)(jobCodec)
+  } toMap)
+
   lazy val copyScheduler = jobScheduler(copyPriority).asInstanceOf[JobScheduler[JsonJob]]
 
 
   // service wiring
 
-  lazy val managerServer       = new thrift.ManagerService(nameServer, copyFactory, jobScheduler, copyScheduler, repairFactory, repairPriority, diffFactory)
+  lazy val managerServer = new thrift.ManagerService(
+    nameServer,
+    copyFactory,
+    jobScheduler,
+    copyScheduler,
+    repairFactory,
+    repairPriority,
+    diffFactory)
+
   lazy val managerThriftServer = config.manager(new thrift.Manager.Processor(managerServer))
 
   lazy val jobInjectorServer       = new thrift.JobInjectorService(jobCodec, jobScheduler)