channelActive() — netty Function Reference
Architecture documentation for the channelActive() function in MqttHeartBeatClientHandler.java from the netty codebase.
Entity Profile
Dependency Diagram
graph TD 72104b44_dd73_2bb4_7e67_a8a38918851d["channelActive()"] ccbda2b6_8f39_2dce_7583_46d91f6cccb1["MqttHeartBeatClientHandler"] 72104b44_dd73_2bb4_7e67_a8a38918851d -->|defined in| ccbda2b6_8f39_2dce_7583_46d91f6cccb1 style 72104b44_dd73_2bb4_7e67_a8a38918851d fill:#6366f1,stroke:#818cf8,color:#fff
Relationship Graph
Source Code
example/src/main/java/io/netty/example/mqtt/heartBeat/MqttHeartBeatClientHandler.java lines 52–69
@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
MqttFixedHeader connectFixedHeader =
new MqttFixedHeader(MqttMessageType.CONNECT, false, MqttQoS.AT_MOST_ONCE, false, 0);
MqttConnectVariableHeader connectVariableHeader =
new MqttConnectVariableHeader(PROTOCOL_NAME_MQTT_3_1_1, PROTOCOL_VERSION_MQTT_3_1_1, true, true, false,
0, false, false, 20, MqttProperties.NO_PROPERTIES);
MqttConnectPayload connectPayload = new MqttConnectPayload(clientId,
MqttProperties.NO_PROPERTIES,
null,
null,
userName,
password);
MqttConnectMessage connectMessage =
new MqttConnectMessage(connectFixedHeader, connectVariableHeader, connectPayload);
ctx.writeAndFlush(connectMessage);
System.out.println("Sent CONNECT");
}
Domain
Subdomains
Source
Frequently Asked Questions
What does channelActive() do?
channelActive() is a function in the netty codebase, defined in example/src/main/java/io/netty/example/mqtt/heartBeat/MqttHeartBeatClientHandler.java.
Where is channelActive() defined?
channelActive() is defined in example/src/main/java/io/netty/example/mqtt/heartBeat/MqttHeartBeatClientHandler.java at line 52.
Analyze Your Own Codebase
Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.
Try Supermodel Free