~WIP: Message queue: add support for message deduplication