Package org.mockserver.async.subscribe
package org.mockserver.async.subscribe
-
ClassDescriptionA thread-safe, bounded FIFO store for
RecordedMessageinstances.AMessageSubscriberthat uses a KafkaKafkaConsumerto subscribe to topics and record received messages.Subscribes to a message broker channel and records received messages for later retrieval/verification — the consumer counterpart ofMessagePublisher.AMessageSubscriberthat uses an MQTTMqttClientto subscribe to topics and record received messages.An immutable record of a message received from a broker subscription.