RMQSource extends MultipleIdsMessageAcknowledgingSourceBase<OUT, String, Long> implements ResultTypeQueryable<OUT> { @Override public void open(Configuration config) throws Exception { super.open(config); initializeConnection(); running = true; } RMQSource(String hostName, String queueName,
				DeserializationSchema<OUT> deserializationSchema);  RMQSource(String hostName, String queueName, boolean usesCorrelationId,
				DeserializationSchema<OUT> deserializationSchema);  RMQSource(String hostName, Integer port,
				String queueName, boolean usesCorrelationId,
				DeserializationSchema<OUT> deserializationSchema);  RMQSource(String hostName, Integer port, String username, String password,
				String queueName, boolean usesCorrelationId,
				DeserializationSchema<OUT> deserializationSchema); @Override void open(Configuration config); @Override void close(); @Override void run(SourceContext<OUT> ctx); @Override void cancel(); @Override TypeInformation<OUT> getProducedType();  }
@Test public void testConstructorParams() { ConstructorTestClass testObj = new ConstructorTestClass( "hostTest", 999, "userTest", "passTest", "queueTest", false, new StringDeserializationScheme()); try { testObj.open(new Configuration()); } catch (Exception e) { } assertEquals("hostTest", testObj.getFactory().getHost()); assertEquals(999, testObj.getFactory().getPort()); assertEquals("userTest", testObj.getFactory().getUsername()); assertEquals("passTest", testObj.getFactory().getPassword()); }