diff --git a/src/main/scala/com/wavesplatform/network/UtxPoolSynchronizer.scala b/src/main/scala/com/wavesplatform/network/UtxPoolSynchronizer.scala index 4e1d8af40cc..bda785d3ce1 100644 --- a/src/main/scala/com/wavesplatform/network/UtxPoolSynchronizer.scala +++ b/src/main/scala/com/wavesplatform/network/UtxPoolSynchronizer.scala @@ -25,7 +25,7 @@ object UtxPoolSynchronizer { .build[ByteStr, Object] txs.observeOn(scheduler).map { case (channel, tx) => knownTransactions.get(tx.id(), () => { - utx.putIfNew(tx).map(_ => allChannels.broadcast(tx, Some(channel))) + utx.putIfNew(tx).map(_ => allChannels.broadcastTx(tx, Some(channel))) dummy }) }