Package org.mockserver.async.subscribe

Class Mqtt5MessageSubscriber

java.lang.Object

org.mockserver.async.subscribe.Mqtt5MessageSubscriber

All Implemented Interfaces:

MessageSubscriber

public class Mqtt5MessageSubscriber
extends Object
implements MessageSubscriber

A MessageSubscriber that uses an MQTT v5 MqttClient to subscribe to topics and record received messages — the v5 counterpart of MqttMessageSubscriber.

MQTT 5 user properties on incoming messages are recorded as the RecordedMessage headers (MQTT 3 has no equivalent). Recorded messages are stored in a bounded BoundedMessageStore per channel to prevent unbounded memory growth.

Constructor Summary

Constructors

Constructor	Description
Mqtt5MessageSubscriber(String brokerUrl, String clientId)	Create a v5 subscriber connected to the given broker with no security.
Mqtt5MessageSubscriber(String brokerUrl, String clientId, int qos)	Create a v5 subscriber with a specific QoS and no security.
Mqtt5MessageSubscriber(String brokerUrl, String clientId, int qos, int maxRecordedMessages, MqttSecurity security)	Create a v5 subscriber with optional security configuration.

Method Summary

Modifier and Type	Method	Description
void	close()	Clear all recorded messages and stop all subscriptions.
List<RecordedMessage>	getAllRecordedMessages()	Return all messages recorded across all channels.
List<RecordedMessage>	getRecordedMessages(String channel)	Return all messages recorded on the given channel since subscription started (or since the last reset).
boolean	isHealthy()	Returns false if the MQTT callback has reported a disconnect.
void	subscribe(String channel)	Start subscribing to the given channel.
void	unsubscribe(String channel)	Stop subscribing to the given channel.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Mqtt5MessageSubscriber

public Mqtt5MessageSubscriber(String brokerUrl,
 String clientId)

Create a v5 subscriber connected to the given broker with no security.

Mqtt5MessageSubscriber

public Mqtt5MessageSubscriber(String brokerUrl,
 String clientId,
 int qos)

Create a v5 subscriber with a specific QoS and no security.

Mqtt5MessageSubscriber

public Mqtt5MessageSubscriber(String brokerUrl,
 String clientId,
 int qos,
 int maxRecordedMessages,
 MqttSecurity security)

Create a v5 subscriber with optional security configuration.

Parameters:

brokerUrl - the MQTT broker URL

clientId - the client identifier

qos - the MQTT QoS level (0, 1, or 2)

maxRecordedMessages - maximum recorded messages per channel

security - security configuration (may be null for plaintext)

Method Details

isHealthy

public boolean isHealthy()

Returns false if the MQTT callback has reported a disconnect.

subscribe

public void subscribe(String channel)

Description copied from interface: MessageSubscriber

Start subscribing to the given channel. Messages will be recorded internally and are retrievable via MessageSubscriber.getRecordedMessages(String).

Specified by:

subscribe in interface MessageSubscriber

Parameters:

channel - the channel/topic to subscribe to

unsubscribe

public void unsubscribe(String channel)

Description copied from interface: MessageSubscriber

Stop subscribing to the given channel.

Specified by:

unsubscribe in interface MessageSubscriber

getRecordedMessages

public List<RecordedMessage> getRecordedMessages(String channel)

Description copied from interface: MessageSubscriber

Return all messages recorded on the given channel since subscription started (or since the last reset).

Specified by:

getRecordedMessages in interface MessageSubscriber

getAllRecordedMessages

public List<RecordedMessage> getAllRecordedMessages()

Description copied from interface: MessageSubscriber

Return all messages recorded across all channels.

Specified by:

getAllRecordedMessages in interface MessageSubscriber

close

public void close()

Description copied from interface: MessageSubscriber

Clear all recorded messages and stop all subscriptions.

Specified by:

close in interface MessageSubscriber