AddMessenger adds a Messenger messaging backend to the manager.
(msg Messenger)
| 198 | |
| 199 | // AddMessenger adds a Messenger messaging backend to the manager. |
| 200 | func (m *Manager) AddMessenger(msg Messenger) error { |
| 201 | id := msg.Name() |
| 202 | if _, ok := m.messengers[id]; ok { |
| 203 | return fmt.Errorf("messenger '%s' is already loaded", id) |
| 204 | } |
| 205 | m.messengers[id] = msg |
| 206 | |
| 207 | return nil |
| 208 | } |
| 209 | |
| 210 | // PushMessage pushes an arbitrary non-campaign Message to be sent out by the workers. |
| 211 | // It times out if the queue is busy. |
no test coverage detected