requestProcessors.setKeepAliveTime(NIOreceiver.getProcessormKeepAliveTime());
requestProcessors.setKeepAliveTime(NIOreceiver.getProcessorKeepAliveTime());
   protected void init()      throws Exception   {      TCP_NIO NIOreceiver = (TCP_NIO)receiver;      // use directExector if max thread pool size is less than or equal to zero.      if(NIOreceiver.getProcessorMaxThreads() <= 0) {         m_requestProcessors = new DirectExecutor();      }      else      {         // Create worker thread pool for processing incoming buffers         PooledExecutor requestProcessors = new PooledExecutor(new BoundedBuffer(NIOreceiver.getProcessorQueueSize()), NIOreceiver.getProcessorMaxThreads());         requestProcessors.setMinimumPoolSize(NIOreceiver.getProcessorMinThreads());         requestProcessors.setKeepAliveTime(NIOreceiver.getProcessormKeepAliveTime());         requestProcessors.waitWhenBlocked();         requestProcessors.createThreads(NIOreceiver.getProcessorThreads());         m_requestProcessors = requestProcessors;      }      m_writeHandlers = WriteHandler.create(NIOreceiver.getWriterThreads());      m_readHandlers = new ReadHandler[NIOreceiver.getReaderThreads()];      for (int i = 0; i < m_readHandlers.length; i++)         m_readHandlers[i] = new ReadHandler();   }