code: def _get_partition_receive_func(
      self,
      name,
      tag,
      src_party_id,
      src_role,
      dst_party_id,
      dst_role,
      topic_infos,
      mq,
      conf: dict,
  ):
      def _fn(index, _):
          return self._partition_receive(
              index=index,
              name=name,
              tag=tag,
              src_party_id=src_party_id,
              src_role=src_role,
              dst_party_id=dst_party_id,
              dst_role=dst_role,
              topic_infos=topic_infos,
              mq=mq,
              conf=conf,
          )
  
      return _fn
  
imports: import json
  import logging
  import sys
  import typing
  from typing import List
  from fate.arch.computing.api import KVTableContext
  from fate.arch.federation.api import Federation, PartyMeta, TableMeta
  from ._datastream import Datastream
  from ._parties import Party
label_desc: Use image node_id 24 for calling the MessageQueueBasedFederation obj's underlying member method code with example usage: obj._get_partition_receive_func(name, tag, src_party_id, src_role, dst_party_id, dst_role, topic_infos, mq, conf) and returns: _fn, self