diff --git a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/AmqpTestSupport.java b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/AmqpTestSupport.java
index 6f1c31ac50..e24412df1d 100644
--- a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/AmqpTestSupport.java
+++ b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/AmqpTestSupport.java
@@ -124,22 +124,26 @@ public class AmqpTestSupport {
         TransportConnector connector = null;
 
         if (isUseTcpConnector()) {
-            connector = brokerService.addConnector("amqp://0.0.0.0:" + port);
+            connector = brokerService.addConnector(
+                "amqp://0.0.0.0:" + port + "?transport.transformer=" + getAmqpTransformer());
             port = connector.getConnectUri().getPort();
             LOG.debug("Using amqp port " + port);
         }
         if (isUseSslConnector()) {
-            connector = brokerService.addConnector("amqp+ssl://0.0.0.0:" + sslPort);
+            connector = brokerService.addConnector(
+                "amqp+ssl://0.0.0.0:" + sslPort + "?transport.transformer=" + getAmqpTransformer());
             sslPort = connector.getConnectUri().getPort();
             LOG.debug("Using amqp+ssl port " + sslPort);
         }
         if (isUseNioConnector()) {
-            connector = brokerService.addConnector("amqp+nio://0.0.0.0:" + nioPort);
+            connector = brokerService.addConnector(
+                "amqp+nio://0.0.0.0:" + nioPort + "?transport.transformer=" + getAmqpTransformer());
             nioPort = connector.getConnectUri().getPort();
             LOG.debug("Using amqp+nio port " + nioPort);
         }
         if (isUseNioPlusSslConnector()) {
-            connector = brokerService.addConnector("amqp+nio+ssl://0.0.0.0:" + nioPlusSslPort);
+            connector = brokerService.addConnector(
+                "amqp+nio+ssl://0.0.0.0:" + nioPlusSslPort + "?transport.transformer=" + getAmqpTransformer());
             nioPlusSslPort = connector.getConnectUri().getPort();
             LOG.debug("Using amqp+nio+ssl port " + nioPlusSslPort);
         }
@@ -161,6 +165,10 @@ public class AmqpTestSupport {
         return false;
     }
 
+    protected String getAmqpTransformer() {
+        return "jms";
+    }
+
     public void startBroker() throws Exception {
         if (brokerService != null) {
             throw new IllegalStateException("Broker is already created.");