#NEWLINE# def test_multiproc_pub_sub( self ) : #NEWLINE# #INDENT# if ( not self . do_test ) : #NEWLINE# #INDENT# return #NEWLINE# #UNINDENT# self . event_received = False #NEWLINE# cfg . CONF . df . publisher_multiproc_socket = '/tmp/ipc_test_socket' #NEWLINE# pub_sub_driver = df_utils . load_driver ( cfg . CONF . df . pub_sub_multiproc_driver , df_utils . DF_PUBSUB_DRIVER_NAMESPACE ) #NEWLINE# publisher = pub_sub_driver . get_publisher ( ) #NEWLINE# publisher . initialize ( ) #NEWLINE# self . subscriber = pub_sub_driver . get_subscriber ( ) #NEWLINE# self . subscriber . initialize ( self . _verify_event ) #NEWLINE# self . subscriber . daemonize ( ) #NEWLINE# publisher . send_event ( self . event ) #NEWLINE# wait_until_true ( ( lambda : self . event_received ) ) #NEWLINE# self . subscriber . stop ( ) #NEWLINE# self . subscriber = None