InMemoryTransport
A Transport inside one JVM with broker semantics: every consumer group on a topic receives each record, and the members of a group share them round-robin. Records go through their encoded form, so a bus over it exercises the same encode, decode and validation as one over Kafka or Redis.
Nothing is retained: a record published while a topic has no open receiver is dropped, and acknowledgement is a no-op. It suits tests and single-process setups that want the distributed code path. The local, object-passing buses (InMemoryCommandBus and the event buses) remain what local-first delivery uses.
Functions
Link copied to clipboard
Publishes message to its topic. The returned Mono completes once the broker has accepted it.