public Socket getSocket() {
        Client client = ClientFactory.getDefault().newClient();

        RequestBuilder request = client.newRequestBuilder()
                .method(Request.METHOD.GET)
                .uri("http://localhost:8080" + "/notification/async_socket/1")
                .encoder(new Encoder<Object, String>() {
                    @Override
                    public String encode(Object data) {
                        int a = 1;
                        return "ala";
                    }
                })
                .decoder(new Decoder<String, Object>() {
                    @Override
                    public Object decode(Event type, String data) {

                        data = data.trim();

                        // Padding
                        if (data.length() == 0) {
                            return null;
                        }

                        if (type.equals(Event.MESSAGE)) {
                                return "brak danych";
                        } else {
                            return null;
                        }
                    }
                })
                .transport(Request.TRANSPORT.LONG_POLLING);

        final org.atmosphere.wasync.Socket socket = client.create();
        socket.on("message", new Function<Object>() {
            @Override
            public void on(final Object t) {
                int w = 1;
            }
        }).on(new Function<Throwable>() {
            @Override
            public void on(Throwable t) {
                t.printStackTrace();
            }
        });

        try {
            socket.open(request.build());
            socket.fire("jacek");
        } catch (IOException e) {
            e.printStackTrace();
        }

        return mSocket;
	}