@Override
	public void open(Configuration parameters) throws Exception {
		try {
			synchronized (lock) {
				createConnection();
			}
		}
		catch (IOException e) {
			throw new IOException("Cannot connect to socket server at " + hostName + ":" + port, e);
		}
	}
@ Override public void open ( Configuration parameters ) throws Exception { try { synchronized ( lock ) { createConnection ( ) ; } } catch ( IOException e ) { throw new IOException ( "Cannot connect to socket server at " + hostName + ":" + port , e ) ; } }
Initialize the connection with the Socket in the server.
@param parameters Configuration.