diff --git a/router/java/src/net/i2p/router/transport/CommSystemFacadeImpl.java b/router/java/src/net/i2p/router/transport/CommSystemFacadeImpl.java
index a28ab89f1..495e499f2 100644
--- a/router/java/src/net/i2p/router/transport/CommSystemFacadeImpl.java
+++ b/router/java/src/net/i2p/router/transport/CommSystemFacadeImpl.java
@@ -48,7 +48,8 @@ public class CommSystemFacadeImpl extends CommSystemFacade {
     }
     
     public void processMessage(OutNetMessage msg) {	
-        _context.jobQueue().addJob(new GetBidsJob(_context, this, msg));
+        GetBidsJob j = new GetBidsJob(_context, this, msg);
+        j.runJob();
     }
     
     public String renderStatusHTML() { return _manager.renderStatusHTML(); }
diff --git a/router/java/src/net/i2p/router/transport/tcp/TCPTransport.java b/router/java/src/net/i2p/router/transport/tcp/TCPTransport.java
index bfa381180..b747766d5 100644
--- a/router/java/src/net/i2p/router/transport/tcp/TCPTransport.java
+++ b/router/java/src/net/i2p/router/transport/tcp/TCPTransport.java
@@ -119,7 +119,9 @@ public class TCPTransport extends TransportImpl {
      * and it should not block
      */
     protected void outboundMessageReady() {
-        _context.jobQueue().addJob(new NextJob());
+        //_context.jobQueue().addJob(new NextJob());
+        NextJob j = new NextJob();
+        j.runJob();
     }
     
     private class NextJob extends JobImpl {