You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by Sparg <sp...@hotmail.es> on 2015/12/17 15:25:42 UTC
ActiveMQ - JDBC persistence MySQL: ACTIVEMQ_MSGS is empty
I'm implement the persistence with MySQL
(http://activemq.apache.org/jdbc-support.html). But when I check this table,
it's always empty.
<http://activemq.2283324.n4.nabble.com/file/n4705108/sqlCaptura.png>
-----------------------------------------------------------
[activemq.log]
-----------------------------------------------------------
2015-12-17 15:16:57,966 | INFO | Apache ActiveMQ 5.13.0 (localhost,
ID:PTLSF07-63181-1450361138461-0:1) is shutting down |
org.apache.activemq.broker.BrokerService | ActiveMQ ShutdownHook
2015-12-17 15:16:57,969 | INFO | Connector openwire stopped |
org.apache.activemq.broker.TransportConnector | ActiveMQ ShutdownHook
2015-12-17 15:16:57,971 | INFO | Connector amqp stopped |
org.apache.activemq.broker.TransportConnector | ActiveMQ ShutdownHook
2015-12-17 15:16:57,972 | INFO | Connector stomp stopped |
org.apache.activemq.broker.TransportConnector | ActiveMQ ShutdownHook
2015-12-17 15:16:57,974 | INFO | Connector mqtt stopped |
org.apache.activemq.broker.TransportConnector | ActiveMQ ShutdownHook
2015-12-17 15:16:57,974 | INFO | socketQueue interrupted - stopping |
org.apache.activemq.transport.tcp.TcpTransportServer | ActiveMQ Transport
Server Thread Handler:
mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600
2015-12-17 15:16:57,977 | ERROR | Could not accept connection :
java.lang.InterruptedException |
org.apache.activemq.broker.TransportConnector | ActiveMQ Transport Server
Thread Handler:
mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600
2015-12-17 15:16:57,989 | INFO | Connector ws stopped |
org.apache.activemq.broker.TransportConnector | ActiveMQ ShutdownHook
2015-12-17 15:16:57,994 | INFO |
PListStore:[C:\apache-activemq-5.13.0\bin\win64\..\..\data\localhost\tmp_storage]
stopped | org.apache.activemq.store.kahadb.plist.PListStoreImpl | ActiveMQ
ShutdownHook
2015-12-17 15:16:58,198 | INFO | Apache ActiveMQ 5.13.0 (localhost,
ID:PTLSF07-63181-1450361138461-0:1) uptime 11 minutes |
org.apache.activemq.broker.BrokerService | ActiveMQ ShutdownHook
2015-12-17 15:16:58,199 | INFO | Apache ActiveMQ 5.13.0 (localhost,
ID:PTLSF07-63181-1450361138461-0:1) is shutdown |
org.apache.activemq.broker.BrokerService | ActiveMQ ShutdownHook
2015-12-17 15:16:58,200 | INFO | Closing
org.apache.activemq.xbean.XBeanBrokerFactory$1@200669bf: startup date [Thu
Dec 17 15:05:33 CET 2015]; root of context hierarchy |
org.apache.activemq.xbean.XBeanBrokerFactory$1 | ActiveMQ ShutdownHook
2015-12-17 15:16:58,211 | INFO | Destroying Spring FrameworkServlet
'dispatcher' | /admin | ActiveMQ ShutdownHook
2015-12-17 15:17:00,588 | INFO | Refreshing
org.apache.activemq.xbean.XBeanBrokerFactory$1@200669bf: startup date [Thu
Dec 17 15:17:00 CET 2015]; root of context hierarchy |
org.apache.activemq.xbean.XBeanBrokerFactory$1 | WrapperSimpleAppMain
2015-12-17 15:17:01,779 | INFO |
PListStore:[C:\apache-activemq-5.13.0\bin\win64\..\..\data\localhost\tmp_storage]
started | org.apache.activemq.store.kahadb.plist.PListStoreImpl |
WrapperSimpleAppMain
2015-12-17 15:17:01,810 | INFO | Using Persistence Adapter:
JDBCPersistenceAdapter(org.apache.commons.dbcp2.BasicDataSource@2311fe17) |
org.apache.activemq.broker.BrokerService | WrapperSimpleAppMain
2015-12-17 15:17:02,196 | INFO | Database adapter driver override
recognized for : [mysql_connector_java] - adapter: class
org.apache.activemq.store.jdbc.adapter.MySqlJDBCAdapter |
org.apache.activemq.store.jdbc.JDBCPersistenceAdapter | WrapperSimpleAppMain
-----------------------------------------------------------
[activemq.xml]
-----------------------------------------------------------
<beans
xmlns="http://www.springframework.org/schema/beans"
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.xsd
http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core.xsd">
<bean
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="locations">
<value>file:${activemq.conf}/credentials.properties</value>
</property>
</bean>
<bean id="logQuery" class="io.fabric8.insight.log.log4j.Log4jLogQuery"
lazy-init="false" scope="singleton"
init-method="start" destroy-method="stop">
</bean>
<broker xmlns="http://activemq.apache.org/schema/core"
brokerName="localhost" dataDirectory="${activemq.data}">
<destinationPolicy>
<policyMap>
<policyEntries>
<policyEntry topic=">" >
<pendingMessageLimitStrategy>
<constantPendingMessageLimitStrategy limit="1000"/>
</pendingMessageLimitStrategy>
</policyEntry>
</policyEntries>
</policyMap>
</destinationPolicy>
<managementContext>
<managementContext createConnector="false"/>
</managementContext>
<persistenceAdapter>
<jdbcPersistenceAdapter dataDirectory="${activemq.base}/data"
dataSource="#mysql-ds"/>
</persistenceAdapter>
<systemUsage>
<systemUsage>
<memoryUsage>
<memoryUsage percentOfJvmHeap="70" />
</memoryUsage>
<storeUsage>
<storeUsage limit="10 gb"/>
</storeUsage>
<tempUsage>
<tempUsage limit="5 gb"/>
</tempUsage>
</systemUsage>
</systemUsage>
<transportConnectors>
<transportConnector name="openwire"
uri="tcp://0.0.0.0:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="amqp"
uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="stomp"
uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="mqtt"
uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="ws"
uri="ws://0.0.0.0:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
</transportConnectors>
<shutdownHooks>
<bean xmlns="http://www.springframework.org/schema/beans"
class="org.apache.activemq.hooks.SpringContextHook" />
</shutdownHooks>
</broker>
<bean id="mysql-ds" class="org.apache.commons.dbcp2.BasicDataSource"
destroy-method="close">
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<property name="url"
value="jdbc:mysql://localhost/activemq?relaxAutoCommit=true"/>
<property name="username" value="user"/>
<property name="password" value="pass"/>
<property name="poolPreparedStatements" value="true"/>
</bean>
<import resource="jetty.xml"/>
</beans>
-----------------------------------------------------------
Could you please help me fixing this problem?
Thanks,
--
View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-JDBC-persistence-MySQL-ACTIVEMQ-MSGS-is-empty-tp4705108.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.