Package org.mockserver.async.subscribe
package org.mockserver.async.subscribe
-
ClassDescriptionA
MessageSubscriberthat consumes from an AMQP 0.9.1 broker (RabbitMQ) using the officialcom.rabbitmq:amqp-clientlibrary, the consumer-side counterpart ofAmqpMessagePublisher.A thread-safe, bounded FIFO store forRecordedMessageinstances.AMessageSubscriberthat consumes Confluent wire-format Avro messages from Kafka and records them as JSON — the consume/verify counterpart ofKafkaAvroMessagePublisher.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 MQTT v5MqttClientto subscribe to topics and record received messages — the v5 counterpart ofMqttMessageSubscriber.AMessageSubscriberthat uses an MQTTMqttClientto subscribe to topics and record received messages.An immutable record of a message received from a broker subscription.