Amazon MQ 支持以下 JMS 版本:
示例代码:
// 使用 JMS 1.1 ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(endpointUrl); Connection connection = connectionFactory.createConnection(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); Destination destination = session.createQueue(queueName); MessageProducer producer = session.createProducer(destination);
// 使用 ActiveMQ 5.x ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(endpointUrl); Connection connection = connectionFactory.createConnection(); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); Destination destination = session.createQueue(queueName); MessageProducer producer = session.createProducer(destination);