search

DavidBM / rsmq-async-rs

RSMQ port to async rust. RSMQ is a simple redis queue system that works in any redis v2.6+
MIT License
43 stars 8 forks source link

Receive message using "qname" rather than ":qname" #13

Closed YJChan closed 2 years ago

YJChan commented 2 years ago

Hi, I've follow to example, let message = rsmq.receive_message::<String>("myqueue", None).await?; but I always get queue not found error. So, I try using let message = rsmq.receive_message::<String>(":myqueue", None).await?;. Can I confirm that this is a mistake?

DavidBM commented 2 years ago

It seems that the JS library add the : to the queue name and this one doesn't. Let me check the JS source code and see. I will update the library if there is any mismatch.

DavidBM commented 2 years ago

I cannot see where are the : comming from. What library created the queue initially in the Redis instance?

As you can see in the tests, https://github.com/Couragium/rsmq-async-rs/blob/master/tests/test.rs#L18 it should work without prepending anything.

YJChan commented 2 years ago

Wasn't check on my notification recently. There is : in my redis queue created by other node.js service by accident. I will proceed to close this issue. Thank you for verifying it.