diff --git a/apps/streaming/java/src/net/i2p/client/streaming/impl/Packet.java b/apps/streaming/java/src/net/i2p/client/streaming/impl/Packet.java
index 032f8117a..77de11061 100644
--- a/apps/streaming/java/src/net/i2p/client/streaming/impl/Packet.java
+++ b/apps/streaming/java/src/net/i2p/client/streaming/impl/Packet.java
@@ -12,7 +12,6 @@ import net.i2p.data.DataFormatException;
 import net.i2p.data.DataHelper;
 import net.i2p.data.Destination;
 import net.i2p.data.Signature;
-import net.i2p.data.SigningPrivateKey;
 import net.i2p.data.SigningPublicKey;
 import net.i2p.util.Log;
 
@@ -72,13 +71,13 @@ class Packet {
     private long _receiveStreamId;
     private long _sequenceNum;
     private long _ackThrough;
-    private long _nacks[];
+    protected long _nacks[];
     private int _resendDelay;
     private int _flags;
     private ByteArray _payload;
     // the next four are set only if the flags say so
-    private Signature _optionSignature;
-    private Destination _optionFrom;
+    protected Signature _optionSignature;
+    protected Destination _optionFrom;
     private int _optionDelay;
     private int _optionMaxSize;
     private int _localPort;
@@ -420,7 +419,7 @@ class Packet {
      * @param fakeSigLen if 0, include the real signature in _optionSignature;
      *                   if nonzero, leave space for that many bytes
      */
-    private int writePacket(byte buffer[], int offset, int fakeSigLen) throws IllegalStateException {
+    protected int writePacket(byte buffer[], int offset, int fakeSigLen) throws IllegalStateException {
         int cur = offset;
         DataHelper.toLong(buffer, cur, 4, (_sendStreamId >= 0 ? _sendStreamId : STREAM_ID_UNKNOWN));
         cur += 4;
@@ -720,45 +719,6 @@ class Packet {
         }
         return ok;
     }
-
-    /**
-     * Sign and write the packet to the buffer (starting at the offset) and return
-     * the number of bytes written.
-     *
-     * @param buffer data to be written
-     * @param offset starting point in the buffer
-     * @param ctx Application Context
-     * @param key signing key
-     * @return Count of bytes written
-     * @throws IllegalStateException if there is data missing or otherwise b0rked
-     */
-    public int writeSignedPacket(byte buffer[], int offset, I2PAppContext ctx, SigningPrivateKey key) throws IllegalStateException {
-        setFlag(FLAG_SIGNATURE_INCLUDED);
-        int size = writePacket(buffer, offset, key.getType().getSigLen());
-        _optionSignature = ctx.dsa().sign(buffer, offset, size, key);
-        //if (false) {
-        //    Log l = ctx.logManager().getLog(Packet.class);
-        //    l.error("Signing: " + toString());
-        //    l.error(Base64.encode(buffer, 0, size));
-        //    l.error("Signature: " + Base64.encode(_optionSignature.getData()));
-        //}
-        // jump into the signed data and inject the signature where we 
-        // previously placed a bunch of zeroes
-        int signatureOffset = offset 
-                              + 4 // sendStreamId
-                              + 4 // receiveStreamId
-                              + 4 // sequenceNum
-                              + 4 // ackThrough
-                              + (_nacks != null ? 4*_nacks.length + 1 : 1)
-                              + 1 // resendDelay
-                              + 2 // flags
-                              + 2 // optionSize
-                              + (isFlagSet(FLAG_DELAY_REQUESTED) ? 2 : 0)
-                              + (isFlagSet(FLAG_FROM_INCLUDED) ? _optionFrom.size() : 0)
-                              + (isFlagSet(FLAG_MAX_PACKET_SIZE_INCLUDED) ? 2 : 0);
-        System.arraycopy(_optionSignature.getData(), 0, buffer, signatureOffset, _optionSignature.length());
-        return size;
-    }
     
     @Override
     public String toString() {
diff --git a/apps/streaming/java/src/net/i2p/client/streaming/impl/PacketLocal.java b/apps/streaming/java/src/net/i2p/client/streaming/impl/PacketLocal.java
index f95ff335c..83153af72 100644
--- a/apps/streaming/java/src/net/i2p/client/streaming/impl/PacketLocal.java
+++ b/apps/streaming/java/src/net/i2p/client/streaming/impl/PacketLocal.java
@@ -9,6 +9,7 @@ import net.i2p.I2PAppContext;
 import net.i2p.data.Destination;
 import net.i2p.data.SessionKey;
 import net.i2p.data.SessionTag;
+import net.i2p.data.SigningPrivateKey;
 import net.i2p.util.Log;
 import net.i2p.util.SimpleTimer2;
 
@@ -189,8 +190,49 @@ class PacketLocal extends Packet implements MessageOutputStream.WriteStatus {
     public int getNACKs() { return _nackCount.get(); }
     
     public void setResendPacketEvent(SimpleTimer2.TimedEvent evt) { _resendEvent = evt; }
+
+    /**
+     * Sign and write the packet to the buffer (starting at the offset) and return
+     * the number of bytes written.
+     *
+     * @param buffer data to be written
+     * @param offset starting point in the buffer
+     * @param ctx Application Context
+     * @param key signing key
+     * @return Count of bytes written
+     * @throws IllegalStateException if there is data missing or otherwise b0rked
+     * @since 0.9.20 moved from Packet
+     */
+    public int writeSignedPacket(byte buffer[], int offset, I2PAppContext ctx, SigningPrivateKey key) throws IllegalStateException {
+        setFlag(FLAG_SIGNATURE_INCLUDED);
+        int size = writePacket(buffer, offset, key.getType().getSigLen());
+        _optionSignature = ctx.dsa().sign(buffer, offset, size, key);
+        //if (false) {
+        //    Log l = ctx.logManager().getLog(Packet.class);
+        //    l.error("Signing: " + toString());
+        //    l.error(Base64.encode(buffer, 0, size));
+        //    l.error("Signature: " + Base64.encode(_optionSignature.getData()));
+        //}
+        // jump into the signed data and inject the signature where we 
+        // previously placed a bunch of zeroes
+        int signatureOffset = offset 
+                              //+ 4 // sendStreamId
+                              //+ 4 // receiveStreamId
+                              //+ 4 // sequenceNum
+                              //+ 4 // ackThrough
+                              //+ 1 // resendDelay
+                              //+ 2 // flags
+                              //+ 2 // optionSize
+                              + 21
+                              + (_nacks != null ? 4*_nacks.length + 1 : 1)
+                              + (isFlagSet(FLAG_DELAY_REQUESTED) ? 2 : 0)
+                              + (isFlagSet(FLAG_FROM_INCLUDED) ? _optionFrom.size() : 0)
+                              + (isFlagSet(FLAG_MAX_PACKET_SIZE_INCLUDED) ? 2 : 0);
+        System.arraycopy(_optionSignature.getData(), 0, buffer, signatureOffset, _optionSignature.length());
+        return size;
+    }
     
-	@Override
+    @Override
     public StringBuilder formatAsString() {
         StringBuilder buf = super.formatAsString();