diff --git a/lib/go/camli/blobserver/replica/replica.go b/lib/go/camli/blobserver/replica/replica.go
index f4689bd05..5de609fc8 100644
--- a/lib/go/camli/blobserver/replica/replica.go
+++ b/lib/go/camli/blobserver/replica/replica.go
@@ -177,6 +177,7 @@ func (sto *replicaStorage) ReceiveBlob(b *blobref.BlobRef, source io.Reader) (xx
 		case res.err == nil && res.sb.Size == size:
 			nSuccess++
 			if nSuccess == sto.minWritesForSuccess {
+				sto.GetBlobHub().NotifyBlobReceived(b)
 				return res.sb, nil
 			}
 		case res.err == nil: