Hi All,

I developed a sample POC for the Topic and durable Topic on fuse and I faced an issue.

Sample code description

My sample code consists of 3 bundles, and each bundle has its own camel context, and its own route, so I have 3 routes in 3 bundles as the following:

bundle1 route : consume file from file system and send it to a queue

bundle2 route: consume message from the previous queue and send it to a topic

bundle3 route: consume message from the previous topic and send it to the file system

When I put a file in the first folder "D://camel_test" , the sample code runs successfully in 95% of the cases and the file is disappeared from "D://camel_test" folder and moved to the second folder "D://camel_test2"

Issue Description

? Sometime, 5% of the cases, the file isn?t consumed by the second route, and when checking the consumers and queues on jconsole, I find

o a registered consumer for the queue "service.queue" as shown in the attached jconsole screen shot (2.png).

   o The queue?s Enqueue count is increased while the queue?s Dequeue count is zero as shown in the attached jconsole screen shot (1.png).

? The issue appears in many cases but the most reproducible case after restarting Fuse ESB.

? the issue doesn?t appear In every fuse ESB restart, many times the sample code runs successfully without problems after fuse ESB restart.

Important Note: Always the issue disappears after refreshing bundle2 and bundle3.

could you please advise?