public class org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext extends java.lang.Object
{
private final org.hibernate.search.mapper.orm.common.spi.TransactionHelper transactionHelper;
private final org.hibernate.search.mapper.orm.common.spi.SessionHelper sessionHelper;
private final org.hibernate.search.mapper.orm.outboxpolling.cluster.impl.AgentRepositoryProvider agentRepositoryProvider;
private org.hibernate.engine.spi.SessionImplementor session;
private org.hibernate.search.mapper.orm.outboxpolling.cluster.impl.AgentRepository agentRepository;
public 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)
{
org.hibernate.search.mapper.orm.common.spi.TransactionHelper v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext v;
org.hibernate.search.mapper.orm.common.spi.SessionHelper v;
org.hibernate.search.mapper.orm.outboxpolling.cluster.impl.AgentRepositoryProvider v;
v := @this: org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext;
v := @parameter: org.hibernate.search.mapper.orm.common.spi.TransactionHelper;
v := @parameter: org.hibernate.search.mapper.orm.common.spi.SessionHelper;
v := @parameter: org.hibernate.search.mapper.orm.outboxpolling.cluster.impl.AgentRepositoryProvider;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext: org.hibernate.search.mapper.orm.common.spi.TransactionHelper transactionHelper> = v;
v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext: org.hibernate.search.mapper.orm.common.spi.SessionHelper sessionHelper> = v;
v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext: org.hibernate.search.mapper.orm.outboxpolling.cluster.impl.AgentRepositoryProvider agentRepositoryProvider> = v;
return;
}
void begin()
{
org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext v;
org.hibernate.search.mapper.orm.common.spi.SessionHelper v;
org.hibernate.search.mapper.orm.common.spi.TransactionHelper v;
org.hibernate.search.mapper.orm.outboxpolling.cluster.impl.AgentRepository v;
org.hibernate.search.mapper.orm.outboxpolling.cluster.impl.AgentRepositoryProvider v;
org.hibernate.engine.spi.SessionImplementor v, v, v;
v := @this: org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext;
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext: org.hibernate.search.mapper.orm.common.spi.SessionHelper sessionHelper>;
v = virtualinvoke v.<org.hibernate.search.mapper.orm.common.spi.SessionHelper: org.hibernate.engine.spi.SessionImplementor openSession()>();
v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext: org.hibernate.engine.spi.SessionImplementor session> = v;
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext: org.hibernate.search.mapper.orm.common.spi.TransactionHelper transactionHelper>;
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext: org.hibernate.engine.spi.SessionImplementor session>;
virtualinvoke v.<org.hibernate.search.mapper.orm.common.spi.TransactionHelper: void begin(org.hibernate.engine.spi.SharedSessionContractImplementor)>(v);
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext: org.hibernate.search.mapper.orm.outboxpolling.cluster.impl.AgentRepositoryProvider agentRepositoryProvider>;
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext: org.hibernate.engine.spi.SessionImplementor session>;
v = interfaceinvoke v.<org.hibernate.search.mapper.orm.outboxpolling.cluster.impl.AgentRepositoryProvider: org.hibernate.search.mapper.orm.outboxpolling.cluster.impl.AgentRepository create(org.hibernate.Session)>(v);
v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext: org.hibernate.search.mapper.orm.outboxpolling.cluster.impl.AgentRepository agentRepository> = v;
return;
}
public org.hibernate.search.mapper.orm.outboxpolling.cluster.impl.AgentRepository agentRepository()
{
org.hibernate.search.mapper.orm.outboxpolling.cluster.impl.AgentRepository v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext v;
v := @this: org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext;
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext: org.hibernate.search.mapper.orm.outboxpolling.cluster.impl.AgentRepository agentRepository>;
return v;
}
public void commitAndBeginNewTransaction()
{
org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext v;
v := @this: org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext;
virtualinvoke v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext: void commit()>();
virtualinvoke v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext: void begin()>();
return;
}
void commit()
{
java.lang.Throwable v;
org.hibernate.search.util.common.spi.ClosingOperator v, v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext v;
org.hibernate.search.mapper.orm.common.spi.TransactionHelper v;
org.hibernate.engine.spi.SessionImplementor v, v;
org.hibernate.search.util.common.impl.Closer v;
v := @this: org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext;
v = new org.hibernate.search.util.common.impl.Closer;
specialinvoke v.<org.hibernate.search.util.common.impl.Closer: void <init>()>();
label:
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext: org.hibernate.search.mapper.orm.common.spi.TransactionHelper transactionHelper>;
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext$commit__14: org.hibernate.search.util.common.spi.ClosingOperator bootstrap$(org.hibernate.search.mapper.orm.common.spi.TransactionHelper)>(v);
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext: org.hibernate.engine.spi.SessionImplementor session>;
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.AgentClusterLinkContext$close__15: org.hibernate.search.util.common.spi.ClosingOperator bootstrap$()>();
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext: org.hibernate.engine.spi.SessionImplementor session>;
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.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext: org.hibernate.engine.spi.SessionImplementor session> = null;
v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext: org.hibernate.search.mapper.orm.outboxpolling.cluster.impl.AgentRepository agentRepository> = null;
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;
}
void rollbackLatestTransactionSafely(java.lang.Throwable)
{
java.lang.Throwable v;
org.hibernate.search.util.common.spi.ClosingOperator v, v;
org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext v;
org.hibernate.search.util.common.impl.SuppressingCloser v;
java.lang.Object v;
org.hibernate.engine.spi.SessionImplementor v, v;
v := @this: org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext;
v := @parameter: java.lang.Throwable;
v = new org.hibernate.search.util.common.impl.SuppressingCloser;
specialinvoke v.<org.hibernate.search.util.common.impl.SuppressingCloser: void <init>(java.lang.Throwable)>(v);
v = staticinvoke <org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext$lambda_rollbackLatestTransactionSafely_0__16: org.hibernate.search.util.common.spi.ClosingOperator bootstrap$(org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext,java.lang.Throwable)>(v, v);
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext: org.hibernate.engine.spi.SessionImplementor session>;
v = virtualinvoke v.<org.hibernate.search.util.common.impl.SuppressingCloser: 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.AgentClusterLinkContext$close__17: org.hibernate.search.util.common.spi.ClosingOperator bootstrap$()>();
v = v.<org.hibernate.search.mapper.orm.outboxpolling.event.impl.AgentClusterLinkContext: org.hibernate.engine.spi.SessionImplementor session>;
virtualinvoke v.<org.hibernate.search.util.common.impl.SuppressingCloser: java.lang.Object push(org.hibernate.search.util.common.spi.ClosingOperator,java.lang.Object)>(v, v);
return;
}
}