|
@@ -6,6 +6,7 @@ import (
|
|
|
|
|
|
"github.com/go-nunu/nunu-layout-advanced/internal/job"
|
|
|
"github.com/go-nunu/nunu-layout-advanced/pkg/log"
|
|
|
+ "go.uber.org/zap"
|
|
|
)
|
|
|
|
|
|
type JobServer struct {
|
|
@@ -40,7 +41,12 @@ func (j *JobServer) Start(ctx context.Context) error {
|
|
|
// 启动 WhitelistJob 的消费者
|
|
|
j.wg.Add(1)
|
|
|
go func() {
|
|
|
- defer j.wg.Done()
|
|
|
+ defer func() {
|
|
|
+ if r := recover(); r != nil {
|
|
|
+ j.log.Error("whitelistJob consumer panic", zap.Any("error", r))
|
|
|
+ }
|
|
|
+ j.wg.Done()
|
|
|
+ }()
|
|
|
j.whitelistJob.DomainConsumer(ctx)
|
|
|
}()
|
|
|
|