#!/usr/bin/env python

from gi.repository import GObject
GObject.threads_init()
from gi.repository import GLib
from gi.repository import Gst
Gst.init(None)

def cb_notify(obj, prop):
  print obj
  print prop

q = Gst.ElementFactory.make('queue', None)
q.connect('notify', cb_notify)
q.set_property('max-size-bytes', 0)