public final class org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent extends java.lang.Object implements org.hibernate.search.mapper.pojo.massindexing.spi.PojoMassIndexerAgent, org.hibernate.search.util.common.spi.ToStringTreeAppendable
{
private static final org.hibernate.search.mapper.orm.outboxpolling.logging.impl.Log log;
private static final org.hibernate.search.engine.cfg.spi.ConfigurationProperty POLLING_INTERVAL;
private static final org.hibernate.search.engine.cfg.spi.ConfigurationProperty PULSE_INTERVAL;
private static final org.hibernate.search.engine.cfg.spi.ConfigurationProperty PULSE_EXPIRATION;
private final java.lang.String name;
private final long pollingInterval;
private final java.util.concurrent.atomic.AtomicReference status;
private final org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgentClusterLink clusterLink;
private final org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContextProvider clusterLinkContextProvider;
private final org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Worker worker;
private org.hibernate.search.engine.backend.orchestration.spi.SingletonTask processingTask;
private static java.lang.String name(java.lang.String)
{
java.lang.StringBuilder v, v, v;
java.lang.String v, v;
v := @parameter: java.lang.String;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>(java.lang.String)>("Mass indexer agent");
if v == null goto label;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(" - Tenant <");
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(">");
label:
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
public static org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Factory factory(org.hibernate.search.mapper.orm.automaticindexing.spi.AutomaticIndexingMappingContext, java.time.Clock, java.lang.String, org.hibernate.search.engine.cfg.ConfigurationPropertySource)
{
org.hibernate.search.engine.cfg.ConfigurationPropertySource v;
org.hibernate.search.engine.cfg.spi.ConfigurationProperty v, v, v;
org.hibernate.search.mapper.orm.automaticindexing.spi.AutomaticIndexingMappingContext v;
java.util.function.Function v, v, v;
java.time.Clock v;
java.lang.Object v, v, v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Factory v;
java.lang.String v;
v := @parameter: org.hibernate.search.mapper.orm.automaticindexing.spi.AutomaticIndexingMappingContext;
v := @parameter: java.time.Clock;
v := @parameter: java.lang.String;
v := @parameter: org.hibernate.search.engine.cfg.ConfigurationPropertySource;
v = <org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: org.hibernate.search.engine.cfg.spi.ConfigurationProperty POLLING_INTERVAL>;
v = staticinvoke <org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$ofMillis__42: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<org.hibernate.search.engine.cfg.spi.ConfigurationProperty: java.lang.Object getAndTransform(org.hibernate.search.engine.cfg.ConfigurationPropertySource,java.util.function.Function)>(v, v);
v = <org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: org.hibernate.search.engine.cfg.spi.ConfigurationProperty PULSE_INTERVAL>;
v = staticinvoke <org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$lambda_factory_0__43: java.util.function.Function bootstrap$(java.time.Duration)>(v);
v = interfaceinvoke v.<org.hibernate.search.engine.cfg.spi.ConfigurationProperty: java.lang.Object getAndTransform(org.hibernate.search.engine.cfg.ConfigurationPropertySource,java.util.function.Function)>(v, v);
v = <org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: org.hibernate.search.engine.cfg.spi.ConfigurationProperty PULSE_EXPIRATION>;
v = staticinvoke <org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$lambda_factory_1__44: java.util.function.Function bootstrap$(java.time.Duration)>(v);
v = interfaceinvoke v.<org.hibernate.search.engine.cfg.spi.ConfigurationProperty: java.lang.Object getAndTransform(org.hibernate.search.engine.cfg.ConfigurationPropertySource,java.util.function.Function)>(v, v);
v = new org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Factory;
specialinvoke v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Factory: void <init>(org.hibernate.search.mapper.orm.automaticindexing.spi.AutomaticIndexingMappingContext,java.time.Clock,java.lang.String,java.time.Duration,java.time.Duration,java.time.Duration)>(v, v, v, v, v, v);
return v;
}
private void <init>(java.lang.String, org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Factory, org.hibernate.search.mapper.orm.outboxpolling.cluster.impl.AgentRepositoryProvider, org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgentClusterLink)
{
org.hibernate.search.mapper.orm.common.spi.SessionHelper v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgentClusterLink v;
long v;
java.util.concurrent.atomic.AtomicReference v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Status v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent v;
java.time.Duration v;
java.lang.String v, v;
org.hibernate.search.mapper.orm.tenancy.spi.TenancyConfiguration v;
org.hibernate.engine.spi.SessionFactoryImplementor v, v;
org.hibernate.search.mapper.orm.automaticindexing.spi.AutomaticIndexingMappingContext v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContextProvider v;
org.hibernate.search.mapper.orm.common.spi.TransactionHelper v;
org.hibernate.search.mapper.orm.outboxpolling.cluster.impl.AgentRepositoryProvider v;
java.lang.Object v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Factory v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Worker v;
v := @this: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent;
v := @parameter: java.lang.String;
v := @parameter: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Factory;
v := @parameter: org.hibernate.search.mapper.orm.outboxpolling.cluster.impl.AgentRepositoryProvider;
v := @parameter: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgentClusterLink;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.concurrent.atomic.AtomicReference;
v = <org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Status: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Status STOPPED>;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>(java.lang.Object)>(v);
v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: java.util.concurrent.atomic.AtomicReference status> = v;
v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: java.lang.String name> = v;
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Factory: org.hibernate.search.mapper.orm.automaticindexing.spi.AutomaticIndexingMappingContext mapping>;
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Factory: java.time.Duration pollingInterval>;
v = virtualinvoke v.<java.time.Duration: long toMillis()>();
v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: long pollingInterval> = v;
v = interfaceinvoke v.<org.hibernate.search.mapper.orm.automaticindexing.spi.AutomaticIndexingMappingContext: org.hibernate.search.mapper.orm.tenancy.spi.TenancyConfiguration tenancyConfiguration()>();
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Factory: java.lang.String tenantId>;
v = virtualinvoke v.<org.hibernate.search.mapper.orm.tenancy.spi.TenancyConfiguration: java.lang.Object convert(java.lang.String)>(v);
v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgentClusterLink clusterLink> = v;
v = new org.hibernate.search.mapper.orm.common.spi.TransactionHelper;
v = interfaceinvoke v.<org.hibernate.search.mapper.orm.automaticindexing.spi.AutomaticIndexingMappingContext: org.hibernate.engine.spi.SessionFactoryImplementor sessionFactory()>();
specialinvoke v.<org.hibernate.search.mapper.orm.common.spi.TransactionHelper: void <init>(org.hibernate.engine.spi.SessionFactoryImplementor,java.lang.Integer)>(v, null);
v = new org.hibernate.search.mapper.orm.common.spi.SessionHelper;
v = interfaceinvoke v.<org.hibernate.search.mapper.orm.automaticindexing.spi.AutomaticIndexingMappingContext: org.hibernate.engine.spi.SessionFactoryImplementor sessionFactory()>();
specialinvoke v.<org.hibernate.search.mapper.orm.common.spi.SessionHelper: void <init>(org.hibernate.engine.spi.SessionFactoryImplementor,java.lang.Object)>(v, v);
v = new org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContextProvider;
specialinvoke v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContextProvider: void <init>(org.hibernate.search.mapper.orm.common.spi.TransactionHelper,org.hibernate.search.mapper.orm.common.spi.SessionHelper,org.hibernate.search.mapper.orm.outboxpolling.cluster.impl.AgentRepositoryProvider)>(v, v, v);
v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContextProvider clusterLinkContextProvider> = v;
v = new org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Worker;
specialinvoke v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Worker: void <init>(org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent)>(v);
v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Worker worker> = v;
return;
}
public java.lang.String toString()
{
java.lang.String v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent v;
v := @this: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent;
v = virtualinvoke v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: java.lang.String toStringTree()>();
return v;
}
public void appendTo(org.hibernate.search.util.common.spi.ToStringTreeAppender)
{
org.hibernate.search.util.common.spi.ToStringTreeAppender v, v, v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgentClusterLink v;
long v;
java.lang.Long v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent v;
java.lang.String v;
v := @this: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent;
v := @parameter: org.hibernate.search.util.common.spi.ToStringTreeAppender;
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: java.lang.String name>;
v = interfaceinvoke v.<org.hibernate.search.util.common.spi.ToStringTreeAppender: org.hibernate.search.util.common.spi.ToStringTreeAppender attribute(java.lang.String,java.lang.Object)>("name", v);
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: long pollingInterval>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(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)>("pollingInterval", v);
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgentClusterLink clusterLink>;
interfaceinvoke v.<org.hibernate.search.util.common.spi.ToStringTreeAppender: org.hibernate.search.util.common.spi.ToStringTreeAppender attribute(java.lang.String,java.lang.Object)>("clusterLink", v);
return;
}
public java.util.concurrent.CompletableFuture start(org.hibernate.search.mapper.pojo.massindexing.spi.PojoMassIndexerAgentStartContext)
{
org.hibernate.search.engine.backend.orchestration.spi.SingletonTask v, v;
org.hibernate.search.mapper.orm.outboxpolling.logging.impl.Log v;
org.hibernate.search.engine.reporting.FailureHandler v;
java.util.concurrent.CompletableFuture v;
org.hibernate.search.mapper.pojo.massindexing.spi.PojoMassIndexerAgentStartContext v;
java.util.concurrent.atomic.AtomicReference v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Scheduler v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Status v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent v;
java.util.concurrent.ScheduledExecutorService v;
java.lang.String v, v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Worker v, v;
v := @this: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent;
v := @parameter: org.hibernate.search.mapper.pojo.massindexing.spi.PojoMassIndexerAgentStartContext;
v = <org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: org.hibernate.search.mapper.orm.outboxpolling.logging.impl.Log log>;
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: java.lang.String name>;
interfaceinvoke v.<org.hibernate.search.mapper.orm.outboxpolling.logging.impl.Log: void startingOutboxMassIndexerAgent(java.lang.String,org.hibernate.search.util.common.spi.ToStringTreeAppendable)>(v, v);
v = new org.hibernate.search.engine.backend.orchestration.spi.SingletonTask;
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: java.lang.String name>;
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Worker worker>;
v = new org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Scheduler;
v = interfaceinvoke v.<org.hibernate.search.mapper.pojo.massindexing.spi.PojoMassIndexerAgentStartContext: java.util.concurrent.ScheduledExecutorService scheduledExecutor()>();
specialinvoke v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Scheduler: void <init>(org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent,java.util.concurrent.ScheduledExecutorService)>(v, v);
v = interfaceinvoke v.<org.hibernate.search.mapper.pojo.massindexing.spi.PojoMassIndexerAgentStartContext: org.hibernate.search.engine.reporting.FailureHandler failureHandler()>();
specialinvoke v.<org.hibernate.search.engine.backend.orchestration.spi.SingletonTask: void <init>(java.lang.String,org.hibernate.search.engine.backend.orchestration.spi.SingletonTask$Worker,org.hibernate.search.engine.backend.orchestration.spi.SingletonTask$Scheduler,org.hibernate.search.engine.reporting.FailureHandler)>(v, v, v, v);
v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: org.hibernate.search.engine.backend.orchestration.spi.SingletonTask processingTask> = v;
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: java.util.concurrent.atomic.AtomicReference status>;
v = <org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Status: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Status STARTED>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: org.hibernate.search.engine.backend.orchestration.spi.SingletonTask processingTask>;
virtualinvoke v.<org.hibernate.search.engine.backend.orchestration.spi.SingletonTask: void ensureScheduled()>();
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Worker worker>;
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Worker: java.util.concurrent.CompletableFuture agentFullyStartedFuture>;
return v;
}
public java.util.concurrent.CompletableFuture preStop()
{
org.hibernate.search.engine.backend.orchestration.spi.SingletonTask v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Status v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent v;
java.util.concurrent.CompletableFuture v;
java.util.concurrent.atomic.AtomicReference v;
v := @this: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent;
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: java.util.concurrent.atomic.AtomicReference status>;
v = <org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Status: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$Status STOPPED>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: org.hibernate.search.engine.backend.orchestration.spi.SingletonTask processingTask>;
v = virtualinvoke v.<org.hibernate.search.engine.backend.orchestration.spi.SingletonTask: java.util.concurrent.CompletableFuture completion()>();
return v;
}
public void stop()
{
java.lang.Throwable v;
org.hibernate.search.engine.backend.orchestration.spi.SingletonTask v;
org.hibernate.search.util.common.spi.ClosingOperator v, v;
org.hibernate.search.mapper.orm.outboxpolling.logging.impl.Log v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent v;
java.lang.String v;
org.hibernate.search.util.common.impl.Closer v;
v := @this: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent;
v = <org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: org.hibernate.search.mapper.orm.outboxpolling.logging.impl.Log log>;
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: java.lang.String name>;
interfaceinvoke v.<org.hibernate.search.mapper.orm.outboxpolling.logging.impl.Log: void stoppingOutboxMassIndexerAgent(java.lang.String)>(v);
v = new org.hibernate.search.util.common.impl.Closer;
specialinvoke v.<org.hibernate.search.util.common.impl.Closer: void <init>()>();
label:
v = staticinvoke <org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$stop__45: org.hibernate.search.util.common.spi.ClosingOperator bootstrap$()>();
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: org.hibernate.search.engine.backend.orchestration.spi.SingletonTask processingTask>;
virtualinvoke v.<org.hibernate.search.util.common.impl.Closer: java.lang.Object push(org.hibernate.search.util.common.spi.ClosingOperator,java.lang.Object)>(v, v);
v = staticinvoke <org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$leaveCluster__46: org.hibernate.search.util.common.spi.ClosingOperator bootstrap$()>();
virtualinvoke v.<org.hibernate.search.util.common.impl.Closer: java.lang.Object push(org.hibernate.search.util.common.spi.ClosingOperator,java.lang.Object)>(v, v);
label:
virtualinvoke v.<org.hibernate.search.util.common.impl.Closer: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void leaveCluster()
{
java.util.function.Consumer v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgentClusterLink v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContextProvider v;
v := @this: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent;
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContextProvider clusterLinkContextProvider>;
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgentClusterLink clusterLink>;
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent$leaveCluster__47: java.util.function.Consumer bootstrap$(org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgentClusterLink)>(v);
virtualinvoke v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContextProvider: void inTransaction(java.util.function.Consumer)>(v);
return;
}
static void <clinit>()
{
java.lang.Integer v, v, v;
java.lang.invoke.MethodHandles$Lookup v;
org.hibernate.search.engine.cfg.spi.OptionalPropertyContext v, v, v;
org.hibernate.search.engine.cfg.spi.ConfigurationProperty v, v, v;
org.hibernate.search.engine.cfg.spi.KeyContext v, v, v;
org.hibernate.search.engine.cfg.spi.DefaultedPropertyContext v, v, v;
java.lang.Object 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.OutboxPollingMassIndexerAgent: org.hibernate.search.mapper.orm.outboxpolling.logging.impl.Log log> = v;
v = staticinvoke <org.hibernate.search.engine.cfg.spi.ConfigurationProperty: org.hibernate.search.engine.cfg.spi.KeyContext forKey(java.lang.String)>("mass_indexer.polling_interval");
v = interfaceinvoke v.<org.hibernate.search.engine.cfg.spi.KeyContext: org.hibernate.search.engine.cfg.spi.OptionalPropertyContext asIntegerStrictlyPositive()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(100);
v = interfaceinvoke v.<org.hibernate.search.engine.cfg.spi.OptionalPropertyContext: org.hibernate.search.engine.cfg.spi.DefaultedPropertyContext withDefault(java.lang.Object)>(v);
v = interfaceinvoke v.<org.hibernate.search.engine.cfg.spi.DefaultedPropertyContext: org.hibernate.search.engine.cfg.spi.ConfigurationProperty build()>();
<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: org.hibernate.search.engine.cfg.spi.ConfigurationProperty POLLING_INTERVAL> = v;
v = staticinvoke <org.hibernate.search.engine.cfg.spi.ConfigurationProperty: org.hibernate.search.engine.cfg.spi.KeyContext forKey(java.lang.String)>("mass_indexer.pulse_interval");
v = interfaceinvoke v.<org.hibernate.search.engine.cfg.spi.KeyContext: org.hibernate.search.engine.cfg.spi.OptionalPropertyContext asIntegerStrictlyPositive()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(2000);
v = interfaceinvoke v.<org.hibernate.search.engine.cfg.spi.OptionalPropertyContext: org.hibernate.search.engine.cfg.spi.DefaultedPropertyContext withDefault(java.lang.Object)>(v);
v = interfaceinvoke v.<org.hibernate.search.engine.cfg.spi.DefaultedPropertyContext: org.hibernate.search.engine.cfg.spi.ConfigurationProperty build()>();
<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: org.hibernate.search.engine.cfg.spi.ConfigurationProperty PULSE_INTERVAL> = v;
v = staticinvoke <org.hibernate.search.engine.cfg.spi.ConfigurationProperty: org.hibernate.search.engine.cfg.spi.KeyContext forKey(java.lang.String)>("mass_indexer.pulse_expiration");
v = interfaceinvoke v.<org.hibernate.search.engine.cfg.spi.KeyContext: org.hibernate.search.engine.cfg.spi.OptionalPropertyContext asIntegerStrictlyPositive()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(30000);
v = interfaceinvoke v.<org.hibernate.search.engine.cfg.spi.OptionalPropertyContext: org.hibernate.search.engine.cfg.spi.DefaultedPropertyContext withDefault(java.lang.Object)>(v);
v = interfaceinvoke v.<org.hibernate.search.engine.cfg.spi.DefaultedPropertyContext: org.hibernate.search.engine.cfg.spi.ConfigurationProperty build()>();
<org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent: org.hibernate.search.engine.cfg.spi.ConfigurationProperty PULSE_EXPIRATION> = v;
return;
}
public java.lang.String toStringTree()
{
java.lang.Error $r;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent this;
this := @this: org.hibernate.search.mapper.orm.outboxpolling.event.impl.OutboxPollingMassIndexerAgent;
$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.OutboxPollingMassIndexerAgent: java.lang.String toStringTree()> does not exist!");
throw $r;
}
}