final class org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventLoader extends java.lang.Object implements org.hibernate.search.util.common.spi.ToStringTreeAppendable
{
private static final java.lang.String LOAD_QUERY_STRING;
private static final org.hibernate.search.mapper.orm.outboxpolling.logging.impl.Log log;
private final org.hibernate.LockOptions lockOptions;
void <init>(org.hibernate.dialect.Dialect)
{
org.hibernate.LockMode v, v;
org.hibernate.LockOptions v, v;
org.hibernate.dialect.Dialect v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventLoader v;
boolean v;
v := @this: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventLoader;
v := @parameter: org.hibernate.dialect.Dialect;
specialinvoke v.<java.lang.Object: void <init>()>();
v = virtualinvoke v.<org.hibernate.dialect.Dialect: boolean supportsSkipLocked()>();
if v == 0 goto label;
v = new org.hibernate.LockOptions;
v = <org.hibernate.LockMode: org.hibernate.LockMode UPGRADE_SKIPLOCKED>;
specialinvoke v.<org.hibernate.LockOptions: void <init>(org.hibernate.LockMode)>(v);
v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventLoader: org.hibernate.LockOptions lockOptions> = v;
goto label;
label:
v = new org.hibernate.LockOptions;
v = <org.hibernate.LockMode: org.hibernate.LockMode PESSIMISTIC_WRITE>;
specialinvoke v.<org.hibernate.LockOptions: void <init>(org.hibernate.LockMode)>(v);
v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventLoader: org.hibernate.LockOptions lockOptions> = v;
label:
return;
}
public java.lang.String toString()
{
java.lang.String v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventLoader v;
v := @this: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventLoader;
v = virtualinvoke v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventLoader: java.lang.String toStringTree()>();
return v;
}
public void appendTo(org.hibernate.search.util.common.spi.ToStringTreeAppender)
{
org.hibernate.LockMode v;
org.hibernate.LockOptions v, v;
org.hibernate.search.util.common.spi.ToStringTreeAppender v, v, v, v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventLoader v;
java.lang.Integer v;
int v;
v := @this: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventLoader;
v := @parameter: org.hibernate.search.util.common.spi.ToStringTreeAppender;
v = interfaceinvoke v.<org.hibernate.search.util.common.spi.ToStringTreeAppender: org.hibernate.search.util.common.spi.ToStringTreeAppender startObject(java.lang.String)>("lockOptions");
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventLoader: org.hibernate.LockOptions lockOptions>;
v = virtualinvoke v.<org.hibernate.LockOptions: org.hibernate.LockMode getLockMode()>();
v = interfaceinvoke v.<org.hibernate.search.util.common.spi.ToStringTreeAppender: org.hibernate.search.util.common.spi.ToStringTreeAppender attribute(java.lang.String,java.lang.Object)>("lockMode", v);
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventLoader: org.hibernate.LockOptions lockOptions>;
v = virtualinvoke v.<org.hibernate.LockOptions: int getTimeOut()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<org.hibernate.search.util.common.spi.ToStringTreeAppender: org.hibernate.search.util.common.spi.ToStringTreeAppender attribute(java.lang.String,java.lang.Object)>("timeout", v);
interfaceinvoke v.<org.hibernate.search.util.common.spi.ToStringTreeAppender: org.hibernate.search.util.common.spi.ToStringTreeAppender endObject()>();
return;
}
java.util.List loadLocking(org.hibernate.Session, java.util.Set, java.lang.String)
{
java.lang.Throwable v;
org.hibernate.search.mapper.orm.outboxpolling.logging.impl.Log v;
org.hibernate.LockOptions v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventLoader v;
java.util.Set v;
org.hibernate.Session v;
java.util.List v, v;
org.hibernate.query.Query v;
java.lang.String v, v;
v := @this: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventLoader;
v := @parameter: org.hibernate.Session;
v := @parameter: java.util.Set;
v := @parameter: java.lang.String;
label:
v = <org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventLoader: java.lang.String LOAD_QUERY_STRING>;
v = interfaceinvoke v.<org.hibernate.Session: org.hibernate.query.Query createQuery(java.lang.String,java.lang.Class)>(v, class "Lorg/hibernate/search/mapper/orm/outboxpolling/event/impl/OutboxEvent;");
interfaceinvoke v.<org.hibernate.query.Query: org.hibernate.query.Query setParameter(java.lang.String,java.lang.Object)>("ids", v);
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventLoader: org.hibernate.LockOptions lockOptions>;
interfaceinvoke v.<org.hibernate.query.Query: org.hibernate.query.Query setLockOptions(org.hibernate.LockOptions)>(v);
v = interfaceinvoke v.<org.hibernate.query.Query: java.util.List getResultList()>();
label:
return v;
label:
v := @caughtexception;
v = <org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventLoader: org.hibernate.search.mapper.orm.outboxpolling.logging.impl.Log log>;
interfaceinvoke v.<org.hibernate.search.mapper.orm.outboxpolling.logging.impl.Log: void outboxEventProcessorUnableToLock(java.lang.String,jakarta.persistence.PersistenceException)>(v, v);
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
return v;
catch jakarta.persistence.PessimisticLockException from label to label with label;
catch jakarta.persistence.OptimisticLockException from label to label with label;
}
static void <clinit>()
{
java.lang.invoke.MethodHandles$Lookup v;
java.lang.Object v;
java.lang.String v, v;
v = <org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingOutboxEventAdditionalJaxbMappingProducer: java.lang.String ENTITY_NAME>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("select e from \u e where e.id in (:ids)");
<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventLoader: java.lang.String LOAD_QUERY_STRING> = v;
v = staticinvoke <java.lang.invoke.MethodHandles: java.lang.invoke.MethodHandles$Lookup lookup()>();
v = staticinvoke <org.hibernate.search.util.common.logging.impl.LoggerFactory: java.lang.Object make(java.lang.Class,java.lang.invoke.MethodHandles$Lookup)>(class "Lorg/hibernate/search/mapper/orm/outboxpolling/logging/impl/Log;", v);
<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventLoader: org.hibernate.search.mapper.orm.outboxpolling.logging.impl.Log log> = v;
return;
}
public java.lang.String toStringTree()
{
java.lang.Error $r;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventLoader this;
this := @this: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventLoader;
$r = new java.lang.Error;
specialinvoke $r.<java.lang.Error: void <init>(java.lang.String)>("Unresolved compilation error: Method <org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventLoader: java.lang.String toStringTree()> does not exist!");
throw $r;
}
}