触发数据
This commit is contained in:
parent
787815b64e
commit
1713387f6d
2
main.go
2
main.go
|
@ -21,7 +21,7 @@ var shardID uint64 = 128
|
||||||
|
|
||||||
// 出队的逻辑注册触发函数, 当
|
// 出队的逻辑注册触发函数, 当
|
||||||
var DequeueHandler = triggered.RegisterExecute(func(params *triggered.Params[bool]) {
|
var DequeueHandler = triggered.RegisterExecute(func(params *triggered.Params[bool]) {
|
||||||
|
log.Println("DequeueHandler 触发数据")
|
||||||
params.Shared.Value(func(v any) {
|
params.Shared.Value(func(v any) {
|
||||||
|
|
||||||
cs := stateClient.GetNoOPSession()
|
cs := stateClient.GetNoOPSession()
|
||||||
|
|
Loading…
Reference in New Issue
Block a user