Index: transport/bio/BioReplicationTask.java
===================================================================
--- transport/bio/BioReplicationTask.java	(revision 792283)
+++ transport/bio/BioReplicationTask.java	(working copy)
@@ -61,7 +61,7 @@
         try {
             drainSocket();
         } catch ( Exception x ) {
-            log.error("Unable to service bio socket");
+            log.error("Unable to service bio socket", x);
         }finally {
             try {socket.close();}catch ( Exception ignore){}
             try {reader.close();}catch ( Exception ignore){}
@@ -76,7 +76,6 @@
     public synchronized void serviceSocket(Socket socket, ObjectReader reader) {
         this.socket = socket;
         this.reader = reader;
-        this.notify();		// awaken the thread
     }
     
     protected void execute(ObjectReader reader) throws Exception{
Index: transport/bio/BioReceiver.java
===================================================================
--- transport/bio/BioReceiver.java	(revision 792283)
+++ transport/bio/BioReceiver.java	(working copy)
@@ -150,6 +150,7 @@
             socket.setSoTimeout(getTimeout());
             ObjectReader reader = new ObjectReader(socket);
             task.serviceSocket(socket,reader);
+            getExecutor().execute(task);
         }//while
     }