从WebSphere MQ迁移到Active MQ

Question

有一个类似的问题过程，从IBM MQ迁移到ActiveMQ，它是关闭的，但我将尝试。我们的客户希望从WebSphere MQ迁移到Active MQ。在上面提到的问题中，有人说，对于JMS，这种迁移在理论上将包括应用程序的重新配置。我们的客户说他们的应用使用自动生成的.bindings文件。那么，是否有可能通过编辑.binding文件并将活动MQ的.jar放入java类路径，或者需要一些其他配置来使应用程序与活动MQ一起工作?

Answer 1

为了检查这一点，我尝试了以下命令

a)使用JMSAdmin创建WMQ绑定文件。一旦我创建了QCF和Queue，我就能够通过JMS查找和发送消息了。

b)对于设置为生成.bindings文件的AMQ, IBM有一些示例代码来生成binding文件。

完成后，我使用完全相同的代码发送消息，消息被完美地发送到AMQ和WMQ

这是我能够互操作的示例代码。

public void sendMessages() {
        ConnectionFactory connectionFactory;
        Connection con = null;
        Session session = null;
        MessageProducer producer = null;
        //create initial context properties
        Properties initialContextProperties = new Properties();
        initialContextProperties.put("java.naming.factory.initial", "com.sun.jndi.fscontext.RefFSContextFactory");
        initialContextProperties.put(Context.PROVIDER_URL, "file:/C:/JNDI-Directory/AMQ");
        initialContextProperties.setProperty("transport.jms.security.authentication", "none");
        try {
            InitialContext initialContext = new InitialContext(initialContextProperties);
            //create connection factory object
            //ivtQCF - created connection factory object in IBM-MQ
            connectionFactory = (ConnectionFactory) initialContext.lookup("confact2");
            con = connectionFactory.createConnection();
            con.start();
            session = con.createSession(false, Session.AUTO_ACKNOWLEDGE);
            //localq - created queue in IBM-MQ
            Destination destination = (Destination) initialContext.lookup("dest");
            producer = session.createProducer(destination);
            String msg = "SAMPLE MESSAGE PLACED TO QUEUE";
            TextMessage textMessage = session.createTextMessage(msg);
            producer.send(textMessage);
            con.close();
            session.close();
            producer.close();
        } catch (NamingException e) {
            throw new RuntimeException("Unable to send jms messages", e);
        } catch (JMSException e) {
            throw new RuntimeException("Unable to send jms messages", e);
        }
    }