diff --git a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/streamr/Pinger.java b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/streamr/Pinger.java
index dd7f5642d..b46765287 100644
--- a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/streamr/Pinger.java
+++ b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/streamr/Pinger.java
@@ -1,6 +1,7 @@
 package net.i2p.i2ptunnel.streamr;
 
 import net.i2p.i2ptunnel.udp.*;
+import net.i2p.util.I2PAppThread;
 
 /**
  *
@@ -9,7 +10,7 @@ import net.i2p.i2ptunnel.udp.*;
 public class Pinger implements Source, Runnable {
 
     public Pinger() {
-        this.thread = new Thread(this);
+        this.thread = new I2PAppThread(this);
     }
 
     public void setSink(Sink sink) {
diff --git a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/udp/I2PSource.java b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/udp/I2PSource.java
index 68a9d90a2..2f59418a5 100644
--- a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/udp/I2PSource.java
+++ b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/udp/I2PSource.java
@@ -6,6 +6,7 @@ import java.util.concurrent.BlockingQueue;
 import net.i2p.client.I2PSession;
 import net.i2p.client.I2PSessionListener;
 import net.i2p.client.datagram.I2PDatagramDissector;
+import net.i2p.util.I2PAppThread;
 
 /**
  *
@@ -33,7 +34,7 @@ public class I2PSource implements Source, Runnable {
         this.sess.setSessionListener(new Listener());
         
         // create thread
-        this.thread = new Thread(this);
+        this.thread = new I2PAppThread(this);
     }
     
     public void setSink(Sink sink) {
diff --git a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/udp/UDPSource.java b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/udp/UDPSource.java
index 6f1a20e5f..23d4b8048 100644
--- a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/udp/UDPSource.java
+++ b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/udp/UDPSource.java
@@ -3,6 +3,8 @@ package net.i2p.i2ptunnel.udp;
 import java.net.DatagramSocket;
 import java.net.DatagramPacket;
 
+import net.i2p.util.I2PAppThread;
+
 /**
  *
  * @author welterde
@@ -19,13 +21,13 @@ public class UDPSource implements Source, Runnable {
         }
         
         // create thread
-        this.thread = new Thread(this);
+        this.thread = new I2PAppThread(this);
     }
 
     /** use socket from UDPSink */
     public UDPSource(DatagramSocket sock) {
         this.sock = sock;
-        this.thread = new Thread(this);
+        this.thread = new I2PAppThread(this);
     }
     
     public void setSink(Sink sink) {