code: def _create_rabbitmq_ssl_options(
      rabbitmq_host: Optional[Text] = None,
  ) -> Optional[Dict]:
      """Create RabbitMQ SSL options.
  
      Requires the following environment variables to be set:
  
          RABBITMQ_SSL_CLIENT_CERTIFICATE - path to the SSL client certificate (required)
          RABBITMQ_SSL_CLIENT_KEY - path to the SSL client key (required)
  
      Details on how to enable RabbitMQ TLS support can be found here:
      https://www.rabbitmq.com/ssl.html#enabling-tls
  
      Args:
          rabbitmq_host: RabbitMQ hostname.
  
      Returns:
          Optional SSL arguments for the RabbitMQ connection.
      """
      client_certificate_path = os.environ.get(
          "RABBITMQ_SSL_CLIENT_CERTIFICATE"
      )
      client_key_path = os.environ.get("RABBITMQ_SSL_CLIENT_KEY")
  
      if os.environ.get("RABBITMQ_SSL_CA_FILE"):
          rasa.shared.utils.io.raise_warning(
              "Specifying 'RABBITMQ_SSL_CA_FILE' via "
              "environment variables is no longer supported. Please specify this "
              "through the RabbitMQ URL parameter 'cacertfile' as described here: "
              "https://www.rabbitmq.com/uri-query-parameters.html "
          )
  
      if os.environ.get("RABBITMQ_SSL_KEY_PASSWORD"):
          rasa.shared.utils.io.raise_warning(
              "Specifying 'RABBITMQ_SSL_KEY_PASSWORD' via environment variables is no "
              "longer supported. Please use an unencrypted key file."
          )
  
      if client_certificate_path and client_key_path:
          logger.debug(
              f"Configuring SSL context for RabbitMQ host '{rabbitmq_host}'."
          )
          return {
              "certfile": client_certificate_path,
              "client_key_path": client_key_path,
              "cert_reqs": ssl.CERT_REQUIRED,
          }
  
      return None
  
imports: import asyncio
  import json
  import logging
  import structlog
  import os
  import ssl
  from asyncio import AbstractEventLoop
  from collections import deque
  from typing import Deque, Dict, Optional, Text, Union, Any, List, Set, Tuple, cast
  from urllib.parse import urlparse
  import aio_pika
  from rasa.shared.exceptions import RasaException
  from rasa.shared.constants import DOCS_URL_PIKA_EVENT_BROKER
  from rasa.core.brokers.broker import EventBroker
  import rasa.shared.utils.io
  from rasa.utils.endpoints import EndpointConfig
  from rasa.shared.utils.io import DEFAULT_ENCODING
  import rasa.shared.utils.common
label_desc: Use image node_id 1 for calling a global function with example usage: _create_rabbitmq_ssl_options(rabbitmq_host) and returns: None, dict