java - 从 ActiveMQXASslConnectionFactory 实例创建 XAConnection 实例失败

Question

我在服务器端启用了 SSL 连接传输，并且我想创建到服务器的 SSL 连接。从 ActiveMQXASslConnectionFactory 实例创建 XAConnection 实例失败。这是我的代码:

ActiveMQXASslConnectionFactory sslConnectionFactory = new ActiveMQXASslConnectionFactory(mqUrl);
try {
    sslConnectionFactory.setKeyStore("file:" + keystoreFile);
    sslConnectionFactory.setKeyStorePassword(keystorePassword);
    sslConnectionFactory.setTrustStore("file:" + truststoreFile);
    sslConnectionFactory.setTrustStorePassword(truststorePassword);
} catch (Exception ex) {
}

XAConnection connection = sslConnectionFactory.createXAConnection();

当我运行示例代码时，它抛出异常:

Exception in thread "main" java.lang.NoSuchFieldError: xaAckMode
        at org.apache.activemq.ActiveMQXASslConnectionFactory.configureXAConnection(ActiveMQXASslConnectionFactory.java:84)
        at org.apache.activemq.ActiveMQXASslConnectionFactory.createActiveMQConnection(ActiveMQXASslConnectionFactory.java:79)
        at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:266)
        at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:238)
        at org.apache.activemq.ActiveMQXASslConnectionFactory.createXAConnection(ActiveMQXASslConnectionFactory.java:48)

这是一个错误吗？请帮忙。

Answer 1

我解决了这个问题。 pom.xml 中有不同版本的依赖项。我删除了它并且代码成功执行。