Module Expr Str ImportFrom alias ImportFrom alias alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr ListLoad Assign AttributeStore NameLoad attr ListLoad decorator_list FunctionDef arguments args NameParam defaults body For NameStore AttributeLoad NameLoad attr body Assign NameStore Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr NameLoad Expr Call AttributeLoad NameLoad attr For NameStore AttributeLoad NameLoad attr body Assign NameStore Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr NameLoad Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr Call NameLoad Assign AttributeStore NameLoad attr Call NameLoad keyword Str keyword Str FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr NameLoad Str Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list Assign NameStore Call NameLoad Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr Assign NameStore Call NameLoad keyword NameLoad keyword Str keyword NameLoad Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str Assign NameStore Call NameLoad Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr Assign NameStore Call NameLoad keyword NameLoad keyword AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Str Expr Call AttributeLoad NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr Num decorator_list decorator_list Call NameLoad Str
N/A N/A 
@author Luke Campbell <LCampbell@ASAScience.com>
@date Mon Jul 16 14:07:06 EDT 2012
@file pyon/ion/test/test_stream_pubsub.py
 pyon.util.int_test IonIntegrationTestCase pyon.ion.stream StreamSubscriber StreamPublisher pyon.ion.process SimpleProcess interface.objects StreamRoute gevent.event Event nose.plugins.attrib attr StreamPubsubTest N/A IonIntegrationTestCase N/A setUp N/A N/A self N/A N/A N/A N/A N/A self _start_container N/A N/A self queue_cleanup N/A N/A N/A self exchange_cleanup N/A N/A tearDown N/A N/A self N/A N/A N/A queue N/A self queue_cleanup N/A N/A xn N/A N/A N/A N/A self container ex_manager create_xn_queue queue N/A N/A N/A xn delete N/A exchange N/A self exchange_cleanup N/A N/A xp N/A N/A N/A N/A self container ex_manager create_xp exchange N/A N/A N/A xp delete N/A test_stream_pub_sub N/A N/A self N/A N/A N/A N/A self verified N/A Event N/A N/A self route N/A StreamRoute exchange_point xp_test routing_key route verify N/A N/A message route stream N/A N/A N/A N/A N/A self assertEquals message test N/A N/A N/A self assertEquals route N/A self route N/A N/A N/A self assertEquals stream N/A N/A N/A N/A self verified set N/A N/A sub_proc N/A SimpleProcess N/A N/A sub_proc container N/A self container N/A sub1 N/A StreamSubscriber process sub_proc exchange_name sub1 callback verify N/A N/A N/A sub1 start N/A N/A N/A N/A self queue_cleanup append sub1 N/A pub_proc N/A SimpleProcess N/A N/A pub_proc container N/A self container N/A pub1 N/A StreamPublisher process pub_proc stream_route N/A self route N/A N/A N/A N/A sub1 xn bind N/A N/A self route routing_key N/A pub1 xp N/A N/A N/A pub1 publish test N/A N/A N/A self assertTrue N/A N/A N/A self verified wait 2 N/A N/A N/A attr INT