Queue level de-duplication is not working. about rabbitmq-message-deduplication HOT 10 CLOSED

Hello,

I am not familiar with C# so I need your help here.
Could you please bundle the above code in something I can easily execute from my workstation? I am using Linux.

from rabbitmq-message-deduplication.

Hi
I have attached the publisher and subscriber executable and their source files. Can you please check it?

publisher.zip

Program - pub.txt

Subscriber.zip

Program - sub.txt

from rabbitmq-message-deduplication.

I cannot run them on Linux as they are. Could you please provide a Linux compatible build?

from rabbitmq-message-deduplication.

The size is becoming a problem. Can I place in my one drive so that you can access?

from rabbitmq-message-deduplication.

https://1drv.ms/u/s!AhsWFrOSjEnwkIdyRwbugWLUKzsXGA?e=q2GPgF
Can you please access this link. I have uploaded both Publiher and subscriber linux compatible files there.

from rabbitmq-message-deduplication.

It seems so. In the upcoming days I'll give it a spin and let you know.

from rabbitmq-message-deduplication.

Do you see any issues in the source code?

from rabbitmq-message-deduplication.

I just tested the Publisher and I see only 1 message in the queue. Here's the Publisher log:

$ ./TestPub 
 Sent: Message 1 with x-deduplication-header as Test
 Sent: Message 2 with x-deduplication-header as Test
 Sent: Message 3 with x-deduplication-header as Test
 Sent: Message 4 with x-deduplication-header as Test
 Sent: Message 5 with x-deduplication-header as Test
 Sent: Message 6 with x-deduplication-header as Test
 Sent: Message 7 with x-deduplication-header as Test
 Sent: Message 8 with x-deduplication-header as Test
 Sent: Message 9 with x-deduplication-header as Test
 Sent: Message 10 with x-deduplication-header as Test
Publishing completed

Here's the Queue status:
10 messages where actually published

$ curl -s -u guest:guest http://localhost:15672/api/queues | jq '.[] | select(.name=="DeduplicationTestQueue") | .message_stats'
{
  "publish": 10,
  "publish_details": {
    "rate": 0
  }
}

1 message only in the queue

$ curl -s -u guest:guest http://localhost:15672/api/queues | jq '.[] | select(.name=="DeduplicationTestQueue") | .messages'
1

from rabbitmq-message-deduplication.

Is the plugin correctly installed? Did you restart the broker after enabling the plugin?

from rabbitmq-message-deduplication.

Yes. it is working.

from rabbitmq-message-deduplication.