#NEWLINE# def test_rpc_raises_on_timeout( self ) : #NEWLINE# #INDENT# rpc = Rpc ( FakeConnection ( ) , timeout = 0.1 ) #NEWLINE# uuid = rpc . register_request ( [ 'Test' ] ) #NEWLINE# self . assertEqual ( rpc . _response [ uuid ] , [ ] ) #NEWLINE# time . sleep ( 0.25 ) #NEWLINE# self . assertRaises ( AMQPChannelError , rpc . get_request , uuid )