class CollectorOfflineProcessor implements NettyRemotingProcessor {

    private final ManageServer manageServer;

    public CollectorOfflineProcessor(final ManageServer manageServer) {
        this.manageServer = manageServer;
    }

    @Override
    public ClusterMsg.Message handle(ChannelHandlerContext ctx, ClusterMsg.Message message) {<FILL_FUNCTION_BODY>}
}

        String collector = message.getIdentity();
        log.info("the collector {} actively requests to go offline.", collector);
        this.manageServer.getCollectorAndJobScheduler().collectorGoOffline(collector);
        return null;
    
<no_super_class>