ExecutorService o = ExecutorServiceFactory.get(container);
			try {
				Method coreMethod = ThreadPoolExecutor.class.getMethod("setCorePoolSize", new Class[] { int.class});
				Method maxMethod = ThreadPoolExecutor.class.getMethod("setMaximumPoolSize", new Class[] { int.class});
				Proxy.getInvocationHandler(o).invoke(o, coreMethod, new Object[] {1});
				Proxy.getInvocationHandler(o).invoke(o, maxMethod, new Object[] {2});
			} catch (Throwable thrbl) {
				throw new RuntimeException(thrbl);
			}

    List<IElementProcessor> postProcessors = IPluginContainer.INSTANCE.getPostProcessors();
    for (Iterator<IElementProcessor> it = postProcessors.iterator(); it.hasNext();)
    {
      IElementProcessor elementProcessor = it.next();
      if (elementProcessor instanceof TransportInjector)
      {
        it.remove();
        break;
      }
    }

    TransportInjector transportInjector = new TransportInjector()
    {
      @Override
      protected ExecutorService getExecutorService(IManagedContainer container)
      {
        return (ExecutorService)container.getElement(ExecutorServiceFactory.PRODUCT_GROUP, ExecutorServiceFactory.TYPE, "10:1000:60");
      }
    };

    postProcessors.add(transportInjector);