test_class.declarator: source
test_class.modifier: private
test_class.original_string: private RMQSource<String> source;
test_class.type: RMQSource<String>
test_class.var_name: source
test_class.declarator: config = new Configuration()
test_class.modifier: private
test_class.original_string: private Configuration config = new Configuration();
test_class.type: Configuration
test_class.var_name: config
test_class.declarator: sourceThread
test_class.modifier: private
test_class.original_string: private Thread sourceThread;
test_class.type: Thread
test_class.var_name: sourceThread
test_class.declarator: messageId
test_class.modifier: private volatile
test_class.original_string: private volatile long messageId;
test_class.type: long
test_class.var_name: messageId
test_class.declarator: generateCorrelationIds
test_class.modifier: private
test_class.original_string: private boolean generateCorrelationIds;
test_class.type: boolean
test_class.var_name: generateCorrelationIds
test_class.declarator: exception
test_class.modifier: private volatile
test_class.original_string: private volatile Exception exception;
test_class.type: Exception
test_class.var_name: exception
test_class.file: flink-streaming-connectors/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSourceTest.java
test_class.identifier: RMQSourceTest
test_case.body: @Test
  	public void testConstructorParams() {
  		// verify construction params
  		ConstructorTestClass testObj = new ConstructorTestClass(
  			"hostTest", 999, "userTest", "passTest",
  			"queueTest", false, new StringDeserializationScheme());
  
  		try {
  			testObj.open(new Configuration());
  		} catch (Exception e) {
  			// connection fails but check if args have been passed correctly
  		}
  
  		assertEquals("hostTest", testObj.getFactory().getHost());
  		assertEquals(999, testObj.getFactory().getPort());
  		assertEquals("userTest", testObj.getFactory().getUsername());
  		assertEquals("passTest", testObj.getFactory().getPassword());
  	}
test_case.class_method_signature: RMQSourceTest.testConstructorParams()
test_case.full_signature: @Test public void testConstructorParams()
test_case.identifier: testConstructorParams
test_case.invocations: open assertEquals getHost getFactory assertEquals getPort getFactory assertEquals getUsername getFactory assertEquals getPassword getFactory
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testConstructorParams()
focal_class.declarator: serialVersionUID = 1L
focal_class.modifier: private static final
focal_class.original_string: private static final long serialVersionUID = 1L;
focal_class.type: long
focal_class.var_name: serialVersionUID
focal_class.declarator: LOG = LoggerFactory.getLogger(RMQSource.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger LOG = LoggerFactory.getLogger(RMQSource.class);
focal_class.type: Logger
focal_class.var_name: LOG
focal_class.declarator: hostName
focal_class.modifier: private final
focal_class.original_string: private final String hostName;
focal_class.type: String
focal_class.var_name: hostName
focal_class.declarator: port
focal_class.modifier: private final
focal_class.original_string: private final Integer port;
focal_class.type: Integer
focal_class.var_name: port
focal_class.declarator: username
focal_class.modifier: private final
focal_class.original_string: private final String username;
focal_class.type: String
focal_class.var_name: username
focal_class.declarator: password
focal_class.modifier: private final
focal_class.original_string: private final String password;
focal_class.type: String
focal_class.var_name: password
focal_class.declarator: queueName
focal_class.modifier: private final
focal_class.original_string: private final String queueName;
focal_class.type: String
focal_class.var_name: queueName
focal_class.declarator: usesCorrelationId
focal_class.modifier: private final
focal_class.original_string: private final boolean usesCorrelationId;
focal_class.type: boolean
focal_class.var_name: usesCorrelationId
focal_class.declarator: schema
focal_class.modifier: protected
focal_class.original_string: protected DeserializationSchema<OUT> schema;
focal_class.type: DeserializationSchema<OUT>
focal_class.var_name: schema
focal_class.declarator: connection
focal_class.modifier: protected transient
focal_class.original_string: protected transient Connection connection;
focal_class.type: Connection
focal_class.var_name: connection
focal_class.declarator: channel
focal_class.modifier: protected transient
focal_class.original_string: protected transient Channel channel;
focal_class.type: Channel
focal_class.var_name: channel
focal_class.declarator: consumer
focal_class.modifier: protected transient
focal_class.original_string: protected transient QueueingConsumer consumer;
focal_class.type: QueueingConsumer
focal_class.var_name: consumer
focal_class.declarator: autoAck
focal_class.modifier: protected transient
focal_class.original_string: protected transient boolean autoAck;
focal_class.type: boolean
focal_class.var_name: autoAck
focal_class.declarator: running
focal_class.modifier: private transient volatile
focal_class.original_string: private transient volatile boolean running;
focal_class.type: boolean
focal_class.var_name: running
focal_class.file: flink-streaming-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java
focal_class.identifier: RMQSource
focal_class.interfaces: implements ResultTypeQueryable<OUT>
focal_class.class_method_signature: RMQSource.RMQSource(String hostName, String queueName,
  				DeserializationSchema<OUT> deserializationSchema)
focal_class.full_signature: public  RMQSource(String hostName, String queueName,
  				DeserializationSchema<OUT> deserializationSchema)
focal_class.identifier: RMQSource
focal_class.modifiers: public
focal_class.parameters: (String hostName, String queueName,
  				DeserializationSchema<OUT> deserializationSchema)
focal_class.signature:  RMQSource(String hostName, String queueName,
  				DeserializationSchema<OUT> deserializationSchema)
focal_class.class_method_signature: RMQSource.RMQSource(String hostName, String queueName, boolean usesCorrelationId,
  				DeserializationSchema<OUT> deserializationSchema)
focal_class.full_signature: public  RMQSource(String hostName, String queueName, boolean usesCorrelationId,
  				DeserializationSchema<OUT> deserializationSchema)
focal_class.identifier: RMQSource
focal_class.modifiers: public
focal_class.parameters: (String hostName, String queueName, boolean usesCorrelationId,
  				DeserializationSchema<OUT> deserializationSchema)
focal_class.signature:  RMQSource(String hostName, String queueName, boolean usesCorrelationId,
  				DeserializationSchema<OUT> deserializationSchema)
focal_class.class_method_signature: RMQSource.RMQSource(String hostName, Integer port,
  				String queueName, boolean usesCorrelationId,
  				DeserializationSchema<OUT> deserializationSchema)
focal_class.full_signature: public  RMQSource(String hostName, Integer port,
  				String queueName, boolean usesCorrelationId,
  				DeserializationSchema<OUT> deserializationSchema)
focal_class.identifier: RMQSource
focal_class.modifiers: public
focal_class.parameters: (String hostName, Integer port,
  				String queueName, boolean usesCorrelationId,
  				DeserializationSchema<OUT> deserializationSchema)
focal_class.signature:  RMQSource(String hostName, Integer port,
  				String queueName, boolean usesCorrelationId,
  				DeserializationSchema<OUT> deserializationSchema)
focal_class.class_method_signature: RMQSource.RMQSource(String hostName, Integer port, String username, String password,
  				String queueName, boolean usesCorrelationId,
  				DeserializationSchema<OUT> deserializationSchema)
focal_class.full_signature: public  RMQSource(String hostName, Integer port, String username, String password,
  				String queueName, boolean usesCorrelationId,
  				DeserializationSchema<OUT> deserializationSchema)
focal_class.identifier: RMQSource
focal_class.modifiers: public
focal_class.parameters: (String hostName, Integer port, String username, String password,
  				String queueName, boolean usesCorrelationId,
  				DeserializationSchema<OUT> deserializationSchema)
focal_class.signature:  RMQSource(String hostName, Integer port, String username, String password,
  				String queueName, boolean usesCorrelationId,
  				DeserializationSchema<OUT> deserializationSchema)
focal_class.class_method_signature: RMQSource.setupConnectionFactory()
focal_class.full_signature: protected ConnectionFactory setupConnectionFactory()
focal_class.identifier: setupConnectionFactory
focal_class.modifiers: protected
focal_class.parameters: ()
focal_class.return: ConnectionFactory
focal_class.signature: ConnectionFactory setupConnectionFactory()
focal_class.class_method_signature: RMQSource.initializeConnection()
focal_class.full_signature: private void initializeConnection()
focal_class.identifier: initializeConnection
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void initializeConnection()
focal_class.class_method_signature: RMQSource.open(Configuration config)
focal_class.full_signature: @Override public void open(Configuration config)
focal_class.identifier: open
focal_class.modifiers: @Override public
focal_class.parameters: (Configuration config)
focal_class.return: void
focal_class.signature: void open(Configuration config)
focal_class.class_method_signature: RMQSource.close()
focal_class.full_signature: @Override public void close()
focal_class.identifier: close
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void close()
focal_class.class_method_signature: RMQSource.run(SourceContext<OUT> ctx)
focal_class.full_signature: @Override public void run(SourceContext<OUT> ctx)
focal_class.identifier: run
focal_class.modifiers: @Override public
focal_class.parameters: (SourceContext<OUT> ctx)
focal_class.return: void
focal_class.signature: void run(SourceContext<OUT> ctx)
focal_class.class_method_signature: RMQSource.cancel()
focal_class.full_signature: @Override public void cancel()
focal_class.identifier: cancel
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void cancel()
focal_class.class_method_signature: RMQSource.acknowledgeSessionIDs(List<Long> sessionIds)
focal_class.full_signature: @Override protected void acknowledgeSessionIDs(List<Long> sessionIds)
focal_class.identifier: acknowledgeSessionIDs
focal_class.modifiers: @Override protected
focal_class.parameters: (List<Long> sessionIds)
focal_class.return: void
focal_class.signature: void acknowledgeSessionIDs(List<Long> sessionIds)
focal_class.class_method_signature: RMQSource.getProducedType()
focal_class.full_signature: @Override public TypeInformation<OUT> getProducedType()
focal_class.identifier: getProducedType
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: TypeInformation<OUT>
focal_class.signature: TypeInformation<OUT> getProducedType()
focal_class.superclass: extends MultipleIdsMessageAcknowledgingSourceBase<OUT, String, Long>
focal_method.body: @Override
  	public void open(Configuration config) throws Exception {
  		super.open(config);
  		initializeConnection();
  		running = true;
  	}
focal_method.class_method_signature: RMQSource.open(Configuration config)
focal_method.full_signature: @Override public void open(Configuration config)
focal_method.identifier: open
focal_method.invocations: open initializeConnection
focal_method.modifiers: @Override public
focal_method.parameters: (Configuration config)
focal_method.return: void
focal_method.signature: void open(Configuration config)