'NOTE(belliott) Each Transport object contains connection pool
state.  Maintain references to them to avoid continual reconnects
to the message broker.'

def _get_transport(self, next_hop):

    transport_url = next_hop.db_info['transport_url']
    if (transport_url not in self.transports):
        transport = messaging.get_rpc_transport(nova.conf.CONF, transport_url)
        self.transports[transport_url] = transport
    else:
        transport = self.transports[transport_url]
    return transport
