@pipeline.each_by_interface(Gst::TagSetter) do |element|
                element.signal_connect("state-change") do
                    element.merge(tags_hash, Gst::Tag::MERGE_REPLACE_ALL)
                end
            end