private void onMessage()

in grpc/syneroex/src/main/java/deltix/ember/connector/grpc/syneroex/session/Session.java [400:426]

• 23 lines of code
• 5 McCabe index (conditional complexity)

    private void onMessage(Message message) {
        if (message instanceof OrderResponse) { // order event
            logMessage(true, message);

            if (state.status().isConnecting()) {
                updateStatus(SessionStatus.APPLICATION_CONNECTED);
            }

            final OrderResponse response = (OrderResponse) message;
            listener.onAppMessage(response);
        } else if (message instanceof RequestAnswer) { // request/response
            final RequestAnswer answer = (RequestAnswer) message;
            try {
                // log inbound message if succeeded
                final Message response = answer.response();
                if (response != null) {
                    logMessage(true, response);
                }

                handleRequestAnswer(answer);
            } finally {
                requestAnswerPool.release(answer);
            }
        } else { // unknown message
            logMessage(true, message);
        }
    }