zmq: remove port check error

This commit is contained in:
ErikEk
2022-04-30 12:00:32 +02:00
parent 9bbee09497
commit 30a857b982
2 changed files with 3 additions and 3 deletions

View File

@@ -530,7 +530,7 @@ func NewPartialChainControl(cfg *Config) (*PartialChainControl, func(), error) {
return nil, nil, err
}
if url.Port() != zmqPubRawBlockURL.Port() {
return nil, nil, fmt.Errorf(
log.Warnf(
"unable to subscribe to zmq block events on "+
"%s (bitcoind is running on %s)",
zmqPubRawBlockURL.Host,
@@ -545,7 +545,7 @@ func NewPartialChainControl(cfg *Config) (*PartialChainControl, func(), error) {
return nil, nil, err
}
if url.Port() != zmqPubRawTxURL.Port() {
return nil, nil, fmt.Errorf(
log.Warnf(
"unable to subscribe to zmq tx events on "+
"%s (bitcoind is running on %s)",
zmqPubRawTxURL.Host,