Package com.bytedesk.core.socket.mqtt

Class MqttChannelUtils

java.lang.Object

com.bytedesk.core.socket.mqtt.MqttChannelUtils

public class MqttChannelUtils
extends Object

Various utilities for working with channels

Author:

Dominik Obermaier, Christoph Schäbel

Constructor Summary

Constructors

Modifier	Constructor	Description
private	MqttChannelUtils()

Method Summary

Modifier and Type	Method	Description
static Optional<InetAddress>	getChannelAddress(io.netty.channel.Channel channel)
static Optional<String>	getChannelIP(io.netty.channel.Channel channel)
static String	getClientId(io.netty.channel.Channel channel)	Fetches the clientId from the channel attributes of the passed channel
static void	sendPubAckMessage(io.netty.channel.Channel channel, int messageId)
static void	sendPubRecMessage(io.netty.channel.Channel channel, int messageId)

Methods inherited from class java.lang.Object

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

Constructor Details

MqttChannelUtils

private MqttChannelUtils()

Method Details

getClientId

public static String getClientId(@NonNull
 io.netty.channel.Channel channel)

Fetches the clientId from the channel attributes of the passed channel

sendPubAckMessage

public static void sendPubAckMessage(io.netty.channel.Channel channel,
 int messageId)

sendPubRecMessage

public static void sendPubRecMessage(io.netty.channel.Channel channel,
 int messageId)

getChannelIP

public static Optional<String> getChannelIP(io.netty.channel.Channel channel)

getChannelAddress

public static Optional<InetAddress> getChannelAddress(io.netty.channel.Channel channel)