code: @SuppressWarnings("rawtypes")
      public void prepare(Map stormConf) {
          this.stormConf = stormConf;
  
          int maxWorkers = Utils.getInt(stormConf.get(Config.STORM_MESSAGING_NETTY_CLIENT_WORKER_THREADS));
          ThreadFactory bossFactory = new NettyRenameThreadFactory(MetricDef.NETTY_CLI + "boss");
          ThreadFactory workerFactory = new NettyRenameThreadFactory(MetricDef.NETTY_CLI + "worker");
  
          if (maxWorkers > 0) {
              clientChannelFactory = new NioClientSocketChannelFactory(Executors.newCachedThreadPool(bossFactory),
                      Executors.newCachedThreadPool(workerFactory), maxWorkers);
          } else {
              clientChannelFactory = new NioClientSocketChannelFactory(Executors.newCachedThreadPool(bossFactory),
                      Executors.newCachedThreadPool(workerFactory));
          }
  
          reconnector = new ReconnectRunnable();
          new AsyncLoopThread(reconnector, true, Thread.MIN_PRIORITY, true);
      }
docs: initialization per Storm configuration