Index

C M O P S
All Classes and Interfaces|All Packages

C

close() - Method in class org.mqtt4j.hato.broker.MqttBroker

Stops accepting connections, closes all peers, and discards their session state and the retained messages, without publishing Wills, those that wait for their delay included.

M

MqttBroker - Class in org.mqtt4j.hato.broker

An experimental, in-memory MQTT 3.1.1 and 5.0 broker for tests.

O

org.mqtt4j.hato.broker - module org.mqtt4j.hato.broker

Experimental in-memory MQTT broker for tests, outside the API compatibility promise.

org.mqtt4j.hato.broker - package org.mqtt4j.hato.broker

Experimental broker API for tests, outside the API compatibility promise until productization.

P

port() - Method in class org.mqtt4j.hato.broker.MqttBroker

Returns the assigned listening port, including after close.

S

start() - Static method in class org.mqtt4j.hato.broker.MqttBroker

Starts on a system-assigned port on the loopback address.

start(InetSocketAddress) - Static method in class org.mqtt4j.hato.broker.MqttBroker

Starts listening at address; port zero selects a system-assigned port.

C M O P S
All Classes and Interfaces|All Packages