pyflink.datastream.connectors.rabbitmq.RMQSink# class RMQSink(connection_config: RMQConnectionConfig, queue_name: str, serialization_schema: SerializationSchema)[source]# Methods get_java_function()