String callbackServerURI = "socket:  InvokerLocator callbackServerLocator = new InvokerLocator(callbackServerURI);                              serverURI = serverLocatorURI; InvokerLocator serverLocator = new InvokerLocator(serverLocatorURI);  if (log.isTraceEnabled()) { log.trace("Connecting with server URI:" + serverURI); }  client = new Client(serverLocator);  if (log.isTraceEnabled()) { log.trace("Created client"); }      callbackServer = new Connector();  if (log.isTraceEnabled()) { log.trace("Starting virtual callback server with uri:" + callbackServerLocator.getLocatorURI()); }  callbackServer.setInvokerLocator(callbackServerLocator.getLocatorURI());  callbackServer.create();  callbackServer.start();  if (log.isTraceEnabled()) { log.trace("Created callback server"); }  client.connect();
   public ConnectionState(ConnectionDelegate delegate, String serverId)   {      super(null, delegate);      children = new SyncSet(new HashSet(), new WriterPreferenceReadWriteLock());      resourceManager = ResourceManagerFactory.instance.getResourceManager(serverId);            //TODO size should be configurable      pooledExecutor = new PooledExecutor(new LinkedQueue(), 50);      pooledExecutor.setMinimumPoolSize(50);         }