package rabbitmq2;
//import rabbitmq.Update;
import com.rabbitmq.client.*;

import java.io.IOException;
import java.util.concurrent.TimeoutException;
import org.json.JSONException;
import rabbitmq2.CreateJsonObj;
/**
 *
 * @author bouke
 */
public class Connectie {
    private final static String QUEUE_NAME = "hello";
    private static ConnectionFactory factory = new ConnectionFactory();
    private static Connection connection = null;
    private static Channel channel;
    private static Connectie p;
    private final static String host = "localhost";
    private final CreateJsonObj CJO = new CreateJsonObj();
    
    
    public static Connectie instance()
    {
        return p;
    }
    
    public Connectie() throws IOException, JSONException
    {
        
        channel = connection.createChannel();
        channel.queueDeclare(QUEUE_NAME, false,false,false,null);
        
        channel.basicQos(1);
        
        Consumer consumer = new DefaultConsumer(channel) {
        @Override
        public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body)
          throws IOException {
            String message = new String(body, "UTF-8");
            
            System.out.println(" [x] Received '" + message + "'");
      }
    };
    channel.basicConsume(QUEUE_NAME, false, consumer);
    }
    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) throws IOException, TimeoutException {
        // TODO code application logic here
        
        factory.setHost(host);
        try
        {
            connection = factory.newConnection();
            p = new Connectie();
            
        }
        catch (Exception ex)
        {
            ex.printStackTrace();
            System.exit(1);
        }
        // message = instance().CJO.JSONobj;
        System.out.println(instance().CJO.JSONobj);
        try
        {
            Channel testChannel = connection.createChannel();
            testChannel.basicPublish("", QUEUE_NAME, null, instance().CJO.JSONobj.toString().getBytes("UTF-8"));
            System.out.println(" [x] Sent '" + instance().CJO.JSONobj.toString() + "'");
            testChannel.queueDelete(QUEUE_NAME);
        }
        catch(IOException ex)
        {
            ex.printStackTrace();
        }
    }
    
    
}