public class DefaultReactiveFlushEntityEventListener extends Object
org.hibernate.event.internal.DefaultFlushEntityEventListener
. This implementation is almost, but not quite, a line-for-line copy of DefaultFlushEntityEventListener
. The only difference is that it creates ReactiveEntityUpdateAction
s. Unlike other event listeners in this package, this listener's onFlushEntity(FlushEntityEvent)
method does not need to by called in a non-blocking manner, and so therefore there is no ReactiveFlushEntityEventListener
interface.Constructor and Description |
---|
DefaultReactiveFlushEntityEventListener() |
Modifier and Type | Method and Description |
---|---|
void | checkId(Object object, EntityPersister persister, Serializable id, SessionImplementor session) make sure user didn't mangle the id |
protected void | dirtyCheck(FlushEntityEvent event) Perform a dirty check, and attach the results to the event |
protected boolean | handleInterception(FlushEntityEvent event) |
void | injectCallbackRegistry(CallbackRegistry callbackRegistry) |
protected boolean | invokeInterceptor(SessionImplementor session, Object entity, EntityEntry entry, Object[] values, EntityPersister persister) |
protected boolean | isUpdateNecessary(FlushEntityEvent event) Performs all necessary checking to determine if an entity needs an SQL update to synchronize its state to the database. |
void | onFlushEntity(FlushEntityEvent event) Flushes a single entity's state to the database, by scheduling an update action, if necessary |
public DefaultReactiveFlushEntityEventListener()
public void injectCallbackRegistry(CallbackRegistry callbackRegistry)
public void checkId(Object object, EntityPersister persister, Serializable id, SessionImplementor session) throws HibernateException
HibernateException
public void onFlushEntity(FlushEntityEvent event) throws HibernateException
HibernateException
protected boolean handleInterception(FlushEntityEvent event)
protected boolean invokeInterceptor(SessionImplementor session, Object entity, EntityEntry entry, Object[] values, EntityPersister persister)
protected final boolean isUpdateNecessary(FlushEntityEvent event) throws HibernateException
HibernateException
protected void dirtyCheck(FlushEntityEvent event) throws HibernateException
HibernateException