Change queue size for all subscribers

cosminrentea · Mar 14, 2017 · d13a4e6 · d13a4e6
1 parent b2acb27
commit d13a4e6
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/server/connector/subscriber.go b/server/connector/subscriber.go
@@ -49,6 +49,7 @@ func (sd *SubscriberData) newRoute() *router.Route {
 	return router.NewRoute(router.RouteConfig{
 		Path:         sd.Topic,
 		RouteParams:  sd.Params,
+		QueueSize:    -1,
 		FetchRequest: fr,
 	})
 }