Index: server.scm
==================================================================
--- server.scm
+++ server.scm
@@ -40,15 +40,15 @@
 ;; [x]  [ ]    3. Add create of pullport and pubport with finding of available ports
 ;; [x]  [ ]    4. Add client compose of request
 ;; [x]  [ ]        - name of client: testname/itempath-test_id-hostname 
 ;; [x]  [ ]        - name of request: callname, params
 ;; [x]  [ ]        - request key: f(clientname, callname, params)
-;; [ ]  [ ]    5. Add processing of subscription hits
-;; [ ]  [ ]        - done when get key 
-;; [ ]  [ ]        - return results
-;; [ ]  [ ]    6. Add timeout processing
-;; [ ]  [ ]        - after 60 seconds
+;; [x]  [ ]    5. Add processing of subscription hits
+;; [x]  [ ]        - done when get key 
+;; [x]  [ ]        - return results
+;; [x]  [ ]    6. Add timeout processing
+;; [x]  [ ]        - after 60 seconds
 ;; [ ]  [ ]            i. check server alive, connect to new if necessary
 ;; [ ]  [ ]           ii. resend request
 ;; [ ]  [ ]    7. Turn self ping back on
 
 (define (server:make-server-url hostport)
@@ -373,16 +373,16 @@
 		   ;;      		 (server:self-ping server-info)
 		   ;;      		 ))
 		   ;;      	     "Self ping"))
 		   (th2 (make-thread (lambda ()
 				       (server:run (args:get-arg "-server"))) "Server run"))
-		   ;; (th3 (make-thread (lambda ()(server:keep-running)) "Keep running"))
+		   (th3 (make-thread (lambda ()(server:keep-running)) "Keep running"))
 		   )
 	      (set! *client-non-blocking-mode* #t)
 	      ;; (thread-start! th1)
 	      (thread-start! th2)
-	      ;; (thread-start! th3)
+	      (thread-start! th3)
 	      (set! *didsomething* #t)
 	      ;; (thread-join! th3)
 	      (thread-join! th2)
 	      )
 	    (debug:print 0 "ERROR: Failed to setup for megatest")))