1 files changed, 19 insertions, 6 deletions
diff --git a/src/gsttools/qgstreamerbushelper.cpp b/src/gsttools/qgstreamerbushelper.cpp
index 68c8795ce..751e805ba 100644
--- a/src/gsttools/qgstreamerbushelper.cpp
+++ b/src/gsttools/qgstreamerbushelper.cpp
@@ -98,17 +98,20 @@ private:
     void processMessage(GstMessage* message)
     {
         QGstreamerMessage msg(message);
-        foreach (QGstreamerBusMessageFilter *filter, busFilters) {
-            if (filter->processBusMessage(msg))
-                break;
-        }
-        emit m_helper->message(msg);
+        doProcessMessage(msg);
+    }
+
+    void queueMessage(GstMessage* message)
+    {
+        QGstreamerMessage msg(message);
+        QMetaObject::invokeMethod(this, "doProcessMessage", Qt::QueuedConnection,
+                                  Q_ARG(QGstreamerMessage, msg));
     }
 
     static gboolean busCallback(GstBus *bus, GstMessage *message, gpointer data)
     {
         Q_UNUSED(bus);
-        reinterpret_cast<QGstreamerBusHelperPrivate*>(data)->processMessage(message);
+        reinterpret_cast<QGstreamerBusHelperPrivate*>(data)->queueMessage(message);
         return TRUE;
     }
 
@@ -117,6 +120,16 @@ private:
     QGstreamerBusHelper*  m_helper;
     QTimer*     m_intervalTimer;
 
+private slots:
+    void doProcessMessage(const QGstreamerMessage& msg)
+    {
+        foreach (QGstreamerBusMessageFilter *filter, busFilters) {
+            if (filter->processBusMessage(msg))
+                break;
+        }
+        emit m_helper->message(msg);
+    }
+
 public:
     QMutex filterMutex;
     QList<QGstreamerSyncMessageFilter*> syncFilters;