0) Uncomment line:admin=admin,admin in etc/users.properties 1) Add <transportConnector name= "amqp" uri= "amqp+nio: //localhost:5672" /> and set restartAllowed="true" in broker configuration in activemq.xml 2) run fuse 3) run test case attached. org.apache.activemq.transport.amqp.AmqpProtocolException: Could not process AMQP commands at org.apache.activemq.transport.amqp.AmqpProtocolConverter.onFrame(AmqpProtocolConverter.java:317) at org.apache.activemq.transport.amqp.AmqpProtocolConverter.onAMQPData(AmqpProtocolConverter.java:224) at org.apache.activemq.transport.amqp.AmqpTransportFilter.onCommand(AmqpTransportFilter.java:96) at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83) at org.apache.activemq.transport.amqp.AmqpNioTransportHelper.processCommand(AmqpNioTransportHelper.java:116) at org.apache.activemq.transport.amqp.AmqpNioTransport.serviceRead(AmqpNioTransport.java:110) at org.apache.activemq.transport.amqp.AmqpNioTransport.access$000(AmqpNioTransport.java:43) at org.apache.activemq.transport.amqp.AmqpNioTransport$1.onSelect(AmqpNioTransport.java:68) at org.apache.activemq.transport.nio.SelectorSelection.onSelect(SelectorSelection.java:94) at org.apache.activemq.transport.nio.SelectorWorker$1.run(SelectorWorker.java:119) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at java.lang. Thread .run( Thread .java:744) Caused by: org.apache.activemq.broker.BrokerStoppedException: Broker BrokerService[amq] is being stopped at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:153) at org.apache.activemq.transport.amqp.AmqpTransportFilter.sendToActiveMQ(AmqpTransportFilter.java:111) at org.apache.activemq.transport.amqp.AmqpProtocolConverter.sendToActiveMQ(AmqpProtocolConverter.java:1291) at org.apache.activemq.transport.amqp.AmqpProtocolConverter.onConnectionOpen(AmqpProtocolConverter.java:428) at org.apache.activemq.transport.amqp.AmqpProtocolConverter.onFrame(AmqpProtocolConverter.java:268) ... 12 more