summaryrefslogtreecommitdiff
path: root/plugins/broadcast/plugin.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-09-11 01:04:05 +0300
committerValery Piashchynski <[email protected]>2021-09-11 01:04:05 +0300
commit0c4dd160a3eec4d76b9b82799c55eea4c5f50629 (patch)
treeabc3eef044d6da54e1ba118637564e4d911e0fa6 /plugins/broadcast/plugin.go
parent6984e25ecdfc113400007c45fd69822f09b46ff0 (diff)
Update .vscode settings
Update codecov Update configs Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins/broadcast/plugin.go')
-rw-r--r--plugins/broadcast/plugin.go6
1 files changed, 4 insertions, 2 deletions
diff --git a/plugins/broadcast/plugin.go b/plugins/broadcast/plugin.go
index 47b68fe7..40263eaa 100644
--- a/plugins/broadcast/plugin.go
+++ b/plugins/broadcast/plugin.go
@@ -53,7 +53,7 @@ func (p *Plugin) Init(cfg config.Configurer, log logger.Logger) error {
}
func (p *Plugin) Serve() chan error {
- return make(chan error)
+ return make(chan error, 1)
}
func (p *Plugin) Stop() error {
@@ -158,7 +158,7 @@ func (p *Plugin) GetDriver(key string) (pubsub.SubReader, error) {
p.publishers[configKey] = ps
return ps, nil
- default:
+ case p.cfgPlugin.Has(key):
// try global driver section after local
ps, err := p.constructors[drStr].PSConstruct(key)
if err != nil {
@@ -170,6 +170,8 @@ func (p *Plugin) GetDriver(key string) (pubsub.SubReader, error) {
p.publishers[configKey] = ps
return ps, nil
+ default:
+ p.log.Error("can't find local or global configuration, this section will be skipped", "local: ", configKey, "global: ", key)
}
}
}