#!/usr/bin/env python

from gnuradio import gr

class testing(gr.top_block):
    def __init__(self):
        gr.top_block.__init__(self, "testing")

        self.src = gr.vector_source_f( range(200), False )

        self.mq = gr.msg_queue()
        self.sink = gr.message_sink(gr.sizeof_float, self.mq, False)
        self.connect( self.src, self.sink )

def main():
    top_block = testing()
    runtime = gr.runtime(top_block)

    try:
        runtime.start()

        print "queue"
        print top_block.mq.count()

        msg = top_block.mq.delete_head()
        print "msg"
        print msg.type()
        print msg.arg1()
        print msg.arg2()
        print msg.length()

        runtime.wait()
    except KeyboardInterrupt:
        pass

if __name__ == "__main__":
    main()

# vim: ai ts=4 sts=4 et sw=4