gchar *caps_str = g_strdup ("video/x-raw,width=640,height=320,format=RGB");
gchar *topic_name = g_strdup ("test_topic");
gchar *str_pipeline = g_strdup_printf (
- "mqttsrc sub-topic=%s debug=true is-live=true num-buffers=%d ! "
+ "mqttsrc sub-topic=%s debug=true is-live=true num-buffers=%d "
+ "sub-timeout=%" G_GINT64_FORMAT " ! "
"capsfilter caps=%s ! videoconvert ! videoscale ! fakesink",
- topic_name, 1, caps_str);
+ topic_name, 1, G_TIME_SPAN_MINUTE, caps_str);
GError *err = NULL;
GstElement *pipeline;
GstStateChangeReturn ret;
gchar *caps_str = g_strdup ("video/x-raw,width=640,height=320,format=RGB");
gchar *topic_name = g_strdup ("test_topic");
gchar *str_pipeline = g_strdup_printf (
- "mqttsrc sub-topic=%s debug=true is-live=true num-buffers=%d ! "
+ "mqttsrc sub-topic=%s debug=true is-live=true num-buffers=%d "
+ "sub-timeout=%" G_GINT64_FORMAT " ! "
"capsfilter caps=%s ! videoconvert ! videoscale ! fakesink",
- topic_name, 2, caps_str);
+ topic_name, 2, G_TIME_SPAN_MINUTE, caps_str);
GError *err = NULL;
GstElement *pipeline;
GstStateChangeReturn ret;
gchar *caps_str = g_strdup ("video/x-raw,width=640,height=320,format=RGB");
gchar *topic_name = g_strdup ("test_topic");
gchar *str_pipeline = g_strdup_printf (
- "mqttsrc sub-topic=%s debug=true is-live=true num-buffers=%d ! "
+ "mqttsrc sub-topic=%s debug=true is-live=true num-buffers=%d "
+ "sub-timeout=%" G_GINT64_FORMAT " ! "
"capsfilter caps=%s ! videoconvert ! videoscale ! fakesink",
- topic_name, 1, caps_str);
+ topic_name, 1, G_TIME_SPAN_MINUTE, caps_str);
GError *err = NULL;
GstElement *pipeline;
GstStateChangeReturn ret;
gchar *caps_str = g_strdup ("video/x-raw,width=640,height=320,format=RGB");
gchar *topic_name = g_strdup ("test_topic");
gchar *str_pipeline = g_strdup_printf (
- "mqttsrc sub-topic=%s debug=true is-live=true num-buffers=%d ! "
+ "mqttsrc sub-topic=%s debug=true is-live=true num-buffers=%d "
+ "sub-timeout=%" G_GINT64_FORMAT " ! "
"capsfilter caps=%s ! videoconvert ! videoscale ! fakesink",
- topic_name, 1, caps_str);
+ topic_name, 1, G_TIME_SPAN_MINUTE, caps_str);
GError *err = NULL;
GstElement *pipeline;
GstStateChangeReturn ret;
gchar *caps_str = g_strdup ("video/x-raw,width=640,height=320,format=RGB");
gchar *topic_name = g_strdup ("test_topic");
gchar *str_pipeline = g_strdup_printf (
- "mqttsrc sub-topic=%s debug=true is-live=true num-buffers=%d ! "
+ "mqttsrc sub-topic=%s debug=true is-live=true num-buffers=%d "
+ "sub-timeout=%" G_GINT64_FORMAT " ! "
"capsfilter caps=%s ! videoconvert ! videoscale ! fakesink",
- topic_name, 1, caps_str);
+ topic_name, 1, G_TIME_SPAN_MINUTE, caps_str);
GError *err = NULL;
GstElement *pipeline;
GstStateChangeReturn ret;