diff --git a/pubsub.go b/pubsub.go
index 05ead71d..fdfa755b 100644
--- a/pubsub.go
+++ b/pubsub.go
@@ -1001,10 +1001,6 @@ func (p *PubSub) handleIncomingRPC(rpc *RPC) {
 	for _, subopt := range subs {
 		t := subopt.GetTopicid()
 
-		if !p.peerFilter(rpc.from, t) {
-			continue
-		}
-
 		if subopt.GetSubscribe() {
 			tmap, ok := p.topics[t]
 			if !ok {