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
>
