Skip to content

Commit 88e757e

Browse files
committed
Rolled back cluster feature
1 parent e908801 commit 88e757e

File tree

5 files changed

+7
-265
lines changed

5 files changed

+7
-265
lines changed

driver/src/main/java/org/neo4j/driver/internal/ClusterDriver.java

Lines changed: 0 additions & 154 deletions
This file was deleted.

driver/src/main/java/org/neo4j/driver/v1/GraphDatabase.java

Lines changed: 7 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -18,18 +18,17 @@
1818
*/
1919
package org.neo4j.driver.v1;
2020

21-
import java.io.IOException;
22-
import java.net.URI;
23-
import java.security.GeneralSecurityException;
24-
25-
import org.neo4j.driver.internal.ClusterDriver;
2621
import org.neo4j.driver.internal.DirectDriver;
2722
import org.neo4j.driver.internal.SessionParameters;
23+
import org.neo4j.driver.internal.net.BoltServerAddress;
2824
import org.neo4j.driver.internal.net.pooling.PoolSettings;
2925
import org.neo4j.driver.internal.security.SecurityPlan;
30-
import org.neo4j.driver.internal.net.BoltServerAddress;
3126
import org.neo4j.driver.v1.exceptions.ClientException;
3227

28+
import java.io.IOException;
29+
import java.net.URI;
30+
import java.security.GeneralSecurityException;
31+
3332
import static java.lang.String.format;
3433
import static org.neo4j.driver.v1.Config.EncryptionLevel.REQUIRED;
3534
import static org.neo4j.driver.v1.Config.EncryptionLevel.REQUIRED_NON_LOCAL;
@@ -152,7 +151,7 @@ public static Driver driver( URI uri, AuthToken authToken, Config config )
152151
SecurityPlan securityPlan;
153152
try
154153
{
155-
securityPlan = createSecurityPlan( address, authToken, config );
154+
securityPlan = createSecurityPlan( address, config );
156155
}
157156
catch ( GeneralSecurityException | IOException ex )
158157
{
@@ -169,8 +168,6 @@ public static Driver driver( URI uri, AuthToken authToken, Config config )
169168
{
170169
case "bolt":
171170
return new DirectDriver( address, sessionParameters, securityPlan, poolSettings, config.logging() );
172-
case "bolt+discovery":
173-
return new ClusterDriver( address, sessionParameters, securityPlan, poolSettings, config.logging() );
174171
default:
175172
throw new ClientException( format( "Unsupported URI scheme: %s", scheme ) );
176173
}
@@ -180,7 +177,7 @@ public static Driver driver( URI uri, AuthToken authToken, Config config )
180177
* Establish a complete SecurityPlan based on the details provided for
181178
* driver construction.
182179
*/
183-
private static SecurityPlan createSecurityPlan( BoltServerAddress address, AuthToken authToken, Config config )
180+
private static SecurityPlan createSecurityPlan( BoltServerAddress address, Config config )
184181
throws GeneralSecurityException, IOException
185182
{
186183
Config.EncryptionLevel encryptionLevel = config.encryptionLevel();

driver/src/test/java/org/neo4j/driver/v1/ClusterDriverTest.java

Lines changed: 0 additions & 70 deletions
This file was deleted.

driver/src/test/java/org/neo4j/driver/v1/GraphDatabaseTest.java

Lines changed: 0 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -21,19 +21,13 @@
2121

2222
import org.junit.Rule;
2323
import org.junit.Test;
24-
import org.neo4j.driver.internal.ClusterDriver;
2524
import org.neo4j.driver.internal.DirectDriver;
26-
import org.neo4j.driver.internal.net.BoltServerAddress;
2725
import org.neo4j.driver.v1.util.TestNeo4jSession;
2826

2927
import java.net.URI;
30-
import java.util.Collection;
31-
import java.util.Set;
3228

33-
import static org.hamcrest.core.IsEqual.equalTo;
3429
import static org.hamcrest.core.IsInstanceOf.instanceOf;
3530
import static org.junit.Assert.*;
36-
import static org.neo4j.driver.v1.Values.parameters;
3731

3832
public class GraphDatabaseTest
3933
{
@@ -54,18 +48,4 @@ public void boltSchemeShouldInstantiateDirectDriver()
5448

5549
}
5650

57-
@Test
58-
public void boltPlusDiscoverySchemeShouldInstantiateClusterDriver()
59-
{
60-
// Given
61-
URI uri = URI.create( "bolt+discovery://localhost:7687" );
62-
63-
// When
64-
Driver driver = GraphDatabase.driver( uri );
65-
66-
// Then
67-
assertThat( driver, instanceOf( ClusterDriver.class ) );
68-
69-
}
70-
7151
}

driver/src/test/resources/discovery.script

Lines changed: 0 additions & 11 deletions
This file was deleted.

0 commit comments

Comments
 (0)