diff --git a/gstreamer/gstreamer.py b/gstreamer/gstreamer.py
index 13dcd05..d09a819 100755
--- a/gstreamer/gstreamer.py
+++ b/gstreamer/gstreamer.py
@@ -216,7 +216,7 @@ def run_pipeline(user_function,
     else:
         SRC_CAPS = 'video/x-raw,width={width},height={height},framerate=30/1'
     if videosrc.startswith('/dev/video'):
-        PIPELINE = 'v4l2src device=%s ! {src_caps}'%videosrc
+        PIPELINE = 'v4l2src device=/dev/video1 ! {src_caps} ! {leaky_q} ! tee name=t'
     elif videosrc.startswith('http'):
         PIPELINE = 'souphttpsrc location=%s'%videosrc
     elif videosrc.startswith('rtsp'):