Use parameters in StreamSubscriptionServiceImpl