Hi, same behavior using the tcp transport connector instead of vm and advisory enabled ?
I will try to reproduce tomorrow. Regards JB On 19/11/2019 19:00, Christopher Mathrusse wrote: > Hi JB, > > Yes, the broker does have schedulerSupport set to true. > <broker xmlns="http://activemq.apache.org/schema/core"; > brokerName="broker-vv" > advisorySupport="false" > dataDirectory="/data2/activemq-data/vv" > schedulerSupport="true" > schedulePeriodForDestinationPurge="3600000"> > > And yes, the transportConnector URL is using tcp: > > > > > > * <transportConnectors> <!-- DOS protection, limit > concurrent connections to 1000 and frame size to 100MB --> > <transportConnector name="openwire" > uri="tcp://0.0.0.0:61616?maximumConnections=1000&wireformat.maxFrameSize=104857600 > <http://0.0.0.0:61616?maximumConnections=1000&wireformat.maxFrameSize=104857600>"/> > </transportConnectors>* > > The provider URL being supplied to the ActiveMQConnectionFactory is the > following: vm://$activemq_host$?jms.watchTopicAdvisories=false > (of course, the activemq_host variable is expanded at runtime to the actual > host name) > > > Thanks for the assistance. > Chris > > On Tue, Nov 19, 2019 at 9:46 AM Jean-Baptiste Onofré <j...@nanthrax.net> > wrote: > >> Hi Chris, >> >> You are using tcp connection right ? >> >> What's the provider URL you are using in the connection factory ? >> >> In your activemq.xml scheduler support is enabled in the <broker/> >> element right ? >> >> Regards >> JB >> >> On 19/11/2019 18:42, Christopher Mathrusse wrote: >>> We are currently running ActiveMQ version 5.15.3 for our broker within a >>> Docker container. The ActiveMQ client version was just upgraded to >> 5.15.10, >>> but we were experiencing the issue prior to the upgrade when our client >> was >>> running version 5.6. >>> >>> We are constantly experiencing communication failures between the client >>> and the broker resulting in Exceptions in our client log files showing: >> *Timer >>> already cancelled* >>> >>> The only way to resolve the issue is to restart the broker. There is no >>> error occurring in the broker's log file. If anything it appears that >> there >>> is no activity in the broker's log file at all. Restarting the broker >> does >>> resolve the issue but this is constantly occurring in our environments. >>> >>> I've researched the issue and found the following link: >>> https://issues.apache.org/jira/browse/AMQ-5251 >>> which states that the issue was resolved in versions 5.10.1 >>> < >> https://issues.apache.org/jira/issues/?jql=project+%3D+AMQ+AND+fixVersion+%3D+5.10.1 >>> >>> , 5.11.0 >>> < >> https://issues.apache.org/jira/issues/?jql=project+%3D+AMQ+AND+fixVersion+%3D+5.11.0 >>> . >>> However, we are still experiencing the same issue. >>> >>> Is there any way to identify this issue or a way to work around it? >>> >>> Thanks for the assistance... >>> Chris >>> >>> Caused by: javax.jms.JMSException: Timer already cancelled. >>> at >> org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:49) >>> at >> org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1362) >>> at >> org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1290) >>> at org.apache.activemq.ActiveMQSession.send(ActiveMQSession.java:1785) >>> at >> org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:277) >>> at >> org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:212) >>> at org.apache.activemq.pool.PooledProducer.send(PooledProducer.java:74) >>> at org.apache.activemq.pool.PooledProducer.send(PooledProducer.java:59) >>> at >> veeva.ecm.common.infrastructure.util.queue.impl.DurableVeevaObjectQueue.sendMessage(DurableVeevaObjectQueue.java:367) >>> at >> veeva.ecm.common.infrastructure.util.queue.impl.DurableVeevaObjectQueue.lambda$0(DurableVeevaObjectQueue.java:270) >>> ... 281 more >>> Caused by: java.lang.IllegalStateException: Timer already cancelled. >>> at java.util.Timer.sched(Timer.java:397) >>> at java.util.Timer.schedule(Timer.java:248) >>> at >> org.apache.activemq.thread.Scheduler.executePeriodically(Scheduler.java:49) >>> at org.apache.activemq.broker.region.Queue.start(Queue.java:993) >>> at >> org.apache.activemq.broker.region.AbstractRegion.addDestination(AbstractRegion.java:161) >>> at >> org.apache.activemq.broker.region.RegionBroker.addDestination(RegionBroker.java:339) >>> at >> org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:174) >>> at >> org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:174) >>> at >> org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:174) >>> at >> org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:174) >>> at >> org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:174) >>> at >> org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:454) >>> at >> org.apache.activemq.broker.jmx.ManagedRegionBroker.send(ManagedRegionBroker.java:293) >>> at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:154) >>> at >> org.apache.activemq.broker.scheduler.SchedulerBroker.send(SchedulerBroker.java:312) >>> at >> org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:96) >>> at >> org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:293) >>> at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:154) >>> at >> org.apache.activemq.plugin.StatisticsBroker.send(StatisticsBroker.java:203) >>> at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:154) >>> at >> org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:572) >>> at >> org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:768) >>> at >> org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:330) >>> at >> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:194) >>> at >> org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50) >>> at >> org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:125) >>> at >> org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:301) >>> at >> org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83) >>> at >> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:233) >>> at >> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:215) >>> >> >> -- >> Jean-Baptiste Onofré >> jbono...@apache.org >> http://blog.nanthrax.net >> Talend - http://www.talend.com >> > -- Jean-Baptiste Onofré jbono...@apache.org http://blog.nanthrax.net Talend - http://www.talend.com
