diff --git a/src/engines/gstenginepipeline.cpp b/src/engines/gstenginepipeline.cpp
index 5c051583b..c8fbba415 100644
--- a/src/engines/gstenginepipeline.cpp
+++ b/src/engines/gstenginepipeline.cpp
@@ -389,6 +389,11 @@ QString GstEnginePipeline::ParseTag(GstTagList* list, const char* tag) const {
 }
 
 void GstEnginePipeline::StateChangedMessageReceived(GstMessage* msg) {
+  if (msg->src != GST_OBJECT(pipeline_)) {
+    // We only care about state changes of the whole pipeline.
+    return;
+  }
+
   GstState old_state, new_state, pending;
   gst_message_parse_state_changed(msg, &old_state, &new_state, &pending);