gistfile1.java

package com.kevinherron.campfire.playground;

import com.ning.http.client.AsyncHandler;
import com.ning.http.client.AsyncHttpClient;
import com.ning.http.client.AsyncHttpClientConfig;
import com.ning.http.client.HttpResponseBodyPart;
import com.ning.http.client.HttpResponseHeaders;
import com.ning.http.client.HttpResponseStatus;
import com.ning.http.client.Realm;
import com.ning.http.client.Request;

public class Problem {

    public static void main(String[] args) throws Exception {
        AsyncHttpClientConfig config = new AsyncHttpClientConfig.Builder()
                .setRequestTimeoutInMs(Integer.MAX_VALUE)
                .setIdleConnectionTimeoutInMs(Integer.MAX_VALUE)
                .build();

        AsyncHttpClient client = new AsyncHttpClient(config);

        Realm realm = new Realm.RealmBuilder()
                .setPrincipal("REMOVED")
                .setPassword("X")
                .build();

        Request streamRequest = client
                .prepareGet("https://streaming.campfirenow.com/room/316301/live.json")
                .setRealm(realm)
                .build();

        client.executeRequest(streamRequest);

        // Give it time to actually connect...
        Thread.sleep(5000);

        System.out.println("Closing client...");
        client.close();
        System.out.println("...Done.");

        System.out.println("Exiting...");
    }

}