activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Mrityunjoy Roy (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (AMQ-4783) Scheduled messages lost if broker is shut down during the scheduled time of the message
Date Thu, 03 Oct 2013 22:46:42 GMT

     [ https://issues.apache.org/jira/browse/AMQ-4783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Mrityunjoy Roy updated AMQ-4783:
--------------------------------

    Priority: Minor  (was: Major)

> Scheduled messages lost if broker is shut down during the scheduled time of the message
> ---------------------------------------------------------------------------------------
>
>                 Key: AMQ-4783
>                 URL: https://issues.apache.org/jira/browse/AMQ-4783
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 5.8.0
>            Reporter: Mrityunjoy Roy
>            Priority: Minor
>
> a.	Send a scheduled message to broker , let us say to deliver in 60 sec
> b.	Immediately shut down the broker and keep it down for 60 seconds (down at the time
the message is scheduled to deliver) 
> On coming up , the message is not queued .
> When the broker starts , it adds listeners to it’s store 
>             2013-04-18 19:35:42,184  INFO Broker starter  activemq.broker.BrokerService:633
- Apache ActiveMQ 5.8.0 (authorizerBroker, ID:Joycomp-4951-1366328140528-1:1) is starting
> 2013-04-18 19:35:42,199 DEBUG Broker starter  kahadb.scheduler.JobSchedulerImpl:82 -
Joy - Adding job listener
> 2013-04-18 19:35:42,215 DEBUG Broker starter  kahadb.scheduler.JobSchedulerImpl:85 -
Joy - Added Listener is scheduler broker
> After that when message’s scheduld time comes , it fires the message to queue as below
-:
> 2013-04-18 19:37:41,012 DEBUG JobScheduler:JMS  kahadb.scheduler.JobSchedulerImpl:442
- Firing Job [id=ID:Joycomp-4951-1366328140528-5:1:1:1:1, startTime=Thu Apr 18 19:37:36 EDT
2013, delay=5000, period=0, repeat=0, nextTime=Thu Apr 18 19:37:41 EDT 2013]
> 2013-04-18 19:37:41,012 DEBUG JobScheduler:JMS  kahadb.scheduler.JobSchedulerImpl:445
- byte sequnce = org.apache.activemq.util.ByteSequence@f0c67
> 2013-04-18 19:37:41,012 DEBUG JobScheduler:JMS  kahadb.scheduler.JobSchedulerImpl:446
- Job listeners list=1
> Now , for my case , on a restart , if it finds that a message’s scheduled time is past
the time of start of the broker , during the initialization it fires the message even before
the broker is started 
> 2013-04-18 19:40:57,387  INFO Broker starter  kahadb.plist.PListStoreImpl:331 - PListStore:[C:\Joy\servers\tomcat\7.0.37\dist\bin\activemq-data\authorizerBroker\tmp_storage]
started
> 2013-04-18 19:40:58,356 DEBUG JobScheduler:JMS  kahadb.scheduler.JobSchedulerImpl:445
- byte sequnce = org.apache.activemq.util.ByteSequence@10ee5b8
> 2013-04-18 19:40:58,356 DEBUG JobScheduler:JMS  kahadb.scheduler.JobSchedulerImpl:446
- Job listeners list=0
> // Broker started later -:
> 2013-04-18 19:40:59,199  INFO Broker starter  activemq.broker.BrokerService:633 - Apache
ActiveMQ 5.8.0 (authorizerBroker, ID:Joycomp-1494-1366328458231-1:1) is starting
> 2013-04-18 19:40:59,246 DEBUG Broker starter  kahadb.scheduler.JobSchedulerImpl:82 -
Joy - Adding job listener
> 2013-04-18 19:40:59,246 DEBUG Broker starter  kahadb.scheduler.JobSchedulerImpl:85 -
Joy - Added Listener is scheduler broker



--
This message was sent by Atlassian JIRA
(v6.1#6144)

Mime
View raw message