Examples of org.atmosphere.wasync.serial.DefaultSerializedFireStage

org.atmosphere.wasync.serial.DefaultSerializedFireStage
Default implementation of a {@link SerializedFireStage}.
This implementation is based on an unbounded stage that enqueues the payload objects to be fired ( {@link SerializedFireStage#enqueue(Object,SettableFuture)}) by means of a {@link LinkedBlockingQueue}.
Every instance of this class spans its dedicated stage thread, which sequentially consumes payload objects off the stage queue.
Binary payloads are aggregated up to a {@code maxBinaryPayloadAggregationSize}.
@author Christian Bach

        final CountDownLatch latch = new CountDownLatch(1);
        final AtomicReference<StringBuffer> response = new AtomicReference<StringBuffer>(new StringBuffer());
        SerializedClient client = ClientFactory.getDefault().newClient(SerializedClient.class);


        SerializedOptionsBuilder b = client.newOptionsBuilder();
        b.serializedFireStage(new DefaultSerializedFireStage());


        RequestBuilder request = client.newRequestBuilder()
                .method(Request.METHOD.GET)
                .uri(targetUrl + "/suspend")
                .transport(transport());

View Full Code Here

        final CountDownLatch latch = new CountDownLatch(2);
        final AtomicReference<StringBuffer> response = new AtomicReference<StringBuffer>(new StringBuffer());
        SerializedClient client = ClientFactory.getDefault().newClient(SerializedClient.class);


        SerializedOptionsBuilder b = client.newOptionsBuilder();
        b.serializedFireStage(new DefaultSerializedFireStage());


        RequestBuilder request = client.newRequestBuilder()
                .method(Request.METHOD.GET)
                .uri(targetUrl + "/suspend")
                .transport(transport());

View Full Code Here

        RequestBuilder request = client.newRequestBuilder()
                .method(Request.METHOD.GET)
                .uri(targetUrl + "/suspend")
                .transport(Request.TRANSPORT.WEBSOCKET);


        Socket socket = client.create(client.newOptionsBuilder().runtime(ahc).runtimeShared(false).serializedFireStage(new DefaultSerializedFireStage()).build());
        socket.open(request.build());
        socket.close();


        // AHC is async closed
        Thread.sleep(1000);

View Full Code Here

TOP

Related Classes of org.atmosphere.wasync.serial.DefaultSerializedFireStage

com.ning.http.client.Response

org.atmosphere.tests.BaseTest

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.