#NEWLINE# def testCallClient( self ) : #NEWLINE# #INDENT# 'Flows can send client messages using CallClient().' #NEWLINE# flow_obj = self . FlowSetup ( 'FlowOrderTest' ) #NEWLINE# manager = queue_manager . QueueManager ( token = self . token ) #NEWLINE# tasks = manager . Query ( self . client_id , limit = 100 ) #NEWLINE# self . assertEqual ( len ( tasks ) , 1 ) #NEWLINE# message = tasks [ 0 ] #NEWLINE# self . assertEqual ( message . session_id , flow_obj . session_id ) #NEWLINE# self . assertEqual ( message . request_id , 1 ) #NEWLINE# self . assertEqual ( message . name , 'Test' )