diff --git a/driver/src/main/java/org/neo4j/driver/internal/connector/socket/SocketConnection.java b/driver/src/main/java/org/neo4j/driver/internal/connector/socket/SocketConnection.java index 4706f8dba6..e9831f826e 100644 --- a/driver/src/main/java/org/neo4j/driver/internal/connector/socket/SocketConnection.java +++ b/driver/src/main/java/org/neo4j/driver/internal/connector/socket/SocketConnection.java @@ -67,6 +67,7 @@ public SocketConnection( String host, int port, Config config ) public void init( String clientName, Map authToken ) { queueMessage( new InitMessage( clientName, authToken ), StreamCollector.NO_OP ); + sync(); } @Override diff --git a/driver/src/test/java/org/neo4j/driver/v1/integration/CredentialsIT.java b/driver/src/test/java/org/neo4j/driver/v1/integration/CredentialsIT.java index 89dc388980..65a1d452ff 100644 --- a/driver/src/test/java/org/neo4j/driver/v1/integration/CredentialsIT.java +++ b/driver/src/test/java/org/neo4j/driver/v1/integration/CredentialsIT.java @@ -74,15 +74,12 @@ public void shouldGetHelpfulErrorOnInvalidCredentials() throws Throwable String password = "secret"; enableAuth( password ); - Driver driver = GraphDatabase.driver( neo4j.address(), basic("thisisnotthepassword", password ) ); - Session session = driver.session(); - // Expect exception.expect( ClientException.class ); exception.expectMessage( "The client is unauthorized due to authentication failure." ); // When - session.run( "RETURN 1" ).single().get(0); + GraphDatabase.driver( neo4j.address(), basic("thisisnotthepassword", password ) ).session(); } private void enableAuth( String password ) throws Exception