pyflink.datastream.connectors.rabbitmq.RMQSource# class RMQSource(connection_config: RMQConnectionConfig, queue_name: str, use_correlation_id: bool, deserialization_schema: DeserializationSchema)[source]# Methods get_java_function()