class RMQSource extends MultipleIdsMessageAcknowledgingSourceBase<OUT, String, Long> implements ResultTypeQueryable<OUT> {

	@Override
	public void open(Configuration config) throws Exception {
		super.open(config);
		initializeConnection();
		running = true;
	}

	public  RMQSource(String hostName, String queueName,
				DeserializationSchema<OUT> deserializationSchema);
	public  RMQSource(String hostName, String queueName, boolean usesCorrelationId,
				DeserializationSchema<OUT> deserializationSchema);
	public  RMQSource(String hostName, Integer port,
				String queueName, boolean usesCorrelationId,
				DeserializationSchema<OUT> deserializationSchema);
	public  RMQSource(String hostName, Integer port, String username, String password,
				String queueName, boolean usesCorrelationId,
				DeserializationSchema<OUT> deserializationSchema);

}