mqjava代码 java中的mq( 三 )


jdbcPersistenceAdapter dataDirectory="${activemq.base}/data" dataSource="#derby-ds"/
/persistenceAdapter
在配置文件中的broker节点外增加
bean id="derby-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"
property name="driverClassName" value="https://www.04ip.com/post/com.mysql.jdbc.Driver"/
property name="url" value="https://www.04ip.com/post/jdbc:mysql://localhost/activemq?relaxAutoCommit=true"/
property name="username" value="https://www.04ip.com/post/activemq"/
property name="password" value="https://www.04ip.com/post/activemq"/
property name="maxActive" value="https://www.04ip.com/post/200"/
property name="poolPreparedStatements" value="https://www.04ip.com/post/true"/
/bean
从配置中可以看出数据库的名称是activemq,需要手动在MySql中增加这个库 。
然后重新启动消息队列,会发现多了3张表
1:activemq_acks
2:activemq_lock
3:activemq_msgs
【mqjava代码 java中的mq】关于mqjava代码和java中的mq的介绍到此就结束了,不知道你从中找到你需要的信息了吗 ?如果你还想了解更多这方面的信息,记得收藏关注本站 。

推荐阅读