Method onMessage

src/main/java/fielded/webserver/Server.java:147–180

(WebSocket webSocket, String s)

                Log.log("remote.trace", () -> " message:<" + s + ">");
                JSONObject o = new JSONObject(s);
                String address = o.getString("address");
                Object payload = o.get("payload");
                Object originalPayload = payload;

                for (Handler h : new ArrayList<>(handlers)) {
                    if (h instanceof HandlerInMainThread) {
                        if (((HandlerInMainThread) h).will(Server.this, webSocket, address, payload)) {
                            final Object p = payload;
                            Server.this.queue(new Runnable() {
                                @Override
                                public void run() {
                                    currentWebSocket.set(webSocket);
                                    h.handle(Server.this, webSocket, address, p);

                                }
                            });
                            // not threading these all through the main thread means that we don't get backlogged nearly as easily

//                            } catch (InterruptedException | ExecutionException e) {
//                                Log.log("remote.error", " exception thrown by asynchronous websocket handler <" + h + "> while servicing <" + s + " / " + address + "
// ->" + originalPayload + " " + p, e);
//                            }
                        }
                    } else {
                        currentWebSocket.set(webSocket);
                        payload = h.handle(Server.this, webSocket, address, payload);
                    }
                }
            }

            @Override
            public void onError(WebSocket webSocket, Exception e) {
                Log.log("remote.error", () -> " websocket error reported :" + e);
                e.printStackTrace();
            }