driver-spring-integration/io.github.octaviusframework.driver.spring/OctaviusSessionSynchronization

OctaviusSessionSynchronization

internal class OctaviusSessionSynchronization(holder: OctaviusSessionHolder, key: OctaviusSessionKey) : ResourceHolderSynchronization<OctaviusSessionHolder, OctaviusSessionKey>

Ends the transaction-scoped session at the right point in Spring's completion sequence.

ResourceHolderSynchronization carries the binding for us, including suspend and resume - a REQUIRES_NEW transaction inside another one gets a different connection, and without unbinding over the suspension it would find the outer transaction's session still bound and run its work on the wrong connection.

Constructors

constructor(holder: OctaviusSessionHolder, key: OctaviusSessionKey)

Properties

order

open override val order: Int

Functions

afterCommit

open fun afterCommit()

afterCompletion

open fun afterCompletion(status: Int)

beforeCommit

open fun beforeCommit(readOnly: Boolean)

beforeCompletion

open fun beforeCompletion()

cleanupResource

protected open fun cleanupResource(resourceHolder: OctaviusSessionHolder?, resourceKey: OctaviusSessionKey?, committed: Boolean)

flush

open fun flush()

flushResource

protected open fun flushResource(resourceHolder: OctaviusSessionHolder?)

getOrder

open override fun getOrder(): Int

Ahead of Spring's own connection synchronization, which releases the connection at DataSourceUtils.CONNECTION_SYNCHRONIZATION_ORDER. Ending the session runs statements on that connection, so it has to come first.

processResourceAfterCommit

protected open fun processResourceAfterCommit(resourceHolder: OctaviusSessionHolder?)

releaseResource

protected open override fun releaseResource(resourceHolder: OctaviusSessionHolder, resourceKey: OctaviusSessionKey)

resume

open fun resume()

savepoint

open fun savepoint(savepoint: Any?)

savepointRollback

open fun savepointRollback(savepoint: Any?)

shouldReleaseAfterCompletion

protected open fun shouldReleaseAfterCompletion(resourceHolder: OctaviusSessionHolder?): Boolean

shouldReleaseBeforeCompletion

protected open override fun shouldReleaseBeforeCompletion(): Boolean

Moves the release from beforeCompletion, where this class puts it by default, to afterCompletion.

shouldUnbindAtCompletion

protected open fun shouldUnbindAtCompletion(): Boolean

suspend

open fun suspend()