diff --git a/pubsub/pubsub.go b/pubsub/pubsub.go index a8911d4..1277cfa 100644 --- a/pubsub/pubsub.go +++ b/pubsub/pubsub.go @@ -96,7 +96,7 @@ func (p *PubSub) routingUpdates(ctx context.Context, sub chan *events.Event) { go func() { for hu := range routingUpdates { p.logger.Debug("receive htlcUpdate") - if !(*hu).IsEmpty() { + if (*hu).OutgoingChannelId != 0 { sub <- events.NewWithData(events.RoutingEventUpdated, hu) } }