code: def publish_receiver_count(self, service, routing_id):
          '''Get the number of peers that would handle a particular publish
  
          :param service: the service name
          :type service: anything hash-able
          :param routing_id: the id used for limiting the service handlers
          :type routing_id: int
          '''
          peers = len(list(self._dispatcher.find_peer_routes(
              const.MSG_TYPE_PUBLISH, service, routing_id)))
          if self._dispatcher.locally_handles(const.MSG_TYPE_PUBLISH,
                  service, routing_id):
              return peers + 1
          return peerf publish_receiver_count(self, service, routing_id):
          '''Get the number of peers that would handle a particular publish
  
          :param service: the service name
          :type service: anything hash-able
          :param routing_id: the id used for limiting the service handlers
          :type routing_id: int
          '''
          peers = len(list(self._dispatcher.find_peer_routes(
              const.MSG_TYPE_PUBLISH, service, routing_id)))
          if self._dispatcher.locally_handles(const.MSG_TYPE_PUBLISH,
                  service, routing_id):
              return peers + 1
          return peers
docs: Get the number of peers that would handle a particular publish
  
          :param service: the service name
          :type service: anything hash-able
          :param routing_id: the id used for limiting the service handlers
          :type routing_id: int