logging has been changed.
This commit is contained in:
@@ -3,16 +3,13 @@ package subscribe
|
||||
import (
|
||||
"context"
|
||||
|
||||
"git.loafle.net/commons_go/logging"
|
||||
"git.loafle.net/overflow/overflow_gateway_web/server"
|
||||
ofs "git.loafle.net/overflow/overflow_subscriber"
|
||||
"go.uber.org/zap"
|
||||
)
|
||||
|
||||
func newWebSubscriberHandler(ctx context.Context, channel string) ofs.SubscriberHandler {
|
||||
h := &webSubscriberHandlers{
|
||||
ctx: ctx,
|
||||
logger: logging.WithContext(ctx),
|
||||
ctx: ctx,
|
||||
}
|
||||
h.Channel = channel
|
||||
|
||||
@@ -21,8 +18,7 @@ func newWebSubscriberHandler(ctx context.Context, channel string) ofs.Subscriber
|
||||
|
||||
type webSubscriberHandlers struct {
|
||||
ofs.SubscriberHandlers
|
||||
ctx context.Context
|
||||
logger *zap.Logger
|
||||
ctx context.Context
|
||||
}
|
||||
|
||||
func (h *webSubscriberHandlers) OnSubscribe(payload string) {
|
||||
|
||||
Reference in New Issue
Block a user