Refactor hanler

core-go · Jul 21, 2024 · 86751c6 · 86751c6
1 parent 1153c1c
commit 86751c6
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 3 deletions.
diff --git a/go.mod b/go.mod
@@ -0,0 +1,3 @@
+module github.com/core-go/mq
+
+go 1.18
diff --git a/go.sum b/go.sum
diff --git a/handler.go b/handler.go
@@ -30,16 +30,16 @@ func NewHandlerByConfig[T any](c HandlerConfig,
 	validate func(context.Context, *T) ([]ErrorMessage, error),
 	reject func(context.Context, *T, []ErrorMessage, []byte),
 	handleError func(context.Context, []byte),
-	goroutines bool, key string, logs ...func(context.Context, string)) *Handler[T] {
-	return NewHandlerByConfigAndUnmarshal[T](c, nil, write, validate, reject, handleError, goroutines, key, logs...)
+	logs ...func(context.Context, string)) *Handler[T] {
+	return NewHandlerByConfigAndUnmarshal[T](c, nil, write, validate, reject, handleError, logs...)
 }
 func NewHandlerByConfigAndUnmarshal[T any](c HandlerConfig,
 	unmarshal func(data []byte, v any) error,
 	write func(context.Context, *T) error,
 	validate func(context.Context, *T) ([]ErrorMessage, error),
 	reject func(context.Context, *T, []ErrorMessage, []byte),
 	handleError func(context.Context, []byte),
-	goroutines bool, key string, logs ...func(context.Context, string)) *Handler[T] {
+	logs ...func(context.Context, string)) *Handler[T] {
 	if c.Retry == nil {
 		return NewHandlerWithKey[T](unmarshal, write, validate, reject, handleError, nil, c.Goroutines, c.Key, logs...)
 	} else {