无法使用基于JMS的代码和amqp 1.0访问ActiveMQ

最好与jndi合作

public static void main(String[] args) throws JMSException, InterruptedException, NamingException {    Connection connection = null;    try {        Properties props = new Properties();        props.put(Context.INITIAL_CONTEXT_FACTORY, "org.apache.qpid.jms.jndi.JmsInitialContextFactory");        props.setProperty("connectionfactory.myFactoryLookup",     "amqp://localhost:5672");        props.put("topic." + "MyTOPIC", "customerTopic");        InitialContext ic = new InitialContext(props);        ConnectionFactory cf1 = (ConnectionFactory) ic.lookup("myFactoryLookup");        Topic topic = (Topic) ic.lookup("MyTOPIC");        connection = cf1.createConnection();        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);        MessageProducer producer = session.createProducer(topic);        connection.start();        for (int i = 0; i < 10; i++) { Message msg = session.createTextMessage("Task : " + i); producer.send(msg);        }        session.close();    } finally {        if (connection != null) { connection.close();        }    }}

更换

 <dependency>    <groupId>org.apache.qpid</groupId>    <artifactId>qpid-amqp-1-0-client-jms</artifactId>    <version>0.32</version></dependency>

通过

    <dependency>        <groupId>org.apache.qpid</groupId>        <artifactId>qpid-jms-client</artifactId>        <version>0.9.0</version>    </dependency>

在经纪人方面，您需要添加：

 <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?transport.transformer=jms"/>

参考http://activemq.apache.org/amqp.html