diff --git a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpWireFormat.java b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpWireFormat.java
index 5d261f9c85..b5c8f593ae 100644
--- a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpWireFormat.java
+++ b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpWireFormat.java
@@ -49,7 +49,7 @@ public class AmqpWireFormat implements WireFormat {
     private int connectAttemptTimeout = DEFAULT_CONNECTION_TIMEOUT;
     private int idelTimeout = DEFAULT_IDLE_TIMEOUT;
     private int producerCredit = DEFAULT_PRODUCER_CREDIT;
-    private String transformer = InboundTransformer.TRANSFORMER_NATIVE;
+    private String transformer = InboundTransformer.TRANSFORMER_JMS;
 
     private boolean magicRead = false;
     private ResetListener resetListener;