io.netty.handler.codec.mqtt

类 MqttPublishMessage

java.lang.Object

io.netty.handler.codec.mqtt.MqttMessage

io.netty.handler.codec.mqtt.MqttPublishMessage

所有已实现的接口:

ByteBufHolder, ReferenceCounted

public class MqttPublishMessage
extends MqttMessage
implements ByteBufHolder

See MQTTV3.1/publish

字段概要

从类继承的字段 io.netty.handler.codec.mqtt.MqttMessage

DISCONNECT, PINGREQ, PINGRESP

构造器概要

构造器

构造器和说明
MqttPublishMessage(MqttFixedHeader mqttFixedHeader, MqttPublishVariableHeader variableHeader, ByteBuf payload)

方法概要

限定符和类型	方法和说明
ByteBuf	content() Return the data which is held by this ByteBufHolder.
MqttPublishMessage	copy() Creates a deep copy of this ByteBufHolder.
MqttPublishMessage	duplicate() Duplicates this ByteBufHolder.
ByteBuf	payload()
int	refCnt() Returns the reference count of this object.
boolean	release() Decreases the reference count by 1 and deallocates this object if the reference count reaches at 0.
boolean	release(int decrement) Decreases the reference count by the specified decrement and deallocates this object if the reference count reaches at 0.
MqttPublishMessage	replace(ByteBuf content) Returns a new ByteBufHolder which contains the specified content.
MqttPublishMessage	retain() Increases the reference count by 1.
MqttPublishMessage	retain(int increment) Increases the reference count by the specified increment.
MqttPublishMessage	retainedDuplicate() Duplicates this ByteBufHolder.
MqttPublishMessage	touch() Records the current access location of this object for debugging purposes.
MqttPublishMessage	touch(java.lang.Object hint) Records the current access location of this object with an additional arbitrary information for debugging purposes.
MqttPublishVariableHeader	variableHeader()

从类继承的方法 io.netty.handler.codec.mqtt.MqttMessage

decoderResult, fixedHeader, toString

从类继承的方法 java.lang.Object

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

构造器详细资料

MqttPublishMessage

public MqttPublishMessage(MqttFixedHeader mqttFixedHeader,
                          MqttPublishVariableHeader variableHeader,
                          ByteBuf payload)

方法详细资料

variableHeader

public MqttPublishVariableHeader variableHeader()

覆盖:

variableHeader 在类中 MqttMessage

payload

public ByteBuf payload()

覆盖:

payload 在类中 MqttMessage

content

public ByteBuf content()

从接口复制的说明: ByteBufHolder

Return the data which is held by this ByteBufHolder.

指定者:

content 在接口中 ByteBufHolder

copy

public MqttPublishMessage copy()

从接口复制的说明: ByteBufHolder

Creates a deep copy of this ByteBufHolder.

指定者:

copy 在接口中 ByteBufHolder

duplicate

public MqttPublishMessage duplicate()

从接口复制的说明: ByteBufHolder

Duplicates this ByteBufHolder. Be aware that this will not automatically call ByteBufHolder.retain().

指定者:

duplicate 在接口中 ByteBufHolder

retainedDuplicate

public MqttPublishMessage retainedDuplicate()

从接口复制的说明: ByteBufHolder

Duplicates this ByteBufHolder. This method returns a retained duplicate unlike ByteBufHolder.duplicate().

指定者:

retainedDuplicate 在接口中 ByteBufHolder

另请参阅:

ByteBuf.retainedDuplicate()

replace

public MqttPublishMessage replace(ByteBuf content)

从接口复制的说明: ByteBufHolder

Returns a new ByteBufHolder which contains the specified content.

指定者:

replace 在接口中 ByteBufHolder

refCnt

public int refCnt()

从接口复制的说明: ReferenceCounted

Returns the reference count of this object. If 0, it means this object has been deallocated.

指定者:

refCnt 在接口中 ReferenceCounted

retain

public MqttPublishMessage retain()

从接口复制的说明: ReferenceCounted

Increases the reference count by 1.

指定者:

retain 在接口中 ByteBufHolder

指定者:

retain 在接口中 ReferenceCounted

retain

public MqttPublishMessage retain(int increment)

从接口复制的说明: ReferenceCounted

Increases the reference count by the specified increment.

指定者:

retain 在接口中 ByteBufHolder

指定者:

retain 在接口中 ReferenceCounted

touch

public MqttPublishMessage touch()

从接口复制的说明: ReferenceCounted

Records the current access location of this object for debugging purposes. If this object is determined to be leaked, the information recorded by this operation will be provided to you via ResourceLeakDetector. This method is a shortcut to touch(null).

指定者:

touch 在接口中 ByteBufHolder

指定者:

touch 在接口中 ReferenceCounted

touch

public MqttPublishMessage touch(java.lang.Object hint)

从接口复制的说明: ReferenceCounted

Records the current access location of this object with an additional arbitrary information for debugging purposes. If this object is determined to be leaked, the information recorded by this operation will be provided to you via ResourceLeakDetector.

指定者:

touch 在接口中 ByteBufHolder

指定者:

touch 在接口中 ReferenceCounted

release

public boolean release()

从接口复制的说明: ReferenceCounted

Decreases the reference count by 1 and deallocates this object if the reference count reaches at 0.

指定者:

release 在接口中 ReferenceCounted

返回:

true if and only if the reference count became 0 and this object has been deallocated

release

public boolean release(int decrement)

从接口复制的说明: ReferenceCounted

Decreases the reference count by the specified decrement and deallocates this object if the reference count reaches at 0.

指定者:

release 在接口中 ReferenceCounted

返回:

true if and only if the reference count became 0 and this object has been deallocated