Transport-agnostic queue testing abstractions: in-memory message aggregator, subscriber and publisher base classes