activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Tim Bain <tb...@alumni.duke.edu>
Subject Re: AMQ SCHEDULED DELAY
Date Wed, 20 Sep 2017 04:50:08 GMT
On Sep 19, 2017 1:44 PM, "srramu45" <sbadri45@gmail.com> wrote:

Yes scheduled messages are not working .We have requirement to set message
schedule for 60 sec to 1 hour , message should come in to queue or it should
be consumed after given time and not sure if this scheduled messages are
going through queue or consumed.


That's why I gave you a link to a blog post about how to determine exactly
that. What did you discover when you used the techniques it explained?

We found below error on the servers.

We have enabled schedule support to true  and version 5.14

Do we need to configure separate data store for schedule messages?


No, you just need to set schedulerSupport to true, which you say you've
already done.

Why does Job schedule fail ?


Apparently because it couldn't find that file in that location. It's
possible that the error is due to a code bug, but there's also the
possibility that there's something environmental going on with your NFS
mount. But let's start by determining if that path exists on the broker's
host, and if files are being created in it.

Kahadb.scheduler.JobSchedulerImpl  600 | 121 - | JMS Failed to schedule job
java.io.IOException: Could not locate data file
/nfsroot/standalone/store1/amq-p1n1/scheduler/db-25.log

ERROR | JMS Failed to schedule job |
org.apache.activemq.broker.scheduler.JobSchedulerImpl | JobScheduler:JMS
java.lang.NullPointerException
at org.apache.kahadb.index.BTreeIndex.loadNode(BTreeIndex.java:264)
at org.apache.kahadb.index.BTreeNode.getChild(BTreeNode.java:225)
at org.apache.kahadb.index.BTreeNode.remove(BTreeNode.java:330)
at org.apache.kahadb.index.BTreeIndex.remove(BTreeIndex.java:194)
at
org.apache.activemq.broker.scheduler.JobSchedulerImpl.
remove(JobSchedulerImpl.java:347)
at
org.apache.activemq.broker.scheduler.JobSchedulerImpl$4.
execute(JobSchedulerImpl.java:125)
at org.apache.kahadb.page.Transaction.execute(Transaction.java:728)
at
org.apache.activemq.broker.scheduler.JobSchedulerImpl.
remove(JobSchedulerImpl.java:123)
at
org.apache.activemq.broker.scheduler.JobSchedulerImpl.
mainLoop(JobSchedulerImpl.java:515)
at
org.apache.activemq.broker.scheduler.JobSchedulerImpl.
run(JobSchedulerImpl.java:429)
at java.lang.Thread.run(Thread.java:619)
2010-12-10 16:31:39,561 | INFO |
JobSchedulerStore:activemq-data/primary/scheduler stopped |
org.apache.activemq.broker.scheduler.JobSchedulerStore | JobScheduler:JMS
{noformat}



--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message