code: def test_rabbitmq_connectors(self):
      connection_config = (
          RMQConnectionConfig.Builder()
          .set_host("localhost")
          .set_port(5672)
          .set_virtual_host("/")
          .set_user_name("guest")
          .set_password("guest")
          .build()
      )
      type_info = Types.ROW([Types.INT(), Types.STRING()])
      deserialization_schema = (
          JsonRowDeserializationSchema.builder()
          .type_info(type_info=type_info)
          .build()
      )
  
      rmq_source = RMQSource(
          connection_config,
          "source_queue",
          True,
          deserialization_schema,
      )
      self.assertEqual(
          get_field_value(rmq_source.get_java_function(), "queueName"),
          "source_queue",
      )
      self.assertTrue(
          get_field_value(
              rmq_source.get_java_function(), "usesCorrelationId"
          )
      )
  
      serialization_schema = (
          JsonRowSerializationSchema.builder()
          .with_type_info(type_info)
          .build()
      )
      rmq_sink = RMQSink(
          connection_config, "sink_queue", serialization_schema
      )
      self.assertEqual(
          get_field_value(rmq_sink.get_java_function(), "queueName"),
          "sink_queue",
      )
  
imports: from pyflink.common import Types
  from pyflink.datastream.connectors.rabbitmq import RMQSink, RMQSource, RMQConnectionConfig
  from pyflink.datastream.formats.json import JsonRowDeserializationSchema, JsonRowSerializationSchema
  from pyflink.testing.test_case_utils import PyFlinkStreamingTestCase
  from pyflink.util.java_utils import get_field_value
label_desc: Use image node_id 1 for calling the RMQTest obj's underlying member method code with example usage: obj.test_rabbitmq_connectors() without return types