docstr: Creates a new RabbitMQ sink.
  
  :param connection_config: The RabbiMQ connection configuration.
  :param queue_name: The queue to publish messages to.
  :param serialization_schema: A serializer used to convert Flink objects to bytes.
docstr_tok: ["Creates","a","new","RabbitMQ","sink",".",":","param","connection_config",":","The","RabbiMQ","connection","configuration",".",":","param","queue_name",":","The","queue","to","publish","messages","to",".",":","param","serialization_schema",":","A","serializer","used","to","convert","Flink","objects","to","bytes","."]
code: def __init__(
      self,
      connection_config: "RMQConnectionConfig",
      queue_name: str,
      serialization_schema: SerializationSchema,
  ):
      """
      Creates a new RabbitMQ sink.
  
      :param connection_config: The RabbiMQ connection configuration.
      :param queue_name: The queue to publish messages to.
      :param serialization_schema: A serializer used to convert Flink objects to bytes.
      """
      JRMQSink = (
          get_gateway().jvm.org.apache.flink.streaming.connectors.rabbitmq.RMQSink
      )
      j_rmq_sink = JRMQSink(
          connection_config._j_rmq_connection_config,
          queue_name,
          serialization_schema._j_serialization_schema,
      )
      super(RMQSink, self).__init__(sink_func=j_rmq_sink)
  
imports: from pyflink.common import SerializationSchema, DeserializationSchema
  from pyflink.datastream.functions import SinkFunction, SourceFunction
  from pyflink.java_gateway import get_gateway
label_desc: Use image node_id 1 to create a new RMQSink object from inherited base classes: SinkFunction with example: obj = RMQSink(connection_config, queue_name, serialization_schema)