It requests when connection is open, isn't it a right place to start WebSocket conversation ?
Thanks 2016-08-18 13:35 GMT+03:00 Pavel Rappo <pavel.ra...@oracle.com>: > This API was designed to work within "reactive pull" model [1]. In other > words, > in order to receive messages you must first request them ( see > WebSocket.request(long) ). > > As far as I can see, your code requests nothing. If you want to disable > reactive > pull completely, you can request Long.MAX_VALUE messages once and never > worry > about that ever again. > > Thanks. > > ------------------------------------------------------------ > -------------------- > [1] http://www.reactive-streams.org > > > On 18 Aug 2016, at 11:17, Rahman USTA <rahman.usta...@gmail.com> wrote: > > > > Hi Pavel; > > > > My WebSocket client is; > > > > URI uri = URI.create("ws://localhost:8080/merhaba"); > > MessageListener messageListener = new MessageListener(); > > > > WebSocket.newBuilder(uri, messageListener) > > .buildAsync() > > .join(); > > > > My MessageListener is here; > > > > public class MessageListener implements WebSocket.Listener { > > > > @Override > > public void onOpen(WebSocket webSocket) { > > webSocket.sendText("Ali"); > > webSocket.sendText("Ata"); > > webSocket.sendText("Bak"); > > } > > > > @Override > > public CompletionStage<?> onText(WebSocket webSocket, CharSequence > message, WebSocket.MessagePart part) { > > System.out.println("Gelen mesaj: " + message); > > return null; > > } > > > > @Override > > public void onClose(WebSocket webSocket, > Optional<WebSocket.CloseCode> code, String reason) { > > System.out.println("Closed.."); > > } > > > > @Override > > public void onError(WebSocket webSocket, Throwable error) { > > error.printStackTrace(); > > } > > } > > > > And the ServerEndpoint; > > > > @ServerEndpoint("/merhaba") > > public class MerhabaSoket { > > > > @OnError > > public void onerror(Throwable thr) { > > thr.printStackTrace(); > > } > > > > @OnMessage > > public void onmessage(Session session, String message) throws > IOException { > > session.getBasicRemote().sendText(message); > > } > > > > } > > > > Thanks > > > > > > 2016-08-18 13:08 GMT+03:00 Pavel Rappo <pavel.ra...@oracle.com>: > > Hi, > > > > Though it's not yet complete and some bugs are expected [1], I strongly > suspect > > the reason you don't receive any messages from the server might be due to > > MessageListener implementation. Could you please post its code? Thanks. > > > > ------------------------------------------------------------ > -------------------- > > [1] https://bugs.openjdk.java.net/browse/JDK-8161333?jql=labels% > 20%3D%20websocket%20and%20labels%20%3D%20jep-110% > 20and%20status%20not%20in%20(resolved%2C%20closed) > > > > > On 18 Aug 2016, at 10:38, Rahman USTA <rahman.usta...@gmail.com> > wrote: > > > > > > Hello; > > > > > > I try the WebSocket API in java.httpclient module; > > > > > > URI uri = URI.create("ws://localhost:8080/merhaba"); > > > MessageListener messageListener = new MessageListener(); > > > > > > WebSocket.newBuilder(uri, messageListener) > > > .buildAsync() > > > .join(); > > > > > > I have this code, it connects to WebSocket server, but after > connection it doesn't get messages sent from server. Is this feature ready > to test? > > > > > > Thanks. > > > > > > -- > > > Rahman USTA > > > Istanbul JUG > > > https://github.com/rahmanusta > > > > > > > > > > -- > > Rahman USTA > > Istanbul JUG > > https://github.com/rahmanusta > > -- Rahman USTA Istanbul JUG https://github.com/rahmanusta <http://www.kodcu.com/>
