// Path: common/java/common/AMQPCommon.java
// public class AMQPCommon {
// 
// 	public static Channel connect() throws Exception {
// 		ConnectionFactory factory = new ConnectionFactory();
// 		factory.setHost("127.0.0.1");
// 		factory.setPort(32768);
// 		Connection conn = factory.newConnection();
// 		return conn.createChannel();
// 	}
// 	
// 	public static void close(Channel channel) throws Exception {
// 		channel.close();
// 		channel.getConnection().close();
// 	}
// 
// }


import com.rabbitmq.client.Channel;
import com.rabbitmq.client.QueueingConsumer;
import common.AMQPCommon;
package threshold;



public class AMQPConfig {

	public void execute() throws Exception {
// Path: common/java/common/AMQPCommon.java
// public class AMQPCommon {
// 
// 	public static Channel connect() throws Exception {
// 		ConnectionFactory factory = new ConnectionFactory();
// 		factory.setHost("127.0.0.1");
// 		factory.setPort(32768);
// 		Connection conn = factory.newConnection();
// 		return conn.createChannel();
// 	}
// 	
// 	public static void close(Channel channel) throws Exception {
// 		channel.close();
// 		channel.getConnection().close();
// 	}
// 
// }


// Path: threshold/java/threshold/AMQPConfig.java
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.QueueingConsumer;
import common.AMQPCommon;

package threshold;



public class AMQPConfig {

	public void execute() throws Exception {
		Channel channel = AMQPCommon.connect();