fix setting up hshaserver args

Nathan Marz · Nathan Marz · commit 4eb942239e4a · 2011-10-18T22:06:49.000-07:00
diff --git a/src/clj/backtype/storm/daemon/drpc.clj b/src/clj/backtype/storm/daemon/drpc.clj
@@ -64,11 +64,13 @@
   ([spout-adder]
     (launch-server! DEFAULT-PORT spout-adder))
   ([port spout-adder]
-    (let [service-handler (service-handler spout-adder port)          
-          options (THsHaServer$Args. (TNonblockingServerSocket. port))
-          _ (set! (. options maxWorkerThreads) 64)
-          _ (set! (. options processor) (DistributedRPC$Processor. service-handler)) 
-          _ (set! (. options protocolFactory) (TBinaryProtocol$Factory.))
+    (let [service-handler (service-handler spout-adder port)     
+          options (-> (TNonblockingServerSocket. port)
+                    (THsHaServer$Args.)
+                    (.workerThreads 64)
+                    (.protocolFactory (TBinaryProtocol$Factory.))
+                    (.processor (DistributedRPC$Processor. service-handler))
+                    )
           server (THsHaServer. options)]
       (.addShutdownHook (Runtime/getRuntime) (Thread. (fn [] (.stop server))))
       (log-message "Starting Distributed RPC server...")
diff --git a/src/clj/backtype/storm/daemon/nimbus.clj b/src/clj/backtype/storm/daemon/nimbus.clj
@@ -607,13 +607,12 @@
 (defn launch-server! [conf]
   (validate-distributed-mode! conf)
   (let [service-handler (service-handler conf)
-        options (THsHaServer$Args.
-                  (TNonblockingServerSocket. (int (conf NIMBUS-THRIFT-PORT))))
-        _ (set! (. options workerThreads) 64)
-        _ (set! (. options processor) (Nimbus$Processor. service-handler))
-        _ (set! (. options protocolFactory) (TBinaryProtocol$Factory.))
-        _ (set! (. options maxWorkerThreads) 64)
-       
+        options (-> (TNonblockingServerSocket. (int (conf NIMBUS-THRIFT-PORT)))
+                    (THsHaServer$Args.)
+                    (.workerThreads 64)
+                    (.protocolFactory (TBinaryProtocol$Factory.))
+                    (.processor (Nimbus$Processor. service-handler))
+                    )
        server (THsHaServer. options)]
     (.addShutdownHook (Runtime/getRuntime) (Thread. (fn [] (.shutdown service-handler) (.stop server))))
     (log-message "Starting Nimbus server...")
