[ 
https://issues.apache.org/jira/browse/AMQ-5249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14268871#comment-14268871
 ] 

Anuj Khandelwal commented on AMQ-5249:
--------------------------------------

Hi,

We are using 5.10 broker. 
We saw this error messages. 
[20150107 15:01:52.282 EST (ActiveMQ Transport: 
tcp:///10.79.26.196:41859@61613) 
org.apache.activemq.broker.region.cursors.AbstractStoreCursor#recoverMess
age 103 WARN] - 
TopicStorePrefetch(cas_stuff_price_info_to_jsh,new_golden_price_message) 
ID:kepler47.com-49402-1420406276070-1:22507:-1:1 - org
.apache.activemq.broker.region.cursors.TopicStorePrefetch@7524aad9:pricing.goldenPriceFeed,batchResetNeeded=false,storeHasMessages=true,size=52586,cacheEn
abled=false,maxBatchSize:200,hasSpace:true - cursor got duplicate: 
ID:helium16.nyc-49994-1420473196066-5:6690:1:1:4257, 4 

>From the source code of 
>org.apache.activemq.broker.region.cursors.AbstractStoreCursor#recoverMess
age it looks like duplicates messages got stored in kahadb for same 
destination. The topic for which it happend has a durable subscriber. 
I want to understand in what cases kahadb stores duplicate messages ? Is this a 
bug? 


Thanks,
Anuj


> "cursor got duplicate" error after upgrade
> ------------------------------------------
>
>                 Key: AMQ-5249
>                 URL: https://issues.apache.org/jira/browse/AMQ-5249
>             Project: ActiveMQ
>          Issue Type: Bug
>    Affects Versions: 5.9.1, 5.10.0
>            Reporter: Rural Hunter
>
> I was using 5.9.0 and meet one problem so I tried to upgrade activemq. I 
> tried both 5.9.1 and 5.10.0 and encouterred a same problem. I saw messages 
> filled DLQ very quickly. I checked the clients both producer and consumer but 
> there was no error. I checked activemq log and found the log is full of these 
> warnings:
> 2014-06-27 23:22:09,337 | WARN  | 
> org.apache.activemq.broker.region.cursors.QueueStorePrefetch@19117501:com.cyyun.webmon.spider.update,batchResetNeeded=false,storeHasMessages=true,size=211,cacheEnabled=true,maxBatchSize:200,hasSpace:true
>  - cursor got duplicate: ID:211.com-52399-1400732399425-1:1:235992:1:1, 4 | 
> org.apache.activemq.broker.region.cursors.AbstractStoreCursor | ActiveMQ 
> Broker[localhost] Scheduler
> 2014-06-27 23:22:09,337 | WARN  | 
> org.apache.activemq.broker.region.cursors.QueueStorePrefetch@19117501:com.xxxx.update,batchResetNeeded=false,storeHasMessages=true,size=211,cacheEnabled=true,maxBatchSize:200,hasSpace:true
>  - cursor got duplicate: ID:nbzjjf22805-34129-1403880308671-1:1:28:1:1, 4 | 
> org.apache.activemq.broker.region.cursors.AbstractStoreCursor | ActiveMQ 
> Broker[localhost] Scheduler
> 2014-06-27 23:22:09,338 | WARN  | 
> org.apache.activemq.broker.region.cursors.QueueStorePrefetch@19117501:com.xxxxx.update,batchResetNeeded=false,storeHasMessages=true,size=211,cacheEnabled=true,maxBatchSize:200,hasSpace:true
>  - cursor got duplicate: ID:jxncxnj2-48598-1403856107346-1:1:6007:1:1, 4 | 
> org.apache.activemq.broker.region.cursors.AbstractStoreCursor | ActiveMQ 
> Broker[localhost] Scheduler
> 2014-06-27 23:22:09,338 | WARN  | 
> org.apache.activemq.broker.region.cursors.QueueStorePrefetch@19117501:com.xxxx.update,batchResetNeeded=false,storeHasMessages=true,size=211,cacheEnabled=true,maxBatchSize:200,hasSpace:true
>  - cursor got duplicate: ID:jxnc17-60227-1400730816361-1:1:149072:1:1, 4 | 
> org.apache.activemq.broker.region.cursors.AbstractStoreCursor | ActiveMQ 
> Broker[localhost] Scheduler
> 2014-06-27 23:22:09,339 | WARN  | 
> org.apache.activemq.broker.region.cursors.QueueStorePrefetch@19117501:com.xxxx.update,batchResetNeeded=false,storeHasMessages=true,size=211,cacheEnabled=true,maxBatchSize:200,hasSpace:true
>  - cursor got duplicate: ID:cyyun-46954-1403800808565-1:1:9765:1:1, 4 | 
> org.apache.activemq.broker.region.cursors.AbstractStoreCursor | ActiveMQ 
> Broker[localhost] Scheduler
> 2014-06-27 23:22:09,339 | WARN  | 
> org.apache.activemq.broker.region.cursors.QueueStorePrefetch@19117501:com.xxxx.update,batchResetNeeded=false,storeHasMessages=true,size=211,cacheEnabled=true,maxBatchSize:200,hasSpace:true
>  - cursor got duplicate: ID:ubuntu-55495-1403497638437-1:1:53086:1:1, 4 | 
> org.apache.activemq.broker.region.cursors.AbstractStoreCursor | ActiveMQ 
> Broker[localhost] Scheduler
> 2014-06-27 23:22:09,340 | WARN  | 
> org.apache.activemq.broker.region.cursors.QueueStorePrefetch@19117501:com.xxxx.update,batchResetNeeded=false,storeHasMessages=true,size=211,cacheEnabled=true,maxBatchSize:200,hasSpace:true
>  - cursor got duplicate: ID:cyyun-39030-1403880008363-1:1:70:1:1, 4 | 
> org.apache.activemq.broker.region.cursors.AbstractStoreCursor | ActiveMQ 
> Broker[localhost] Scheduler
> The problem mostly happens right after activemq starts and sometimes happened 
> after activemq worked normally for a while.
> For now I have to roll back to 5.9.0 and the problem doesn't occure.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to