Examples of org.atmosphere.wasync.RequestBuilder

org.atmosphere.wasync.RequestBuilder
Base class for building {@link Request} @author jeanfrancois Arcand


        final CountDownLatch latch = new CountDownLatch(1);
        final AtomicReference<POJO> response = new AtomicReference<POJO>();
        Client client = ClientFactory.getDefault().newClient();


        RequestBuilder request = client.newRequestBuilder()
                .method(Request.METHOD.GET)
                .uri(targetUrl + "/suspend")
                .decoder(new Decoder<String, POJO>() {
                    @Override
                    public POJO decode(Event e, String s) {
                        return new POJO(s);
                    }
                })
                .transport(transport());


        Socket socket = client.create();
        socket.on(Event.MESSAGE, new Function<POJO>() {
            @Override
            public void on(POJO t) {
                response.set(t);
                latch.countDown();
            }
        }).open(request.build()).fire("echo");


        latch.await(5, TimeUnit.SECONDS);


        assertNotNull(response.get());
        assertEquals(response.get().getClass(), POJO.class);

View Full Code Here


        final CountDownLatch latch = new CountDownLatch(1);
        final AtomicReference<Request.TRANSPORT> response = new AtomicReference<Request.TRANSPORT>();
        Client client = ClientFactory.getDefault().newClient();


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


        Socket socket = client.create();
        socket.on(Event.TRANSPORT, new Function<Request.TRANSPORT>() {
            @Override
            public void on(Request.TRANSPORT t) {
                response.set(t);
                latch.countDown();
            }
        }).open(request.build()).fire("yo");


        latch.await(5, TimeUnit.SECONDS);


        assertNotNull(response.get());
        assertEquals(response.get(), transport());

View Full Code Here


        final CountDownLatch latch = new CountDownLatch(1);
        final AtomicReference<String> response = new AtomicReference<String>();
        Client client = ClientFactory.getDefault().newClient();


        RequestBuilder request = client.newRequestBuilder()
                .method(Request.METHOD.GET)
                .uri(targetUrl + "/suspend")
                .encoder(new Encoder<String, POJO>() {
                    @Override
                    public POJO encode(String s) {
                        return new POJO("<-" + s + "->");
                    }
                })
                .encoder(new Encoder<POJO, Reader>() {
                    @Override
                    public Reader encode(POJO s) {
                        return new StringReader(s.message);
                    }
                })
                .transport(transport());


        Socket socket = client.create();
        socket.on(Event.MESSAGE, new Function<String>() {
            @Override
            public void on(String t) {
                response.set(t);
                latch.countDown();
            }
        }).on(new Function<Throwable>() {


            @Override
            public void on(Throwable t) {
                t.printStackTrace();
                latch.countDown();
            }


        }).open(request.build()).fire("echo");


        latch.await(5, TimeUnit.SECONDS);
        socket.close();


        assertEquals(response.get(), "<-echo->");

View Full Code Here


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


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


        Socket socket = client.create();


        socket.on("message", new Function<String>() {
            @Override
            public void on(String t) {
                logger.info("Function invoked {}", t);
                response.get().append(t);
                latch.countDown();
            }
        }).on(new Function<Throwable>() {


            @Override
            public void on(Throwable t) {
                t.printStackTrace();
                latch.countDown();
            }


        }).open(request.build())
                .fire("PING").get()
                .fire("PONG").get();


        latch.await(5, TimeUnit.SECONDS);
        socket.close();

View Full Code Here


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


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


        Socket socket = client.create();


        socket.on("message", new Function<String>() {
            @Override
            public void on(String t) {
                logger.info("Function invoked {}", t);
                response.get().append(t);
                latch.countDown();
            }
        }).on(new Function<Throwable>() {


            @Override
            public void on(Throwable t) {
                t.printStackTrace();
                latch.countDown();
            }


        }).open(request.build())
                .fire("PING")
                .fire("PONG");


        latch.await(5, TimeUnit.SECONDS);
        socket.close();

View Full Code Here

        server.start();


        final AsyncHttpClient c = new AsyncHttpClient(new AsyncHttpClientConfig.Builder().setMaxRequestRetry(0).build());
        final CountDownLatch l = new CountDownLatch(getCount());
        Client client = ClientFactory.getDefault().newClient();
        RequestBuilder request = client.newRequestBuilder();
        request.method(Request.METHOD.GET).uri(targetUrl);
        request.transport(transport());
        request.encoder(new Encoder<String, String>() {
            @Override
            public String encode(String s) {
                return s;
            }
        });
        Socket[] sockets = new Socket[getCount()];
        request.decoder(new Decoder<String, String>() {
            @Override
            public String decode(Event evntp, String s) {
                return s;
            }
        });
        for (int i = 0; i < getCount(); i++) {
            sockets[i] = client.create(client.newOptionsBuilder().runtime(c, true).build());
            sockets[i].on(new Function<Integer>() {
                @Override
                public void on(Integer statusCode) {
                }
            });
            sockets[i].on(new Function<String>() {
                @Override
                public void on(String s) {
                    if (s.equalsIgnoreCase("yo!")) {
                        System.out.println("=========> " + l.getCount());
                        l.countDown();
                    }
                }
            });
            sockets[i].on(new Function<Throwable>() {
                @Override
                public void on(Throwable t) {
                    t.printStackTrace();
                }
            });


            sockets[i].open(request.build());
            sockets[i].fire("OPEN");
        }


        boolean pass = l.await(60, TimeUnit.SECONDS);
        try {

View Full Code Here

        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());


        Socket socket = client.create(b.build());


        socket.on("message", new Function<String>() {
            @Override
            public void on(String t) {
                logger.info("Serialized Function invoked {}", t);
                response.get().append(t);
                latch.countDown();
            }
        }).on(new Function<Throwable>() {


            @Override
            public void on(Throwable t) {
                System.out.println("=============== ERROR");
                t.printStackTrace();
            }


        }).open(request.build())
                .fire("PING")
                .fire("PONG").get();


        latch.await(5, TimeUnit.SECONDS);
        socket.close();

View Full Code Here


        final CountDownLatch latch = new CountDownLatch(1);
        final AtomicReference<String> response = new AtomicReference<String>();
        Client client = ClientFactory.getDefault().newClient();


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


        Socket socket = client.create();
        socket.on(Event.MESSAGE, new Function<String>() {
            @Override
            public void on(String t) {
                response.set(t);
                latch.countDown();
            }
        }).open(request.build()).fire("yoga");


        latch.await(5, TimeUnit.SECONDS);


        assertNotNull(response.get());
        assertEquals(response.get(), "yoga");

View Full Code Here

        final AtomicReference response2 = new AtomicReference();


        Client client = ClientFactory.getDefault().newClient();


        String unreachableUrl = "http://localhost:815";
        RequestBuilder request = client.newRequestBuilder()
                .method(Request.METHOD.GET)
                .uri(unreachableUrl + "/suspend")
                .transport(transport());


        final Socket socket = client.create();
        IOException ioException = null;
        try {


            socket.on(new Function<ConnectException>() {


                @Override
                public void on(ConnectException t) {
                    socket.close(); // I close it here, remove this close, issue will not happen
                    response.set(t);
                    latch.countDown();
                }


            }).on(new Function<IOException>() {


                @Override
                public void on(IOException t) {
                    response2.set(t);
                    latch.countDown();
                }


            }).open(request.build());
        } catch (IOException ex) {
            ioException = ex;
        }
        socket.fire("echo");
        latch.await(5, TimeUnit.SECONDS);

View Full Code Here

        server.start();


        final AtomicReference response = new AtomicReference();
        Client client = ClientFactory.getDefault().newClient();


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


        Socket socket = client.create(client.newOptionsBuilder().reconnect(false).build());
        socket.on(Event.CLOSE, new Function<String>() {
            @Override
            public void on(String t) {
                //Can I receive close message when server is stopped?
                logger.info("Function invoked {}", t);
                response.set(t);
            }
        }).on(new Function<Throwable>() {


            @Override
            public void on(Throwable t) {
                t.printStackTrace();
                latch.countDown();
            }


        }).open(request.build()).fire("PING");


        latch.await(5, TimeUnit.SECONDS);


        server.stop();
        socket.close();

View Full Code Here

0 1 2 3 4

TOP

Related Classes of org.atmosphere.wasync.RequestBuilder

org.atmosphere.tests.BaseTest

org.atmosphere.tests.LongPollingTest

org.atmosphere.tests.SSETest

org.atmosphere.tests.TypedTest

org.atmosphere.wasync.impl.DefaultClient

org.atmosphere.wasync.util.WebSocketLoader

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.