We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 8ef3c45 commit 5773b42Copy full SHA for 5773b42
internal/file/file_plugin.go
@@ -66,7 +66,7 @@ func (fp *FilePlugin) Info() *bus.Info {
66
67
// nolint: cyclop, revive
68
func (fp *FilePlugin) Process(ctx context.Context, msg *bus.Message) {
69
- if logger.ServerType(ctx) == model.Command.String() || logger.ServerType(ctx) == "" {
+ if logger.ServerType(ctx) == fp.serverType.String() || logger.ServerType(ctx) == "" {
70
switch msg.Topic {
71
case bus.ConnectionResetTopic:
72
fp.handleConnectionReset(ctx, msg)
0 commit comments