|
18 | 18 | */
|
19 | 19 | package org.neo4j.driver;
|
20 | 20 |
|
21 |
| -import org.reactivestreams.Subscription; |
22 |
| - |
23 | 21 | import java.io.File;
|
24 | 22 | import java.net.InetAddress;
|
25 | 23 | import java.util.Objects;
|
26 | 24 | import java.util.concurrent.TimeUnit;
|
27 | 25 | import java.util.logging.Level;
|
28 | 26 |
|
29 |
| -import org.neo4j.driver.async.AsyncSession; |
30 |
| -import org.neo4j.driver.exceptions.ServiceUnavailableException; |
31 |
| -import org.neo4j.driver.exceptions.SessionExpiredException; |
32 |
| -import org.neo4j.driver.exceptions.TransientException; |
33 | 27 | import org.neo4j.driver.internal.RevocationStrategy;
|
34 | 28 | import org.neo4j.driver.internal.SecuritySettings;
|
35 | 29 | import org.neo4j.driver.internal.async.pool.PoolSettings;
|
36 | 30 | import org.neo4j.driver.internal.cluster.RoutingSettings;
|
37 | 31 | import org.neo4j.driver.internal.handlers.pulln.FetchSizeUtil;
|
38 | 32 | import org.neo4j.driver.internal.retry.RetrySettings;
|
39 | 33 | import org.neo4j.driver.net.ServerAddressResolver;
|
40 |
| -import org.neo4j.driver.reactive.RxSession; |
41 | 34 | import org.neo4j.driver.util.Immutable;
|
42 |
| -import org.neo4j.driver.util.Resource; |
43 | 35 |
|
44 | 36 | import static java.lang.String.format;
|
45 | 37 | import static org.neo4j.driver.Logging.javaUtilLogging;
|
@@ -318,8 +310,8 @@ public ConfigBuilder withLogging( Logging logging )
|
318 | 310 | * Enable logging of leaked sessions.
|
319 | 311 | * <p>
|
320 | 312 | * Each {@link Session session} is associated with a network connection and thus is a
|
321 |
| - * {@link Resource resource} that needs to be explicitly closed. Unclosed sessions will result in socket |
322 |
| - * leaks and could cause {@link OutOfMemoryError}s. |
| 313 | + * {@link org.neo4j.driver.util.Resource resource} that needs to be explicitly closed. |
| 314 | + * Unclosed sessions will result in socket leaks and could cause {@link OutOfMemoryError}s. |
323 | 315 | * <p>
|
324 | 316 | * Session is considered to be leaked when it is finalized via {@link Object#finalize()} while not being
|
325 | 317 | * closed. This option turns on logging of such sessions and stacktraces of where they were created.
|
@@ -606,12 +598,13 @@ public ConfigBuilder withRoutingTablePurgeDelay( long delay, TimeUnit unit )
|
606 | 598 | * This config is only valid when the driver is used with servers that support Bolt V4 (Server version 4.0 and later).
|
607 | 599 | *
|
608 | 600 | * Bolt V4 enables pulling records in batches to allow client to take control of data population and apply back pressure to server.
|
609 |
| - * This config specifies the default fetch size for all query runs using {@link Session} and {@link AsyncSession}. |
| 601 | + * This config specifies the default fetch size for all query runs using {@link Session} and {@link org.neo4j.driver.async.AsyncSession}. |
610 | 602 | * By default, the value is set to {@code 1000}.
|
611 | 603 | * Use {@code -1} to disables back pressure and config client to pull all records at once after each run.
|
612 | 604 | *
|
613 |
| - * This config only applies to run result obtained via {@link Session} and {@link AsyncSession}. |
614 |
| - * As with {@link RxSession}, the batch size is provided via {@link Subscription#request(long)} instead. |
| 605 | + * This config only applies to run result obtained via {@link Session} and {@link org.neo4j.driver.async.AsyncSession}. |
| 606 | + * As with {@link org.neo4j.driver.reactive.RxSession}, the batch size is provided via |
| 607 | + * {@link org.reactivestreams.Subscription#request(long)} instead. |
615 | 608 | * @param size the default record fetch size when pulling records in batches using Bolt V4.
|
616 | 609 | * @return this builder
|
617 | 610 | */
|
@@ -660,9 +653,9 @@ public ConfigBuilder withConnectionTimeout( long value, TimeUnit unit )
|
660 | 653 | /**
|
661 | 654 | * Specify the maximum time transactions are allowed to retry via
|
662 | 655 | * {@link Session#readTransaction(TransactionWork)} and {@link Session#writeTransaction(TransactionWork)}
|
663 |
| - * methods. These methods will retry the given unit of work on {@link ServiceUnavailableException}, |
664 |
| - * {@link SessionExpiredException} and {@link TransientException} with exponential backoff using initial |
665 |
| - * delay of 1 second. |
| 656 | + * methods. These methods will retry the given unit of work on {@link org.neo4j.driver.exceptions.ServiceUnavailableException}, |
| 657 | + * {@link org.neo4j.driver.exceptions.SessionExpiredException} and {@link org.neo4j.driver.exceptions.TransientException} with |
| 658 | + * exponential backoff using initial delay of 1 second. |
666 | 659 | * <p>
|
667 | 660 | * Default value is 30 seconds.
|
668 | 661 | *
|
|
0 commit comments