Module swim.io.mqtt

Package swim.io.mqtt

Interface MqttInterface

All Superinterfaces:

IpInterface

All Known Implementing Classes:

MqttEndpoint

public interface MqttInterface
extends IpInterface

Method Summary

Modifier and Type	Method	Description
default IpServiceRef	bindMqtt(String address, int port, MqttService service)
default IpServiceRef	bindMqtt(String address, int port, MqttService service, MqttSettings mqttSettings)
default IpServiceRef	bindMqtt(InetSocketAddress localAddress, MqttService service)
default IpServiceRef	bindMqtt(InetSocketAddress localAddress, MqttService service, MqttSettings mqttSettings)
default IpServiceRef	bindMqtts(String address, int port, MqttService service)
default IpServiceRef	bindMqtts(String address, int port, MqttService service, MqttSettings mqttSettings)
default IpServiceRef	bindMqtts(InetSocketAddress localAddress, MqttService service)
default IpServiceRef	bindMqtts(InetSocketAddress localAddress, MqttService service, MqttSettings mqttSettings)
default <I, O> IpSocketRef	connectMqtt(String address, int port, MqttSocket<I,O> socket)
default <I, O> IpSocketRef	connectMqtt(String address, int port, MqttSocket<I,O> socket, MqttSettings mqttSettings)
default <I, O> IpSocketRef	connectMqtt(InetSocketAddress localAddress, MqttSocket<I,O> socket)
default <I, O> IpSocketRef	connectMqtt(InetSocketAddress localAddress, MqttSocket<I,O> socket, MqttSettings mqttSettings)
default <I, O> IpSocketRef	connectMqtts(String address, int port, MqttSocket<I,O> socket)
default <I, O> IpSocketRef	connectMqtts(String address, int port, MqttSocket<I,O> socket, MqttSettings mqttSettings)
default <I, O> IpSocketRef	connectMqtts(InetSocketAddress localAddress, MqttSocket<I,O> socket)
default <I, O> IpSocketRef	connectMqtts(InetSocketAddress localAddress, MqttSocket<I,O> socket, MqttSettings mqttSettings)
MqttSettings	mqttSettings()

Methods inherited from interface swim.io.IpInterface

bindTcp, bindTcp, bindTcp, bindTcp, bindTls, bindTls, bindTls, bindTls, connectTcp, connectTcp, connectTcp, connectTcp, connectTcp, connectTcp, connectTcp, connectTcp, connectTls, connectTls, connectTls, connectTls, connectTls, connectTls, connectTls, connectTls, ipSettings

Method Details

mqttSettings

MqttSettings mqttSettings()

bindMqtt

default IpServiceRef bindMqtt(InetSocketAddress localAddress,
 MqttService service,
 MqttSettings mqttSettings)

bindMqtt

default IpServiceRef bindMqtt(InetSocketAddress localAddress,
 MqttService service)

bindMqtt

default IpServiceRef bindMqtt(String address,
 int port,
 MqttService service,
 MqttSettings mqttSettings)

bindMqtt

default IpServiceRef bindMqtt(String address,
 int port,
 MqttService service)

bindMqtts

default IpServiceRef bindMqtts(InetSocketAddress localAddress,
 MqttService service,
 MqttSettings mqttSettings)

bindMqtts

default IpServiceRef bindMqtts(InetSocketAddress localAddress,
 MqttService service)

bindMqtts

default IpServiceRef bindMqtts(String address,
 int port,
 MqttService service,
 MqttSettings mqttSettings)

bindMqtts

default IpServiceRef bindMqtts(String address,
 int port,
 MqttService service)

connectMqtt

default <I,
O> IpSocketRef connectMqtt(InetSocketAddress localAddress,
 MqttSocket<I,O> socket,
 MqttSettings mqttSettings)

connectMqtt

default <I,
O> IpSocketRef connectMqtt(InetSocketAddress localAddress,
 MqttSocket<I,O> socket)

connectMqtt

default <I,
O> IpSocketRef connectMqtt(String address,
 int port,
 MqttSocket<I,O> socket,
 MqttSettings mqttSettings)

connectMqtt

default <I,
O> IpSocketRef connectMqtt(String address,
 int port,
 MqttSocket<I,O> socket)

connectMqtts

default <I,
O> IpSocketRef connectMqtts(InetSocketAddress localAddress,
 MqttSocket<I,O> socket,
 MqttSettings mqttSettings)

connectMqtts

default <I,
O> IpSocketRef connectMqtts(InetSocketAddress localAddress,
 MqttSocket<I,O> socket)

connectMqtts

default <I,
O> IpSocketRef connectMqtts(String address,
 int port,
 MqttSocket<I,O> socket,
 MqttSettings mqttSettings)

connectMqtts

default <I,
O> IpSocketRef connectMqtts(String address,
 int port,
 MqttSocket<I,O> socket)