code: def _get_consume_message(self, channel_info):
      for method, properties, body in channel_info.consume():
          LOGGER.debug(
              f"[rabbitmq._get_consume_message] method: {method}, properties: {properties}"
          )
  
          properties = {
              "message_id": properties.message_id,
              "correlation_id": properties.correlation_id,
              "content_type": properties.content_type,
              "headers": json.dumps(properties.headers),
          }
  
          yield method.delivery_tag, properties, body
  
imports: import json
  from logging import getLogger
  from typing import List, Optional
  from fate.arch.federation.api import PartyMeta
  from fate.arch.federation.message_queue import MessageQueueBasedFederation, Party
  from ._mq_channel import MQChannel
  from ._rabbit_manager import RabbitManager
label_desc: Use image node_id 11 for calling the RabbitmqFederation obj's underlying member method code with example usage: obj._get_consume_message(channel_info) without return types