org.beetl.sql.saga.kafka

类 SagaLevel3Context

java.lang.Object

org.beetl.sql.saga.common.SagaContext

org.beetl.sql.saga.kafka.SagaLevel3Context

public class SagaLevel3Context
extends org.beetl.sql.saga.common.SagaContext

回滚事务，如果没有完全成功，则发送到kafka队列，在尝试多次后，仍然没有成功，发送给

作者:

xiandafu

另请参阅:

SagaLevel3Config

字段概要

从类继承的字段 org.beetl.sql.saga.common.SagaContext

businessKey, gid, sagaContextFactory, time

构造器概要

构造器

构造器和说明
SagaLevel3Context(SagaLevel3Config config)
SagaLevel3Context(SagaLevel3Transaction transaction, SagaLevel3Config config)

方法概要

限定符和类型	方法和说明
<T> T	callService(Callable<T> callable, Runnable runnable) 非sql类的，比如批量增加数据，逆向操作可能只是简单的删除外键，而不需要每条都删除
protected void	clear()
void	commit()
org.beetl.sql.saga.common.SagaTransaction	getTransaction()
protected void	newTransaction()
boolean	realRollback() 真正的本地回滚
void	rollback()
void	start()
void	start(String gid)

从类继承的方法 org.beetl.sql.saga.common.SagaContext

setGid

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

SagaLevel3Context

public SagaLevel3Context(SagaLevel3Config config)

SagaLevel3Context

public SagaLevel3Context(SagaLevel3Transaction transaction,
                         SagaLevel3Config config)

方法详细资料

start

public void start()

覆盖:

start 在类中 org.beetl.sql.saga.common.SagaContext

start

public void start(String gid)

覆盖:

start 在类中 org.beetl.sql.saga.common.SagaContext

commit

public void commit()

覆盖:

commit 在类中 org.beetl.sql.saga.common.SagaContext

rollback

public void rollback()

指定者:

rollback 在类中 org.beetl.sql.saga.common.SagaContext

realRollback

public boolean realRollback()

真正的本地回滚

getTransaction

public org.beetl.sql.saga.common.SagaTransaction getTransaction()

指定者:

getTransaction 在类中 org.beetl.sql.saga.common.SagaContext

newTransaction

protected void newTransaction()

clear

protected void clear()

callService

public <T> T callService(Callable<T> callable,
                         Runnable runnable)
                  throws Exception

非sql类的，比如批量增加数据，逆向操作可能只是简单的删除外键，而不需要每条都删除

指定者:

callService 在类中 org.beetl.sql.saga.common.SagaContext

类型参数:

T -

参数:

callable -

runnable - ，必须保证可被json序列化和反序列化，比如，提供一个空的构造函数

返回:

抛出:

Exception