Hi colleagues,
Excuse me for my ignorance I am pretty new in DDS RTI
I wonder if u can help me on the bellow, in my project the subscriber is doing an heavy operation once it getting a sample. so I tried to build a pool of reader threads, my intention was that each reader will take sample from the queue and work on it (take not read – will remove it from the queue) But from what I see, I am getting the same sample on all the threads - all the readers, I wonder what I need to do to build a reader pool which all use the same queue and all can take samples from it ? from what I read most of the operation are thread safe so I believe this should be an easy task
BTW currently I am solving the issue by filtering the samples according to the key but this is not my intention
Thanks for your help
This sounds like it could be an application for RTI Queuing service. You should have access to this feature if you're working with Connext Professional. (EDIT/CORRECTION: Queuing Service is an add-on product to Professional. Pro users can request an eval via their RTI sales contacts).
https://www.rti.com/products/queuing-service
https://community.rti.com/static/documentation/connext-dds/6.1.0/doc/manuals/addon_products/queuing_service/getting_started_guide/index.htm
https://community.rti.com/static/documentation/connext-dds/6.1.0/doc/manuals/addon_products/queuing_service/release_notes/index.htm
Regards,
Bob