public final class org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder extends java.lang.Object implements org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventFinder
{
private static final org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventAndPredicate BASE_PREDICATE_FILTER;
private final java.lang.String queryString;
private final java.util.Optional predicate;
private final org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventOrder order;
private void <init>(java.util.Optional, org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventOrder)
{
java.util.Optional v;
java.lang.String v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder v;
java.util.function.Function v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventOrder v;
v := @this: org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder;
v := @parameter: java.util.Optional;
v := @parameter: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventOrder;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder$lambda_new_0__19: java.util.function.Function bootstrap$()>();
v = specialinvoke v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder: java.lang.String createQueryString(java.util.Optional,java.util.function.Function,org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventOrder)>(v, v, v);
v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder: java.lang.String queryString> = v;
v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder: java.util.Optional predicate> = v;
v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventOrder order> = v;
return;
}
public java.util.List findOutboxEvents(org.hibernate.Session, int)
{
java.util.List v;
int v;
org.hibernate.query.Query v;
org.hibernate.Session v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder v;
v := @this: org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder;
v := @parameter: org.hibernate.Session;
v := @parameter: int;
v = virtualinvoke v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder: org.hibernate.query.Query createOutboxEventQuery(org.hibernate.Session)>(v);
interfaceinvoke v.<org.hibernate.query.Query: org.hibernate.query.Query setMaxResults(int)>(v);
v = interfaceinvoke v.<org.hibernate.query.Query: java.util.List list()>();
return v;
}
public org.hibernate.query.Query createOutboxEventQuery(org.hibernate.Session)
{
org.hibernate.Session v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder v;
org.hibernate.query.Query v;
java.util.Optional v, v;
java.lang.Object v;
java.lang.String v;
boolean v;
v := @this: org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder;
v := @parameter: org.hibernate.Session;
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder: java.lang.String queryString>;
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;");
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder: java.util.Optional predicate>;
v = virtualinvoke v.<java.util.Optional: boolean isPresent()>();
if v == 0 goto label;
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder: java.util.Optional predicate>;
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
interfaceinvoke v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventPredicate: void setParams(org.hibernate.query.Query)>(v);
label:
return v;
}
public org.hibernate.query.Query createOutboxEventQueryForTests(org.hibernate.Session, java.util.function.Function, java.lang.Class, org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventOrder)
{
org.hibernate.Session v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder v;
java.util.function.Function v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventOrder v, v;
org.hibernate.query.Query v;
java.util.Optional v, v, v;
java.lang.Class v;
java.lang.Object v;
java.lang.String v;
boolean v;
v := @this: org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder;
v := @parameter: org.hibernate.Session;
v := @parameter: java.util.function.Function;
v := @parameter: java.lang.Class;
v := @parameter: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventOrder;
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder: java.util.Optional predicate>;
if v == null goto label;
v = v;
goto label;
label:
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventOrder order>;
label:
v = specialinvoke v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder: java.lang.String createQueryString(java.util.Optional,java.util.function.Function,org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventOrder)>(v, v, v);
v = interfaceinvoke v.<org.hibernate.Session: org.hibernate.query.Query createQuery(java.lang.String,java.lang.Class)>(v, v);
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder: java.util.Optional predicate>;
v = virtualinvoke v.<java.util.Optional: boolean isPresent()>();
if v == 0 goto label;
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder: java.util.Optional predicate>;
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
interfaceinvoke v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventPredicate: void setParams(org.hibernate.query.Query)>(v);
label:
return v;
}
private java.lang.String createQueryString(java.util.Optional, java.util.function.Function, org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventOrder)
{
org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder v;
java.util.function.Function v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventOrder v;
java.util.Optional v;
java.lang.Object v, v;
java.lang.String v, v, v, v, v;
boolean v;
v := @this: org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder;
v := @parameter: java.util.Optional;
v := @parameter: java.util.function.Function;
v := @parameter: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventOrder;
v = interfaceinvoke v.<java.util.function.Function: java.lang.Object apply(java.lang.Object)>("e");
v = <org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingOutboxEventAdditionalJaxbMappingProducer: java.lang.String ENTITY_NAME>;
v = virtualinvoke v.<java.util.Optional: boolean isPresent()>();
if v == 0 goto label;
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = interfaceinvoke v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventPredicate: java.lang.String queryPart(java.lang.String)>("e");
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[])>(" where \u0001");
goto label;
label:
v = "";
label:
v = virtualinvoke v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventOrder: java.lang.String queryPart(java.lang.String)>("e");
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, 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 \u from \u e \u0001\u0001");
return v;
}
static void <clinit>()
{
org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder$ProcessAfterFilter v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder$ProcessPendingFilter v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventAndPredicate v;
v = new org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder$ProcessAfterFilter;
specialinvoke v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder$ProcessAfterFilter: void <init>()>();
v = new org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder$ProcessPendingFilter;
specialinvoke v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder$ProcessPendingFilter: void <init>()>();
v = staticinvoke <org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventAndPredicate: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventAndPredicate of(org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventPredicate,org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventPredicate)>(v, v);
<org.hibernate.search.mapper.orm.outboxpolling.event.impl.DefaultOutboxEventFinder: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxEventAndPredicate BASE_PREDICATE_FILTER> = v;
return;
}
}