Package org.hibernate.reactive.event.impl

Class AbstractReactiveFlushingEventListener

java.lang.Object

org.hibernate.reactive.event.impl.AbstractReactiveFlushingEventListener

Direct Known Subclasses:

DefaultReactiveAutoFlushEventListener, DefaultReactiveFlushEventListener

public abstract class AbstractReactiveFlushingEventListener
extends Object

Collects commons methods needed during the management of flush events.

See Also:

• AbstractFlushingEventListener

Constructor Summary

Constructors

Constructor	Description
AbstractReactiveFlushingEventListener()

Method Summary

Modifier and Type	Method	Description
protected CompletionStage<Void>	flushEverythingToExecutions(org.hibernate.event.spi.FlushEvent event)	Coordinates the processing necessary to get things ready for executions as db calls by prepping the session caches and moving the appropriate entities and collections to their respective execution queues.
protected void	flushEverythingToExecutions(org.hibernate.event.spi.FlushEvent event, org.hibernate.engine.spi.PersistenceContext persistenceContext, org.hibernate.event.spi.EventSource session)
protected void	logFlushResults(org.hibernate.event.spi.FlushEvent event)
protected CompletionStage<Void>	performExecutions(org.hibernate.event.spi.EventSource session)
protected void	postFlush(org.hibernate.engine.spi.SessionImplementor session)	1.
protected void	postPostFlush(org.hibernate.engine.spi.SessionImplementor session)
protected CompletionStage<Void>	preFlush(org.hibernate.event.spi.EventSource session, org.hibernate.engine.spi.PersistenceContext persistenceContext)

Methods inherited from class java.lang.Object

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

Constructor Details

AbstractReactiveFlushingEventListener

public AbstractReactiveFlushingEventListener()

Method Details

performExecutions

protected CompletionStage<Void> performExecutions(org.hibernate.event.spi.EventSource session)

flushEverythingToExecutions

protected CompletionStage<Void> flushEverythingToExecutions(org.hibernate.event.spi.FlushEvent event)
                                                     throws org.hibernate.HibernateException

Coordinates the processing necessary to get things ready for executions as db calls by prepping the session caches and moving the appropriate entities and collections to their respective execution queues.

Parameters:

event - The flush event.

Throws:

org.hibernate.HibernateException - Error flushing caches to execution queues.

flushEverythingToExecutions

protected void flushEverythingToExecutions(org.hibernate.event.spi.FlushEvent event,
 org.hibernate.engine.spi.PersistenceContext persistenceContext,
 org.hibernate.event.spi.EventSource session)

preFlush

protected CompletionStage<Void> preFlush(org.hibernate.event.spi.EventSource session,
 org.hibernate.engine.spi.PersistenceContext persistenceContext)

logFlushResults

protected void logFlushResults(org.hibernate.event.spi.FlushEvent event)

postFlush

protected void postFlush(org.hibernate.engine.spi.SessionImplementor session)
                  throws org.hibernate.HibernateException

1. Recreate the collection key to collection map 2. rebuild the collection entries 3. call Interceptor.postFlush()

Throws:

org.hibernate.HibernateException

postPostFlush

protected void postPostFlush(org.hibernate.engine.spi.SessionImplementor session)