netty Architecture Docs
Home / Class/ MqttHeartBeatBroker Class — netty Architecture

MqttHeartBeatBroker Class — netty Architecture

Architecture documentation for the MqttHeartBeatBroker class in MqttHeartBeatBroker.java from the netty codebase.

Class java

Entity Profile

Dependency Diagram

graph TD
  a92e1647_c16d_4906_57e3_56ea7e4ca686["MqttHeartBeatBroker"]
  c253141f_e2ab_0549_e229_f45b3df79fec["MqttHeartBeatBroker.java"]
  a92e1647_c16d_4906_57e3_56ea7e4ca686 -->|defined in| c253141f_e2ab_0549_e229_f45b3df79fec
  96d89bc9_7e7a_64e3_438b_8892682b7aa1["MqttHeartBeatBroker()"]
  a92e1647_c16d_4906_57e3_56ea7e4ca686 -->|method| 96d89bc9_7e7a_64e3_438b_8892682b7aa1
  972c152f_5e56_d101_8b6a_25d3214e650f["main()"]
  a92e1647_c16d_4906_57e3_56ea7e4ca686 -->|method| 972c152f_5e56_d101_8b6a_25d3214e650f

Relationship Graph

Source Code

example/src/main/java/io/netty/example/mqtt/heartBeat/MqttHeartBeatBroker.java lines 33–64

public final class MqttHeartBeatBroker {

    private MqttHeartBeatBroker() {
    }

    public static void main(String[] args) throws Exception {
        EventLoopGroup group = new MultiThreadIoEventLoopGroup(NioIoHandler.newFactory());

        try {
            ServerBootstrap b = new ServerBootstrap();
            b.group(group);
            b.option(ChannelOption.SO_BACKLOG, 1024);
            b.channel(NioServerSocketChannel.class);
            b.childHandler(new ChannelInitializer<SocketChannel>() {
                @Override
                protected void initChannel(SocketChannel ch) throws Exception {
                    ch.pipeline().addLast("encoder", MqttEncoder.INSTANCE);
                    ch.pipeline().addLast("decoder", new MqttDecoder());
                    ch.pipeline().addLast("heartBeatHandler", new IdleStateHandler(45, 0, 0, TimeUnit.SECONDS));
                    ch.pipeline().addLast("handler", MqttHeartBeatBrokerHandler.INSTANCE);
                }
            });

            ChannelFuture f = b.bind(1883).sync();
            System.out.println("Broker initiated...");

            f.channel().closeFuture().sync();
        } finally {
            group.shutdownGracefully();
        }
    }
}

Defined In

Source

Frequently Asked Questions

What is the MqttHeartBeatBroker class?
MqttHeartBeatBroker is a class in the netty codebase, defined in example/src/main/java/io/netty/example/mqtt/heartBeat/MqttHeartBeatBroker.java.
Where is MqttHeartBeatBroker defined?
MqttHeartBeatBroker is defined in example/src/main/java/io/netty/example/mqtt/heartBeat/MqttHeartBeatBroker.java at line 33.

Analyze Your Own Codebase

Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.

Try Supermodel Free