diff --git a/dataRetriever/factory/requestersContainer/metaRequestersContainerFactory.go b/dataRetriever/factory/requestersContainer/metaRequestersContainerFactory.go
index 1fd589f498b..f025eacacc7 100644
--- a/dataRetriever/factory/requestersContainer/metaRequestersContainerFactory.go
+++ b/dataRetriever/factory/requestersContainer/metaRequestersContainerFactory.go
@@ -185,7 +185,7 @@ func (mrcf *metaRequestersContainerFactory) generateMetaChainHeaderRequesters()
 func (mrcf *metaRequestersContainerFactory) generateReceiptRequesters() error {
 	// only one receipts topic
 	identifierReceipt := factory.ReceiptTopic + mrcf.shardCoordinator.CommunicationIdentifier(core.MetachainShardId)
-	requester, err := mrcf.createReceiptRequester(identifierReceipt, EmptyExcludePeersOnTopic, core.MetachainShardId, mrcf.numIntraShardPeers)
+	requester, err := mrcf.createReceiptRequester(identifierReceipt, EmptyExcludePeersOnTopic, core.MetachainShardId, mrcf.numTotalPeers)
 	if err != nil {
 		return err
 	}
diff --git a/dataRetriever/factory/requestersContainer/shardRequestersContainerFactory.go b/dataRetriever/factory/requestersContainer/shardRequestersContainerFactory.go
index f917cc01e01..af8623c16ee 100644
--- a/dataRetriever/factory/requestersContainer/shardRequestersContainerFactory.go
+++ b/dataRetriever/factory/requestersContainer/shardRequestersContainerFactory.go
@@ -145,7 +145,7 @@ func (srcf *shardRequestersContainerFactory) generateReceiptRequesters() error {
 	// only one receipts topic
 	selfShardID := srcf.shardCoordinator.SelfId()
 	identifierReceipt := factory.ReceiptTopic
-	requester, err := srcf.createReceiptRequester(identifierReceipt, EmptyExcludePeersOnTopic, selfShardID, srcf.numIntraShardPeers)
+	requester, err := srcf.createReceiptRequester(identifierReceipt, EmptyExcludePeersOnTopic, selfShardID, srcf.numTotalPeers)
 	if err != nil {
 		return err
 	}