Skip to content

Commit 8f6af08

Browse files
injectivesinjectives
committed
Make eligible field final and refactor throws
1 parent 0a23c13 commit 8f6af08

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

41 files changed

+79
-92
lines changed

‎driver/src/main/java/org/neo4j/driver/internal/cluster/SingleDatabaseRoutingProcedureRunner.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ public class SingleDatabaseRoutingProcedureRunner implements RoutingProcedureRun
5151
static final String GET_ROUTING_TABLE = "CALL dbms.cluster.routing.getRoutingTable($" + ROUTING_CONTEXT + ")";
5252

5353
final RoutingContext context;
54-
private Logging logging;
54+
private final Logging logging;
5555

5656
public SingleDatabaseRoutingProcedureRunner(RoutingContext context, Logging logging) {
5757
this.context = context;

‎driver/src/main/java/org/neo4j/driver/internal/logging/NettyLogging.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@
2626
* This is the logging factory to delegate netty's logging to our logging system
2727
*/
2828
public class NettyLogging extends InternalLoggerFactory {
29-
private Logging logging;
29+
private final Logging logging;
3030

3131
public NettyLogging(Logging logging) {
3232
this.logging = logging;

‎driver/src/main/java/org/neo4j/driver/internal/packstream/PackStream.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -151,7 +151,7 @@ public class PackStream {
151151
private PackStream() {}
152152

153153
public static class Packer {
154-
private PackOutput out;
154+
private final PackOutput out;
155155

156156
public Packer(PackOutput out) {
157157
this.out = out;
@@ -337,7 +337,7 @@ public void packStructHeader(int size, byte signature) throws IOException {
337337
}
338338

339339
public static class Unpacker {
340-
private PackInput in;
340+
private final PackInput in;
341341

342342
public Unpacker(PackInput in) {
343343
this.in = in;

‎driver/src/main/java/org/neo4j/driver/internal/summary/InternalDatabaseInfo.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@
2222
import org.neo4j.driver.summary.DatabaseInfo;
2323

2424
public class InternalDatabaseInfo implements DatabaseInfo {
25-
public static DatabaseInfo DEFAULT_DATABASE_INFO = new InternalDatabaseInfo(null);
25+
public static final DatabaseInfo DEFAULT_DATABASE_INFO = new InternalDatabaseInfo(null);
2626

2727
private final String name;
2828

‎driver/src/main/java/org/neo4j/driver/internal/svm/MicrometerSubstitutions.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ final class Target_org_neo4j_driver_internal_DriverFactory {
4040
* @return A metrics provider, never null
4141
*/
4242
@Substitute
43-
protected static MetricsProvider getOrCreateMetricsProvider(Config config, Clock clock) {
43+
private static MetricsProvider getOrCreateMetricsProvider(Config config, Clock clock) {
4444
var metricsAdapter = config.metricsAdapter();
4545
if (metricsAdapter == null) {
4646
metricsAdapter = config.isMetricsEnabled() ? MetricsAdapter.DEFAULT : MetricsAdapter.DEV_NULL;

‎driver/src/main/java/org/neo4j/driver/internal/types/InternalTypeSystem.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@
5050
* @see Type
5151
*/
5252
public class InternalTypeSystem implements TypeSystem {
53-
public static InternalTypeSystem TYPE_SYSTEM = new InternalTypeSystem();
53+
public static final InternalTypeSystem TYPE_SYSTEM = new InternalTypeSystem();
5454

5555
private final TypeRepresentation anyType = constructType(ANY);
5656
private final TypeRepresentation booleanType = constructType(BOOLEAN);

‎driver/src/main/java/org/neo4j/driver/internal/util/Futures.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -226,8 +226,8 @@ public static <T> BiConsumer<T, Throwable> futureCompletingConsumer(CompletableF
226226
}
227227

228228
private static class CompletionResult<T> {
229-
T value;
230-
Throwable error;
229+
final T value;
230+
final Throwable error;
231231

232232
CompletionResult(T value, Throwable error) {
233233
this.value = value;

‎driver/src/main/java/org/neo4j/driver/internal/value/BooleanValue.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -26,8 +26,8 @@ private BooleanValue() {
2626
// do nothing
2727
}
2828

29-
public static BooleanValue TRUE = new TrueValue();
30-
public static BooleanValue FALSE = new FalseValue();
29+
public static final BooleanValue TRUE = new TrueValue();
30+
public static final BooleanValue FALSE = new FalseValue();
3131

3232
public static BooleanValue fromBoolean(boolean value) {
3333
return value ? TRUE : FALSE;

‎driver/src/test/java/org/neo4j/driver/integration/LoadCSVIT.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -73,9 +73,9 @@ private String createLocalIrisData(Session session) throws IOException {
7373
return neo4j.addImportFile("iris", ".csv", IRIS_DATA);
7474
}
7575

76-
private static String[] IRIS_CLASS_NAMES = new String[] {"Iris-setosa", "Iris-versicolor", "Iris-virginica"};
76+
private static final String[] IRIS_CLASS_NAMES = new String[] {"Iris-setosa", "Iris-versicolor", "Iris-virginica"};
7777

78-
private static String IRIS_DATA =
78+
private static final String IRIS_DATA =
7979
"sepal_length,sepal_width,petal_length,petal_width,class_name\n" + "5.1,3.5,1.4,0.2,Iris-setosa\n"
8080
+ "4.9,3.0,1.4,0.2,Iris-setosa\n"
8181
+ "4.7,3.2,1.3,0.2,Iris-setosa\n"

‎driver/src/test/java/org/neo4j/driver/integration/MetricsIT.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ class MetricsIT {
4242
static final DatabaseExtension neo4j = new DatabaseExtension();
4343

4444
private Driver driver;
45-
private MeterRegistry meterRegistry = new SimpleMeterRegistry();
45+
private final MeterRegistry meterRegistry = new SimpleMeterRegistry();
4646

4747
@BeforeEach
4848
void createDriver() {

‎driver/src/test/java/org/neo4j/driver/internal/CustomSecurityPlanTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,7 @@ void testCustomSecurityPlanUsed() {
5656
}
5757

5858
private static class SecurityPlanCapturingDriverFactory extends DriverFactory {
59-
List<SecurityPlan> capturedSecurityPlans = new ArrayList<>();
59+
final List<SecurityPlan> capturedSecurityPlans = new ArrayList<>();
6060

6161
@Override
6262
protected InternalDriver createDriver(

‎driver/src/test/java/org/neo4j/driver/internal/async/inbound/ConnectionReadTimeoutHandlerTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,8 +30,8 @@
3030
import org.neo4j.driver.exceptions.ConnectionReadTimeoutException;
3131

3232
public class ConnectionReadTimeoutHandlerTest {
33-
ConnectionReadTimeoutHandler handler = new ConnectionReadTimeoutHandler(15L, TimeUnit.SECONDS);
34-
ChannelHandlerContext context = mock(ChannelHandlerContext.class);
33+
final ConnectionReadTimeoutHandler handler = new ConnectionReadTimeoutHandler(15L, TimeUnit.SECONDS);
34+
final ChannelHandlerContext context = mock(ChannelHandlerContext.class);
3535

3636
@Test
3737
void shouldFireConnectionReadTimeoutExceptionAndCloseChannelOnReadTimeOutOnce() {

‎driver/src/test/java/org/neo4j/driver/internal/logging/ConsoleLoggingTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@
3434
import org.neo4j.driver.internal.logging.ConsoleLogging.ConsoleLogger;
3535

3636
class ConsoleLoggingTest {
37-
private static ByteArrayOutputStream out = new ByteArrayOutputStream();
37+
private static final ByteArrayOutputStream out = new ByteArrayOutputStream();
3838
private static PrintStream sysErr;
3939

4040
@BeforeAll

‎driver/src/test/java/org/neo4j/driver/internal/messaging/MessageFormatTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@
5757
import org.neo4j.driver.internal.util.messaging.MemorizingInboundMessageDispatcher;
5858

5959
class MessageFormatTest {
60-
public MessageFormat format = new MessageFormatV3();
60+
public final MessageFormat format = new MessageFormatV3();
6161

6262
@Test
6363
void shouldUnpackAllResponses() throws Throwable {

‎driver/src/test/java/org/neo4j/driver/internal/messaging/v3/MessageFormatV3Test.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@
3434
* It's done on this way to make easy to replace the implementation and still getting the same behaviour.
3535
*/
3636
class MessageFormatV3Test {
37-
private static MessageFormat messageFormat = BoltProtocolV3.INSTANCE.createMessageFormat();
37+
private static final MessageFormat messageFormat = BoltProtocolV3.INSTANCE.createMessageFormat();
3838

3939
@Test
4040
void shouldCreateCorrectWriter() {

‎driver/src/test/java/org/neo4j/driver/internal/messaging/v4/BoltProtocolV4Test.java

Lines changed: 9 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -98,11 +98,11 @@
9898

9999
public final class BoltProtocolV4Test {
100100

101-
protected static final String QUERY_TEXT = "RETURN $x";
102-
protected static final Map<String, Value> PARAMS = singletonMap("x", value(42));
103-
protected static final Query QUERY = new Query(QUERY_TEXT, value(PARAMS));
101+
private static final String QUERY_TEXT = "RETURN $x";
102+
private static final Map<String, Value> PARAMS = singletonMap("x", value(42));
103+
private static final Query QUERY = new Query(QUERY_TEXT, value(PARAMS));
104104

105-
protected final BoltProtocol protocol = createProtocol();
105+
private final BoltProtocol protocol = createProtocol();
106106
private final EmbeddedChannel channel = new EmbeddedChannel();
107107
private final InboundMessageDispatcher messageDispatcher = new InboundMessageDispatcher(channel, Logging.none());
108108

@@ -400,7 +400,7 @@ private static InternalAuthToken dummyAuthToken() {
400400
return (InternalAuthToken) AuthTokens.basic("hello", "world");
401401
}
402402

403-
protected void testFailedRunInAutoCommitTxWithWaitingForResponse(
403+
private void testFailedRunInAutoCommitTxWithWaitingForResponse(
404404
Set<Bookmark> bookmarks, TransactionConfig config, AccessMode mode) throws Exception {
405405
// Given
406406
var connection = connectionMock(mode, protocol);
@@ -434,7 +434,7 @@ protected void testFailedRunInAutoCommitTxWithWaitingForResponse(
434434
assertSame(error, actual);
435435
}
436436

437-
protected void testSuccessfulRunInAutoCommitTxWithWaitingForResponse(
437+
private void testSuccessfulRunInAutoCommitTxWithWaitingForResponse(
438438
Set<Bookmark> bookmarks, TransactionConfig config, AccessMode mode) throws Exception {
439439
// Given
440440
var connection = connectionMock(mode, protocol);
@@ -465,8 +465,7 @@ protected void testSuccessfulRunInAutoCommitTxWithWaitingForResponse(
465465
assertNotNull(cursorFuture.get());
466466
}
467467

468-
protected void testRunInUnmanagedTransactionAndWaitForRunResponse(boolean success, AccessMode mode)
469-
throws Exception {
468+
private void testRunInUnmanagedTransactionAndWaitForRunResponse(boolean success, AccessMode mode) throws Exception {
470469
// Given
471470
var connection = connectionMock(mode, protocol);
472471

@@ -497,7 +496,7 @@ connection, QUERY, mock(UnmanagedTransaction.class), UNLIMITED_FETCH_SIZE)
497496
}
498497
}
499498

500-
protected void testRunAndWaitForRunResponse(boolean autoCommitTx, TransactionConfig config, AccessMode mode)
499+
private void testRunAndWaitForRunResponse(boolean autoCommitTx, TransactionConfig config, AccessMode mode)
501500
throws Exception {
502501
// Given
503502
var connection = connectionMock(mode, protocol);
@@ -534,7 +533,7 @@ connection, QUERY, mock(UnmanagedTransaction.class), UNLIMITED_FETCH_SIZE)
534533
assertNotNull(cursorFuture.get());
535534
}
536535

537-
protected void testDatabaseNameSupport(boolean autoCommitTx) {
536+
private void testDatabaseNameSupport(boolean autoCommitTx) {
538537
var connection = connectionMock("foo", protocol);
539538
if (autoCommitTx) {
540539
var factory = protocol.runInAutoCommitTransaction(

‎driver/src/test/java/org/neo4j/driver/internal/messaging/v41/BoltProtocolV41Test.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -98,11 +98,11 @@
9898
import org.neo4j.driver.internal.spi.ResponseHandler;
9999

100100
public final class BoltProtocolV41Test {
101-
protected static final String QUERY_TEXT = "RETURN $x";
102-
protected static final Map<String, Value> PARAMS = singletonMap("x", value(42));
103-
protected static final Query QUERY = new Query(QUERY_TEXT, value(PARAMS));
101+
private static final String QUERY_TEXT = "RETURN $x";
102+
private static final Map<String, Value> PARAMS = singletonMap("x", value(42));
103+
private static final Query QUERY = new Query(QUERY_TEXT, value(PARAMS));
104104

105-
protected final BoltProtocol protocol = createProtocol();
105+
private final BoltProtocol protocol = createProtocol();
106106
private final EmbeddedChannel channel = new EmbeddedChannel();
107107
private final InboundMessageDispatcher messageDispatcher = new InboundMessageDispatcher(channel, Logging.none());
108108

‎driver/src/test/java/org/neo4j/driver/internal/messaging/v42/BoltProtocolV42Test.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -98,11 +98,11 @@
9898
import org.neo4j.driver.internal.spi.ResponseHandler;
9999

100100
public final class BoltProtocolV42Test {
101-
protected static final String QUERY_TEXT = "RETURN $x";
102-
protected static final Map<String, Value> PARAMS = singletonMap("x", value(42));
103-
protected static final Query QUERY = new Query(QUERY_TEXT, value(PARAMS));
101+
private static final String QUERY_TEXT = "RETURN $x";
102+
private static final Map<String, Value> PARAMS = singletonMap("x", value(42));
103+
private static final Query QUERY = new Query(QUERY_TEXT, value(PARAMS));
104104

105-
protected final BoltProtocol protocol = createProtocol();
105+
private final BoltProtocol protocol = createProtocol();
106106
private final EmbeddedChannel channel = new EmbeddedChannel();
107107
private final InboundMessageDispatcher messageDispatcher = new InboundMessageDispatcher(channel, Logging.none());
108108

@@ -111,7 +111,7 @@ public final class BoltProtocolV42Test {
111111
.withMetadata(singletonMap("key", value(42)))
112112
.build();
113113

114-
protected BoltProtocol createProtocol() {
114+
private BoltProtocol createProtocol() {
115115
return BoltProtocolV42.INSTANCE;
116116
}
117117

‎driver/src/test/java/org/neo4j/driver/internal/messaging/v43/BoltProtocolV43Test.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -97,11 +97,11 @@
9797
import org.neo4j.driver.internal.spi.ResponseHandler;
9898

9999
public final class BoltProtocolV43Test {
100-
protected static final String QUERY_TEXT = "RETURN $x";
101-
protected static final Map<String, Value> PARAMS = singletonMap("x", value(42));
102-
protected static final Query QUERY = new Query(QUERY_TEXT, value(PARAMS));
100+
private static final String QUERY_TEXT = "RETURN $x";
101+
private static final Map<String, Value> PARAMS = singletonMap("x", value(42));
102+
private static final Query QUERY = new Query(QUERY_TEXT, value(PARAMS));
103103

104-
protected final BoltProtocol protocol = createProtocol();
104+
private final BoltProtocol protocol = createProtocol();
105105
private final EmbeddedChannel channel = new EmbeddedChannel();
106106
private final InboundMessageDispatcher messageDispatcher = new InboundMessageDispatcher(channel, Logging.none());
107107

@@ -110,7 +110,7 @@ public final class BoltProtocolV43Test {
110110
.withMetadata(singletonMap("key", value(42)))
111111
.build();
112112

113-
protected BoltProtocol createProtocol() {
113+
private BoltProtocol createProtocol() {
114114
return BoltProtocolV43.INSTANCE;
115115
}
116116

‎driver/src/test/java/org/neo4j/driver/internal/metrics/MicrometerConnectionPoolMetricsTest.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -41,10 +41,10 @@ class MicrometerConnectionPoolMetricsTest {
4141
BoltServerAddress address;
4242
ConnectionPool pool;
4343
MeterRegistry registry;
44-
AtomicInteger inUse = new AtomicInteger(0);
45-
IntSupplier inUseSupplier = inUse::get;
46-
AtomicInteger idle = new AtomicInteger(0);
47-
IntSupplier idleSupplier = idle::get;
44+
final AtomicInteger inUse = new AtomicInteger(0);
45+
final IntSupplier inUseSupplier = inUse::get;
46+
final AtomicInteger idle = new AtomicInteger(0);
47+
final IntSupplier idleSupplier = idle::get;
4848

4949
@BeforeEach
5050
void beforeEach() {

‎driver/src/test/java/org/neo4j/driver/internal/util/io/BufferedChannelInput.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@
3030
*/
3131
public class BufferedChannelInput implements PackInput {
3232
private final ByteBuffer buffer;
33-
private ReadableByteChannel channel;
33+
private final ReadableByteChannel channel;
3434
private static final int DEFAULT_BUFFER_CAPACITY = 8192;
3535

3636
public BufferedChannelInput(ReadableByteChannel ch) {

‎driver/src/test/java/org/neo4j/driver/internal/value/BooleanValueTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@
3232
import org.neo4j.driver.types.TypeSystem;
3333

3434
class BooleanValueTest {
35-
private TypeSystem typeSystem = InternalTypeSystem.TYPE_SYSTEM;
35+
private final TypeSystem typeSystem = InternalTypeSystem.TYPE_SYSTEM;
3636

3737
@Test
3838
void testBooleanTrue() {

‎driver/src/test/java/org/neo4j/driver/internal/value/BytesValueTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@
3232
class BytesValueTest {
3333
private static final byte[] TEST_BYTES = "0123".getBytes();
3434

35-
private TypeSystem typeSystem = InternalTypeSystem.TYPE_SYSTEM;
35+
private final TypeSystem typeSystem = InternalTypeSystem.TYPE_SYSTEM;
3636

3737
@Test
3838
void testBytesValue() {

‎driver/src/test/java/org/neo4j/driver/internal/value/FloatValueTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@
3232
import org.neo4j.driver.types.TypeSystem;
3333

3434
class FloatValueTest {
35-
private TypeSystem typeSystem = InternalTypeSystem.TYPE_SYSTEM;
35+
private final TypeSystem typeSystem = InternalTypeSystem.TYPE_SYSTEM;
3636

3737
@Test
3838
void testZeroFloatValue() {

‎driver/src/test/java/org/neo4j/driver/internal/value/IntegerValueTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@
3232
import org.neo4j.driver.types.TypeSystem;
3333

3434
class IntegerValueTest {
35-
private TypeSystem typeSystem = InternalTypeSystem.TYPE_SYSTEM;
35+
private final TypeSystem typeSystem = InternalTypeSystem.TYPE_SYSTEM;
3636

3737
@Test
3838
void testZeroIntegerValue() {

‎driver/src/test/java/org/neo4j/driver/internal/value/StringValueTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@
3030
import org.neo4j.driver.types.TypeSystem;
3131

3232
class StringValueTest {
33-
private TypeSystem typeSystem = InternalTypeSystem.TYPE_SYSTEM;
33+
private final TypeSystem typeSystem = InternalTypeSystem.TYPE_SYSTEM;
3434

3535
@Test
3636
void testStringValue() {

‎driver/src/test/java/org/neo4j/driver/stress/AsyncWriteQuery.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@
2727
import org.neo4j.driver.internal.util.Futures;
2828

2929
public class AsyncWriteQuery<C extends AbstractContext> extends AbstractAsyncQuery<C> {
30-
private AbstractStressTestBase<C> stressTest;
30+
private final AbstractStressTestBase<C> stressTest;
3131

3232
public AsyncWriteQuery(AbstractStressTestBase<C> stressTest, Driver driver, boolean useBookmark) {
3333
super(driver, useBookmark);

‎driver/src/test/java/org/neo4j/driver/stress/AsyncWriteQueryInTx.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@
2626
import org.neo4j.driver.internal.util.Futures;
2727

2828
public class AsyncWriteQueryInTx<C extends AbstractContext> extends AbstractAsyncQuery<C> {
29-
private AbstractStressTestBase<C> stressTest;
29+
private final AbstractStressTestBase<C> stressTest;
3030

3131
public AsyncWriteQueryInTx(AbstractStressTestBase<C> stressTest, Driver driver, boolean useBookmark) {
3232
super(driver, useBookmark);

‎driver/src/test/java/org/neo4j/driver/stress/BlockingWriteQuery.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@
2525
import org.neo4j.driver.summary.ResultSummary;
2626

2727
public class BlockingWriteQuery<C extends AbstractContext> extends AbstractBlockingQuery<C> {
28-
private AbstractStressTestBase<C> stressTest;
28+
private final AbstractStressTestBase<C> stressTest;
2929

3030
public BlockingWriteQuery(AbstractStressTestBase<C> stressTest, Driver driver, boolean useBookmark) {
3131
super(driver, useBookmark);

‎driver/src/test/java/org/neo4j/driver/stress/BlockingWriteQueryInTx.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@
2525
import org.neo4j.driver.Result;
2626

2727
public class BlockingWriteQueryInTx<C extends AbstractContext> extends AbstractBlockingQuery<C> {
28-
private AbstractStressTestBase<C> stressTest;
28+
private final AbstractStressTestBase<C> stressTest;
2929

3030
public BlockingWriteQueryInTx(AbstractStressTestBase<C> stressTest, Driver driver, boolean useBookmark) {
3131
super(driver, useBookmark);

‎driver/src/test/java/org/neo4j/driver/stress/RxWriteQuery.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@
3030
import reactor.core.publisher.Mono;
3131

3232
public class RxWriteQuery<C extends AbstractContext> extends AbstractRxQuery<C> {
33-
private AbstractStressTestBase<C> stressTest;
33+
private final AbstractStressTestBase<C> stressTest;
3434

3535
public RxWriteQuery(AbstractStressTestBase<C> stressTest, Driver driver, boolean useBookmark) {
3636
super(driver, useBookmark);

0 commit comments

Comments
 (0)