run() — netty Function Reference

Architecture documentation for the run() function in AutobahnServer.java from the netty codebase.

Function java Buffer Telemetry called by 1

Entity Profile

Buffer→ Telemetry→ run() — netty Function Reference

Dependency Diagram

graph TD
  372c8382_5835_52eb_dfa8_f1feffe27f33["run()"]
  c8849536_a67f_0799_3c1a_c71e4ec6d145["AutobahnServer"]
  372c8382_5835_52eb_dfa8_f1feffe27f33 -->|defined in| c8849536_a67f_0799_3c1a_c71e4ec6d145
  bb53466f_7329_2040_7331_e79c89b0faf2["main()"]
  bb53466f_7329_2040_7331_e79c89b0faf2 -->|calls| 372c8382_5835_52eb_dfa8_f1feffe27f33
  style 372c8382_5835_52eb_dfa8_f1feffe27f33 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

testsuite-autobahn/src/main/java/io/netty/testsuite/autobahn/AutobahnServer.java lines 39–54

    public void run() throws Exception {
        EventLoopGroup group = new MultiThreadIoEventLoopGroup(NioIoHandler.newFactory());
        try {
            ServerBootstrap b = new ServerBootstrap();
            b.group(group)
             .channel(NioServerSocketChannel.class)
             .childOption(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT)
             .childHandler(new AutobahnServerInitializer());

            ChannelFuture f = b.bind(port).sync();
            System.out.println("Web Socket Server started at port " + port);
            f.channel().closeFuture().sync();
        } finally {
            group.shutdownGracefully();
        }
    }