Provide a concurrency-safe, per-topic message store with id-based deduplication, delete, clear, and a search predicate.
ahp