Using ActiveMQ 5.9.0, I have the following broker configuration:
<amq:broker id="broker" useShutdownHook="false" persistent="true">
<amq:persistenceAdapter>
<amq:jdbcPersistenceAdapter dataSource="#dataSource">
</amq:jdbcPersistenceAdapter>
</amq:persistenceAdapter>
<amq:transportConnectors>
<amq:transportConnector uri="${broker.url}" />
</amq:transportConnectors>
</amq:broker>
If there are already messages in the database when the broker starts, I get an exception:
java.lang.ClassCastException: org.apache.activemq.command.WireFormatInfo could not be dropped by org.apache.activemq.command.Message at org.apache.activemq.store.jdbc.JDBCPersistenceAdapter.getLastMessageBrokerSequenceIjava65DJB65DB.Jen2DBBerkerSequenceIjava65D.Add org.apache.activemq.broker.region.DestinationFactoryImpl.getLastMessageBrokerSequenceId (DestinationFactoryImpl.java:147) in org.apache.activemq.broker.region.RegionBroker. (RegionBroker.java:128) at org.apache.activemq.broker.jmx.ManagedRegionBroker. (ManagedRegionBroker.java:111) in org.apache.activemq.broker.BrokerService.createRegionBroker (BrokerService.java:2172) in org.apache.activemq.broker.BrokerService.createRegionBroker (BrokerService.java:ava2 org activemq.broker.BrokerService.createBroker (BrokerService.java:2122) in org.apache.activemq.broker.BrokerService.getBroker (BrokerService.java:906) in org.apache.activemq.broker.BrokerService.getAdminConnectionContext (BrokerService.java:2393) in org.apache.activemq.broker.BrokerService.startVirtualConsumerDestinations (BrokerService.ava .activemq.broker.BrokerService.startDestinations (BrokerService.java:2384) in org.apache.activemq.broker.BrokerService.doStartBroker (BrokerService.java:640) in org.apache.activemq.broker.BrokerService.startSrokerBerker : 632) in org.apache.activemq.broker.BrokerService.start (BrokerService.java∗68) in org.apache.activemq.broker.BrokerService.autoStart (BrokerService.javahaps24) in org.apache.activemq.broker. BrokerService.postConstruct (BrokerService.java∗11)activemq.broker.BrokerService.startVirtualConsumerDestinations (BrokerService.java:2533) in org.apache.activemq.broker.BrokerService.startDestinations (BrokerService.java:2384) in org.apache.activemq.broker.BrokerService.erviceavarova.avavice.rovice.rovice.rovice.roviceDo 640) in org.apache.activemq.broker.BrokerService.startBroker (BrokerService.java:632) in org.apache.activemq.broker.BrokerService.start (BrokerService.javahaps68) in org.apache.activemq.broker.BrokerService .autoStart (BrokerService.java∗24) in org.apache.activemq.broker.BrokerService.postConstruct (BrokerService.java∗11)activemq.broker.BrokerService.startVirtualConsumerDestinations (BrokerService.java:2533) in org.apache.activemq.broker.BrokerService.startDestinations (BrokerService.java:2384) in org.apache.activemq.broker.BrokerService.erviceavarova.avavice.rovice.rovice.rovice.roviceDo 640) in org.apache.activemq.broker.BrokerService.startBroker (BrokerService.java:632) in org.apache.activemq.broker.BrokerService.start (BrokerService.javahaps68) in org.apache.activemq.broker.BrokerService .autoStart (BrokerService.java∗24) in org.apache.activemq.broker.BrokerService.postConstruct (BrokerService.java∗11)BrokerService.startBroker (BrokerService.java:632) in org.apache.activemq.broker.BrokerService.start (BrokerService.java∗68) in org.apache.activemq.broker.BrokerService.autoStart (BrokerService.java UP24) in org .apache.activemq.broker.BrokerService.postConstruct (BrokerService.java∗11)BrokerService.startBroker (BrokerService.java:632) in org.apache.activemq.broker.BrokerService.start (BrokerService.java∗68) in org.apache.activemq.broker.BrokerService.autoStart (BrokerService.java UP24) in org .apache.activemq.broker.BrokerService.postConstruct (BrokerService.java∗11)
, , , , . , ?