'Create twitter river'

def testCreateTwitterRiver(self):

    test_river = TwitterRiver('test', 'test', index_name='text_index', index_type='status')
    result = self.conn.create_river(test_river, river_name='test_index')
    self.assertResultContains(result, {'ok': True})
