Create RabbitMQ connection

MessageReceiver.java

    private Connection createConnection() throws TimeoutException, InterruptedException {
        ConnectionFactory factory = new ConnectionFactory();
        // "guest"/"guest" by default, limited to localhost connections
        factory.setUsername("guest");
        factory.setPassword("guest");
        factory.setVirtualHost("/");
        factory.setHost("127.0.0.1");
        factory.setPort(5672);
        return connectToRabbitMQ(factory);
    }

    private Connection connectToRabbitMQ(ConnectionFactory factory) throws TimeoutException, InterruptedException {
        Connection conn = null;
        // if the connection has not been established, retry connection
        for (int retryNum = 100; retryNum >= 0; retryNum--) {
            try {
                conn = factory.newConnection("rabbitmq_connection");
                break;
            } catch (IOException e) {
                System.out.println("Waiting for Rabbitmq connection...");
                Thread.sleep(5000);
            }
        }
        if (conn == null){
            throw new IllegalStateException("Couldn't establish connection to rabbitMQ");
        }
        return conn;
    }