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.Matching of concrete MQTT topic names against MQTT topic filters, per MQTT 3.1.1 §4.7 (the same wildcard semantics apply to MQTT 5).An immutable record of a message received from a broker subscription.