diff --git a/core/java/src/net/i2p/data/i2cp/SendMessageMessage.java b/core/java/src/net/i2p/data/i2cp/SendMessageMessage.java
index 37e5ea5f15c8ac89bc5f99ba379eccc5f3bf4226..18f6c6df376b78a827ee04145313f57833cb088c 100644
--- a/core/java/src/net/i2p/data/i2cp/SendMessageMessage.java
+++ b/core/java/src/net/i2p/data/i2cp/SendMessageMessage.java
@@ -84,8 +84,8 @@ public class SendMessageMessage extends I2CPMessageImpl {
      */
     @Override
     public void readMessage(InputStream in, int length, int type) throws I2CPMessageException, IOException {
-        if (type != MESSAGE_TYPE)
-            throw new I2CPMessageException("Invalid message type (found: " + type + " supported: " + MESSAGE_TYPE
+        if (type != getType())
+            throw new I2CPMessageException("Invalid message type (found: " + type + " supported: " + getType()
                                            + " class: " + getClass().getName() + ")");
         if (length < 0) throw new IOException("Negative payload size");
 
@@ -129,7 +129,7 @@ public class SendMessageMessage extends I2CPMessageImpl {
         
         try {
             DataHelper.writeLong(out, 4, len);
-            DataHelper.writeLong(out, 1, MESSAGE_TYPE);
+            DataHelper.writeLong(out, 1, getType());
             _sessionId.writeBytes(out);
             _destination.writeBytes(out);
             _payload.writeBytes(out);