         resp (.recv server 0)]
     (is (= task (.task resp)))
     (is (= req_msg (String. (.message resp))))
+    (.close client)
+    (.close server)
     (.term context)))    
     
 (deftest test-server-delayed

        resp (.recv server 0)]
    (is (= task (.task resp)))
    (is (= req_msg (String. (.message resp))))
    (.term context)))    

(deftest test-batch

        resp (.recv server 0)]
    (is (= task (.task resp)))
    (is (= req_msg (String. (.message resp))))
    (.close client)
    (.close server)
    (.term context)))    

(deftest test-large-msg
