diff --git a/trunk/src/app/srs_app_forward.cpp b/trunk/src/app/srs_app_forward.cpp
index 7698cb5bc..47fe6e809 100755
--- a/trunk/src/app/srs_app_forward.cpp
+++ b/trunk/src/app/srs_app_forward.cpp
@@ -248,9 +248,17 @@ int SrsForwarder::cycle()
         return ret;
     }
     
-    if ((ret = client->publish(_req->stream, stream_id)) != ERROR_SUCCESS) {
-        srs_error("connect with server failed, stream_name=%s, stream_id=%d. ret=%d", 
-            _req->stream.c_str(), stream_id, ret);
+    string stream = _req->stream;
+    // Pass params in stream, @see https://github.com/ossrs/srs/issues/1031#issuecomment-409745733
+    if (!_req->param.empty()) {
+        if (_req->param.find("?") != 0) {
+            stream += "?";
+        }
+        stream += _req->param;
+    }
+    
+    if ((ret = client->publish(stream, stream_id)) != ERROR_SUCCESS) {
+        srs_error("connect with server failed, stream_name=%s, stream_id=%d. ret=%d", stream.c_str(), stream_id, ret);
         return ret;
     }