Module org.neo4j.driver

Package org.neo4j.driver.internal.async

Class NetworkSession

java.lang.Object

org.neo4j.driver.internal.async.NetworkSession

Direct Known Subclasses:

LeakLoggingNetworkSession

public class NetworkSession
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	NetworkSession.RunRxResponseHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected final Logger	log

Constructor Summary

Constructors

Constructor

Description

NetworkSession(BoltSecurityPlanManager securityPlanManager, BoltConnectionProvider boltConnectionProvider, RetryLogic retryLogic, DatabaseName databaseName, AccessMode mode, Set<Bookmark> bookmarks, String impersonatedUser, long fetchSize, Logging logging, BookmarkManager bookmarkManager, NotificationConfig driverNotificationConfig, NotificationConfig notificationConfig, AuthToken overrideAuthToken, boolean telemetryDisabled, AuthTokenManager authTokenManager)

Method Summary

Modifier and Type	Method	Description
CompletionStage<UnmanagedTransaction>	beginTransactionAsync(AccessMode mode, TransactionConfig config, String txType, ApiTelemetryWork apiTelemetryWork, boolean flush)
CompletionStage<UnmanagedTransaction>	beginTransactionAsync(AccessMode mode, TransactionConfig config, ApiTelemetryWork apiTelemetryWork)
CompletionStage<UnmanagedTransaction>	beginTransactionAsync(TransactionConfig config, String txType, ApiTelemetryWork apiTelemetryWork)
CompletionStage<UnmanagedTransaction>	beginTransactionAsync(TransactionConfig config, ApiTelemetryWork apiTelemetryWork)
CompletionStage<Void>	closeAsync()
CompletionStage<BoltConnection>	connectionAsync()
protected CompletionStage<Boolean>	currentConnectionIsOpen()
boolean	isOpen()
Set<Bookmark>	lastBookmarks()
CompletionStage<Void>	releaseConnectionAsync()
CompletionStage<Void>	resetAsync()
RetryLogic	retryLogic()
CompletionStage<ResultCursor>	runAsync(Query query, TransactionConfig config)
CompletionStage<RxResultCursor>	runRx(Query query, TransactionConfig config, CompletionStage<RxResultCursor> cursorPublishStage)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

log

protected final Logger log

Constructor Details

NetworkSession

public NetworkSession(BoltSecurityPlanManager securityPlanManager,
 BoltConnectionProvider boltConnectionProvider,
 RetryLogic retryLogic,
 DatabaseName databaseName,
 AccessMode mode,
 Set<Bookmark> bookmarks,
 String impersonatedUser,
 long fetchSize,
 Logging logging,
 BookmarkManager bookmarkManager,
 NotificationConfig driverNotificationConfig,
 NotificationConfig notificationConfig,
 AuthToken overrideAuthToken,
 boolean telemetryDisabled,
 AuthTokenManager authTokenManager)

Method Details

runAsync

public CompletionStage<ResultCursor> runAsync(Query query,
 TransactionConfig config)

runRx

public CompletionStage<RxResultCursor> runRx(Query query,
 TransactionConfig config,
 CompletionStage<RxResultCursor> cursorPublishStage)

beginTransactionAsync

public CompletionStage<UnmanagedTransaction> beginTransactionAsync(TransactionConfig config,
 ApiTelemetryWork apiTelemetryWork)

beginTransactionAsync

public CompletionStage<UnmanagedTransaction> beginTransactionAsync(TransactionConfig config,
 String txType,
 ApiTelemetryWork apiTelemetryWork)

beginTransactionAsync

public CompletionStage<UnmanagedTransaction> beginTransactionAsync(AccessMode mode,
 TransactionConfig config,
 ApiTelemetryWork apiTelemetryWork)

beginTransactionAsync

public CompletionStage<UnmanagedTransaction> beginTransactionAsync(AccessMode mode,
 TransactionConfig config,
 String txType,
 ApiTelemetryWork apiTelemetryWork,
 boolean flush)

resetAsync

public CompletionStage<Void> resetAsync()

retryLogic

public RetryLogic retryLogic()

lastBookmarks

public Set<Bookmark> lastBookmarks()

releaseConnectionAsync

public CompletionStage<Void> releaseConnectionAsync()

connectionAsync

public CompletionStage<BoltConnection> connectionAsync()

isOpen

public boolean isOpen()

closeAsync

public CompletionStage<Void> closeAsync()

currentConnectionIsOpen

protected CompletionStage<Boolean> currentConnectionIsOpen()