Grails 中的 KahaDb 属性

Question

通过 JMS 插件在 Grails 中使用 ActiveMQ 我不知道如何设置 KahaDb 持久性属性。

试过类似的东西：

amq.broker(useJmx: true, persistent: true) {
    amq.transportConnectors() {
        amq.transportConnector(uri: "tcp://0.0.0.0:61616")
    }
    amq.persistenceAdapter() {
        amq.kahaDB(directory:${application.config.grails.moviesxd.activemq.kahadb},
                   checksumJournalFiles:true,
                   checkForCorruptJournalFiles:true,
                   ignoreMissingJournalfiles:true)          
    }
}

但是我明白了

groovy.lang.GroovyRuntimeException: Namespace prefix: kahadb is not bound to a URI

似乎无法识别 kahadb 前缀，但我无法在任何地方找到有关如何执行此操作的文档。

Answer 1

作为解决方法，我所做的是添加一个额外的 resources.xml 并使用标准且有据可查的 XML 属性：

<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:amq="http://activemq.apache.org/schema/core" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
  http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd">

    <amq:broker useJmx="true" persistent="true">
        <amq:transportConnectors>
            <amq:transportConnector uri="tcp://0.0.0.0:61616" />
        </amq:transportConnectors>
        <amq:persistenceAdapter>
            <amq:kahaDB directory="${grails.moviesxd.activemq.kahadb.path}" />
        </amq:persistenceAdapter>
    </amq:broker>

    <amq:connectionFactory id="amqConnectionFactory"
        brokerURL="vm://localhost" />

    <bean id="jmsConnectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
        <constructor-arg ref="amqConnectionFactory" />
    </bean>

</beans>

...但我必须这样做很遗憾...如果我得到答案仍然会很棒。

Answer 2

你只是错过了相当于

xmlns:amq='http://activemq.apache.org/schema/core'

这将是

xmlns amq:'http://activemq.apache.org/schema/core'

（有关详细信息，请参阅 reference docs - 搜索 "Using Spring Namespaces"）

所以整个转换将是

import org.springframework.jms.connection.SingleConnectionFactory

xmlns amq:'http://activemq.apache.org/schema/core'

amq.broker(useJmx: true, persistent: true) {
    amq.transportConnectors {
        amq.transportConnector(uri: 'tcp://0.0.0.0:61616')
    }
    amq.persistenceAdapter {
        amq.kahaDB(directory: application.config.grails.moviesxd.activemq.kahadb,
                   checksumJournalFiles: true,
                   checkForCorruptJournalFiles: true,
                   ignoreMissingJournalfiles: true)
    }
}

amq.connectionFactory(id: 'amqConnectionFactory', brokerURL: 'vm://localhost')

jmsConnectionFactory(SingleConnectionFactory, ref('amqConnectionFactory'))

Grails 中的 KahaDb 属性

KahaDb properties in Grails

grails

activemq