diff --git a/api/worker.go b/api/worker.go index 39941e0a..90769b77 100644 --- a/api/worker.go +++ b/api/worker.go @@ -335,7 +335,7 @@ func (w *Worker) GetTransactionFromMempoolTx(mempoolTx *bchain.MempoolTx) (*Tx, if bchainVin.Txid != "" { vin.ValueSat = (*Amount)(&bchainVin.ValueSat) vin.AddrDesc = bchainVin.AddrDesc - vin.Addresses, vin.IsAddress, err = w.chainParser.GetAddressesFromAddrDesc(vin.AddrDesc) + vin.Addresses, vin.IsAddress, _ = w.chainParser.GetAddressesFromAddrDesc(vin.AddrDesc) if vin.ValueSat != nil { valInSat.Add(&valInSat, (*big.Int)(vin.ValueSat)) } diff --git a/bchain/mq.go b/bchain/mq.go index 65596040..8f8e8282 100644 --- a/bchain/mq.go +++ b/bchain/mq.go @@ -89,8 +89,9 @@ func (mq *MQ) run(callback func(NotificationType)) { } repeatedError = true time.Sleep(100 * time.Millisecond) + } else { + repeatedError = false } - repeatedError = false if msg != nil && len(msg) >= 3 { var nt NotificationType switch string(msg[0]) {