diff options
| author | Valery Piashchynski <[email protected]> | 2021-05-12 08:49:27 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-05-12 08:49:27 +0300 |
| commit | 8d675100ba4e77909b0dcea7ad60ae4cbbe8ff37 (patch) | |
| tree | 1271381601550d4f4d07364c0d78aad582b978ca /plugins/broadcast/plugin.go | |
| parent | f6ba3c077ccbc572eda26701b9dbacaf9fa453b9 (diff) | |
- Update diagramm
- Remove old code
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins/broadcast/plugin.go')
| -rw-r--r-- | plugins/broadcast/plugin.go | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/plugins/broadcast/plugin.go b/plugins/broadcast/plugin.go index f1ea258e..ec7c2587 100644 --- a/plugins/broadcast/plugin.go +++ b/plugins/broadcast/plugin.go @@ -13,6 +13,7 @@ const ( type Plugin struct { broker Subscriber + driver Storage log logger.Logger cfg *Config @@ -48,17 +49,16 @@ func (p *Plugin) Serve() chan error { // start the underlying broker go func() { - err := p.broker.Serve() - if err != nil { - errCh <- errors.E(op, err) - } + // err := p.broker.Serve() + // if err != nil { + // errCh <- errors.E(op, err) + // } }() return errCh } func (p *Plugin) Stop() error { - return nil } |