diff --git a/invoices/invoiceregistry.go b/invoices/invoiceregistry.go index 06f592ba..80f4474f 100644 --- a/invoices/invoiceregistry.go +++ b/invoices/invoiceregistry.go @@ -226,13 +226,7 @@ func (i *InvoiceRegistry) dispatchToSingleClients(event *invoiceEvent) { continue } - select { - case client.ntfnQueue.ChanIn() <- &invoiceEvent{ - invoice: event.invoice, - }: - case <-i.quit: - return - } + client.notify(event) } }