Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(2)  |  Call(2)  |  Derive(0)  |  Import(0)

src/p/y/pyon-HEAD/pyon/ion/stream.py   pyon(Download)
        self.stream_route = stream_route
 
        self.xp = Container.instance.ex_manager.create_xp(stream_route.exchange_point)
        self.xp_route = self.xp.create_route(stream_route.routing_key)
 
        xp_route = self.xp_route
        if stream_route:
            xp = Container.instance.ex_manager.create_xp(stream_route.exchange_point)
            xp_route = xp.create_route(stream_route.routing_key)
        stream_route = stream_route or self.stream_route