Package com.bytedesk.core.socket.mqtt.protocol

Class Publish

java.lang.Object

com.bytedesk.core.socket.mqtt.protocol.Publish

public class Publish
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final IMessageSendService	messageSendService

Constructor Summary

Constructors

Constructor	Description
Publish()

Method Summary

Modifier and Type	Method	Description
void	processPublish(io.netty.channel.Channel channel, io.netty.handler.codec.mqtt.MqttPublishMessage mqttPublishMessage)
private void	sendMqMessage(io.netty.handler.codec.mqtt.MqttPublishMessage publishMessage, byte[] messageBytes)

Methods inherited from class java.lang.Object

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

Field Details

messageSendService

private final IMessageSendService messageSendService

Constructor Details

Publish

public Publish()

Method Details

processPublish

public void processPublish(io.netty.channel.Channel channel,
 io.netty.handler.codec.mqtt.MqttPublishMessage mqttPublishMessage)

sendMqMessage

private void sendMqMessage(io.netty.handler.codec.mqtt.MqttPublishMessage publishMessage,
 byte[] messageBytes)