this.clientConnectionID = clientConnectionId;
   ServerConnectionEndpoint(ServerPeer serverPeer, String clientID, String username,                            String password, String clientConnectionId)   {      this.serverPeer = serverPeer;      dm = serverPeer.getDestinationManager();      sm = serverPeer.getSecurityManager();      tr = serverPeer.getTxRepository();      cm = serverPeer.getConnectionManager();      started = false;      this.connectionID = serverPeer.getNextObjectID();      this.clientConnectionID = clientConnectionId;      this.clientID = clientID;      consumers = new ConcurrentReaderHashMap();      sessions = new ConcurrentReaderHashMap();      temporaryDestinations = Collections.synchronizedSet(new HashSet()); //TODO Can probably improve concurrency for this      this.username = username;      this.password = password;            closeLock = new WriterPreferenceReadWriteLock();   }